shardedJedis没法设置DB的问题

        本人一直从事java研发，java版本的redis客户端一般使用的是jedis。在以前生产开发过程当中，redis主要以单机形式或者主备读写分离形式使用，并未涉及到分片等高级功能。最近，因为业务量激增，单机redis的性能出现了瓶颈，主要是redis消耗cpu太高。因而，想采用数据分片的方式，将请求路由到其余redis实例上去，下降单机redis的压力，该方案具体的实现方式是使用客户端的ShardedJedis对象来实现数据分片。

  因为系统以前的缓存设计使用了redis多个db分区存储数据，在使用ShardedJedis分片存取的过程当中发现，ShardedJedis不支持动态选择DB，该对象没有select功能。为何呢？ShardedJedis其实是一个虚拟链接，一个ShardJedis对应了多个物理链接，经过一致性哈希算法计算key的哈希值，而后得到相应的物理链接，再发送存储命令，实现存储操做。ShardJedis中对应的物理链接必须保持一致，才能保证分片存储数据的一致性，所以，ShardJedis不支持select操做。

  若是必定要实现选择DB，怎么办呢？也不是没有办法的，只要把ShardJedis对应的全部物理链接客户端都设置为同一个db便可，下面是代码示例：

public class RedisShardPoolTest {
    private static ShardedJedisPool shardedJedisPool;
    static {
        JedisPoolConfig poolConfig = new JedisPoolConfig();
        poolConfig.setMaxTotal(100);
        poolConfig.setMaxIdle(50);
        poolConfig.setMinIdle(10);
        poolConfig.setMaxWaitMillis(1000 * 60);
        poolConfig.setTestOnBorrow(true);

        String host = "127.0.0.1";
        int portA = 6379;
        int portB = 6378;

        List<JedisShardInfo> jdsInfoList = new ArrayList<JedisShardInfo>(2);
        JedisShardInfo infoA = new JedisShardInfo(host, portA);
        JedisShardInfo infoB = new JedisShardInfo(host, portB);
        jdsInfoList.add(infoA);
        jdsInfoList.add(infoB);
        shardedJedisPool = new ShardedJedisPool(poolConfig, jdsInfoList);
    }

    public static void main(String[] args) {
        ShardedJedis jds = shardedJedisPool.getResource();
        Collection<Jedis> collection=jds.getAllShards();
        Iterator<Jedis> jedis = collection.iterator();
        while(jedis.hasNext()){
            jedis.next().select(1);
        }

        ShardedJedisPipeline pipeline = jds.pipelined();

        for(int i=0; i<100; i++) {
            String key = generateKey();
            System.out.println(key + ":" + jds.getShard(key).getClient().getPort());
            System.out.println(pipeline.set(key,Math.random() + ""));
        }

        pipeline.sync();
    }

    private static int index = 1;
    public static String generateKey(){
         return String.valueOf(Thread.currentThread().getId())+"_"+(index++);
    }
}