（十一）Redis集群JedisCluster实现keys命令方法

由于JedisCluster集群类不支持像单机模式下的keys方法，下面的类我们就模拟keys命令方法：
一、获取集群类
package redis.v1.client.server;

import java.util.ArrayList;
import java.util.Date;
import java.util.HashSet;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Set;

import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisCluster;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
import redis.v1.client.common.RedisClusterOperator;
import utils.DateUtil;

public class JedisClusterClient {

private static JedisCluster cluster = null;

static {
if(cluster == null) {
Set<HostAndPort> clusterNodes = new HashSet<HostAndPort>();
clusterNodes.add(new HostAndPort("127.0.0.1", 7001));
clusterNodes.add(new HostAndPort("127.0.0.1", 7002));
clusterNodes.add(new HostAndPort("127.0.0.1", 7003));
clusterNodes.add(new HostAndPort("127.0.0.1", 7004));
clusterNodes.add(new HostAndPort("127.0.0.1", 7005));
clusterNodes.add(new HostAndPort("127.0.0.1", 7006));

JedisPoolConfig config = new JedisPoolConfig();
//控制一个pool可分配多少个jedis实例，通过pool.getResource()来获取；
//如果赋值为-1，则表示不限制；如果pool已经分配了maxActive个jedis实例，则此时pool的状态为exhausted(耗尽)。
config.setMaxTotal(50);
//控制一个pool最多有多少个状态为idle(空闲的)的jedis实例。
config.setMaxIdle(5);
//表示当borrow(引入)一个jedis实例时，最大的等待时间，如果超过等待时间，则直接抛出JedisConnectionException；单位毫秒
//小于零:阻塞不确定的时间, 默认-1
config.setMaxWaitMillis(1000*100);
//在borrow(引入)一个jedis实例时，是否提前进行validate操作；如果为true，则得到的jedis实例均是可用的；
config.setTestOnBorrow(true);
//return 一个jedis实例给pool时，是否检查连接可用性（ping()）
config.setTestOnReturn(true);

/**
* @param nodes 集群服务器地址
* @param connectionTimeout 连接超时 （毫秒）
* @param soTimeout 响应超时（毫秒）
* @param maxAttempts 出现异常最大重试次数
*/
cluster = new JedisCluster(clusterNodes, 2000, 2000, 10, config);
// cluster = new JedisCluster(clusterNodes, 2000, 2000, 10, "619868", config);
}
}
/**
*
* 方法描述 获取集群对象
*
* @return
*
* @author yaomy
* @date 2018年1月18日 上午11:17:05
*/
public static JedisCluster getRedisCluster() {
return cluster;
}

}
二、模拟keys命令方法类package redis.v1.client.common;

import java.util.Iterator;
import java.util.Map;
import java.util.TreeSet;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.v1.client.server.JedisClusterClient;

public class RedisClusterOperator {

/**
*
*KEYS pattern
*查找所有符合给定模式 pattern 的 key 。
*KEYS * 匹配数据库中所有 key 。
*KEYS h?llo 匹配 hello ， hallo 和 hxllo 等。
*KEYS h*llo 匹配 hllo 和 heeeeello 等。
*KEYS h[ae]llo 匹配 hello 和 hallo ，但不匹配 hillo 。
*特殊符号用 \ 隔开
* @param pattern
* @return
*
* @author yaomy
* @date 2018年1月18日 上午11:20:02
*/
public static TreeSet<String> keys(String pattern) {
TreeSet<String> keys = new TreeSet<String>();
Map<String, JedisPool> clusterNodes = JedisClusterClient.getRedisCluster().getClusterNodes();
for(Iterator<JedisPool> it=clusterNodes.values().iterator();it.hasNext();) {
JedisPool pool = it.next();
Jedis jedis = pool.getResource();
try {
keys.addAll(jedis.keys(pattern));
} catch (Exception e) {
System.out.println("获取keys发生异常！");
} finally {
jedis.close();
}
}
return keys;
}
}