java程序连接redis集群
2019-07-19 本文已影响0人
吃西瓜的的小青年
1.1连接步骤
1.1.1第一步:创建项目,导入jar包

1.1.2第二步:创建redis集群的客户端
package cn.gzsxt.jedis.test;
import java.util.HashSet;
import java.util.Set;
import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.JedisCluster;
public class TestJedisCluster {
public static void main(String[] args) {
//1、创建jedidsCluster客户端
//创建一个set集合,用来封装所有redis节点的信息
Set<HostAndPort> nodes = new HashSet<>();
nodes.add(new HostAndPort("192.168.23.12", 7001));
nodes.add(new HostAndPort("192.168.23.12", 7002));
nodes.add(new HostAndPort("192.168.23.12", 7003));
nodes.add(new HostAndPort("192.168.23.12", 7004));
nodes.add(new HostAndPort("192.168.23.12", 7005));
nodes.add(new HostAndPort("192.168.23.12", 7006));
nodes.add(new HostAndPort("192.168.23.12", 7007));
nodes.add(new HostAndPort("192.168.23.12", 7008));
JedisCluster cluster = new JedisCluster(nodes);
String name = cluster.get("user:id:1:name");
cluster.set("user:id:1:address", "你好呀");
String address = cluster.get("user:id:1:address");
System.out.println("name:"+name);
System.out.println("address:"+address);
if(null!=cluster){
cluster.close();
}
}
}
1.2注意事项:
连接Redis集群时,需要修改防火墙,开方每一个redis节点的端口。
说明:如果要开发一个范围的端口,可以使用冒号来分割,即: 7001:7008,表示开发7001-7008之间所有的端口

1.3测试

访问Redis-cluster集群成功!!!