bind 172.28.18.75
port 25701
masterauth "Zaq1xsw@"
requirepass "Zaq1xsw@"
protected-mode yes
daemonize yes
dir "/etc/redis"
pidfile "/var/run/redis_25701.pid"
loglevel notice
logfile "redis-25701.log"
dbfilename "dump-25701.rdb"

cluster-enabled yes
cluster-node-timeout 15000
cluster-config-file node-25701.conf
cluster-require-full-coverage no

public class RedisClusterTest {
    private static Logger logger=LoggerFactory.getLogger(RedisClusterTest.class);
    
    public static void main(String[] args) throws InterruptedException{
        JedisCluster jedis;
        //添加集群的服务节点Set集合
        Set<HostAndPort> hostAndPortsSet =new HashSet<HostAndPort>();
        //添加集群节点信息
        hostAndPortsSet.add(new HostAndPort("172.28.18.75",25701));
        hostAndPortsSet.add(new HostAndPort("172.28.18.103",25701));
        hostAndPortsSet.add(new HostAndPort("172.28.18.104",25701));

        //连接池配置
        JedisPoolConfig config = new JedisPoolConfig();
        //最大连接数, 默认8个
        config.setMaxTotal(500);
        //最大空闲连接数, 默认8个
        config.setMaxIdle(100);
        //最小空闲连接数, 默认0
        config.setMinIdle(0);
        //获取连接时的最大等待毫秒数(如果设置为阻塞时BlockWhenExhausted),如果超时就抛异常, 小于零:阻塞不确定的时间,  默认-1
        config.setMaxWaitMillis(2000); // 设置2秒
        //对拿到的connection进行validateObject校验
        config.setTestOnBorrow(true);
        jedis=new JedisCluster(hostAndPortsSet,config);
        System.out.println("===========增加数据===========");
        System.out.println(jedis.set("key1","value1"));
        System.out.println(jedis.set("key2","value2"));
        System.out.println(jedis.set("key3", "value3"));
        System.out.println("获取键key2:"+jedis.get("key2"));
        System.out.println("获取key1的值："+jedis.get("key1"));
        System.out.println("key3的值："+jedis.get("key3"));
        
    }
}