public static void main(String[] args) throws IOException{
Set<HostAndPort> jedisClusterNode = new HashSet<HostAndPort>();
jedisClusterNode.add(new HostAndPort("ip",7001));//添加对应机器的ip地址和端口号
jedisClusterNode.add(new HostAndPort("ip",7002));
jedisClusterNode.add(new HostAndPort("ip",7003));
jedisClusterNode.add(new HostAndPort("ip",7004));
jedisClusterNode.add(new HostAndPort("ip",7005));
jedisClusterNode.add(new HostAndPort("ip",7006));
JedisPoolConfig config = new JedisPoolConfig();
config.setMaxTotal(100);//设置最大连接数
config.setMaxIdle(10);//设置最大空闲连接
JedisCluster jedisCluster = new JedisCluster(jedisClusterNode,5000,10,config);
//jedisClusterNode 服务节点信息
//5000 设置连接超时的最大时间
//10 循环尝试连接次数
//config jedis连接池配置
// TODO codeing Redis Opreate
jedisCluster.close();
}
测试几个操作吧
System.out.println(jedisCluster.set("stu","xiaoming"));
System.out.println(jedisCluster.set("age","18"));
System.out.println(jedisCluster.get("stu"));
System.out.println(jedisCluster.get("age"));
然后去redis客户端查询:
在7001查询得到,age对应的值
在7001查询stu,提示stu在7003服务器上
其实这就是redis cluster集群写的时候,默认是按照服务器轮询的