Redis的cluster集群

public classRedisShardPoolTest {

        staticShardedJedisPool pool;

        static{

                JedisPoolConfig config = new JedisPoolConfig();//Jedis池配置
config.setMaxActive(500);//最大活动的对象个数
config.setMaxIdle(1000 * 60);//对象最大空闲时间
config.setMaxWait(1000 * 10);//获取对象时最大等待时间
config.setTestOnBorrow(true);

                String hostA = "127.0.0.1";

                int portA = 6378;

                String hostB = "127.0.0.1";

                int portB = 6379;

                List<JedisShardInfo> jdsInfoList = new ArrayList<JedisShardInfo>(2);

                JedisShardInfo infoA = newJedisShardInfo(hostA, portA);

                infoA.setPassword("testpass");

                JedisShardInfo infoB = newJedisShardInfo(hostB, portB);

                infoB.setPassword("testpass");

                jdsInfoList.add(infoA);

                jdsInfoList.add(infoB);

                pool = newShardedJedisPool(config, jdsInfoList, Hashing.MURMUR_HASH,

                Sharded.DEFAULT_KEY_TAG_PATTERN);


        }

        /**
         * 
         * @param args
         * 
         */

        public static voidmain(String[] args) {

                for (int i = 0; i < 100; i++) {

                        String key =generateKey();
                        ShardedJedis jds = null;

                        try{
                                jds =pool.getResource();

                                System.out.println(key + ":"
                                                +jds.getShard(key).getClient().getHost());
                                System.out.println(key + ":"
                                                +jds.getShard(key).getClient().getPort());

                                System.out.println(jds.get(key));
                                System.out.println(jds.set(key,"1111111111111111111111111111111"));
                        } catch(Exception e) {
                                e.printStackTrace();
                        }
                        finally{
                                pool.returnResource(jds);

                        }
                }
        }

        private static int index = 1;

        public staticString generateKey() {

                return String.valueOf(Thread.currentThread().getId()) + "_" + (index++);

        }

}