package com.cb.test;

import java.util.HashMap;
import java.util.HashSet;
import java.util.Map;
import java.util.Set;
import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.JedisCluster;
import redis.clients.jedis.JedisPoolConfig;

public class MyRedisCluster {
	public static void main(String[] args) {
		
		Set<HostAndPort> clusterNodes = new HashSet<HostAndPort>();
		clusterNodes.add(new HostAndPort("192.168.0.203", 6379));
		clusterNodes.add(new HostAndPort("192.168.0.204", 6379));
		clusterNodes.add(new HostAndPort("192.168.0.205", 6379));
		clusterNodes.add(new HostAndPort("192.168.0.206", 6379));
		clusterNodes.add(new HostAndPort("192.168.0.207", 6379));
		clusterNodes.add(new HostAndPort("192.168.0.208", 6379));
		
		JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
		jedisPoolConfig.setMaxTotal(50);//最大連線個數
		jedisPoolConfig.setMaxIdle(10);//最大空閒連線個數
		jedisPoolConfig.setMaxWaitMillis(-1);//獲取連線時的最大等待毫秒數，若超時則拋異常。-1代表不確定的毫秒數
		jedisPoolConfig.setTestOnBorrow(true);//獲取連線時檢測其有效性 
	    JedisCluster jedisCluster = new JedisCluster(clusterNodes,15000,100,
	    		jedisPoolConfig);//第二個引數：超時時間     第三個引數：最大嘗試重連次數	    
	    
	    Map<String,String> map=new HashMap<String,String>();
		
	    jedisCluster.set("id", "1");
	    jedisCluster.set("name", "cb");
	    jedisCluster.set("age", "10");
		
	    System.out.println(jedisCluster.get("id"));
	    System.out.println(jedisCluster.get("name"));
	    System.out.println(jedisCluster.get("age"));
	    
		jedisCluster.close();//關閉jedisCluster	
	}
}