java连接redis集群

向右看齐 2022-06-14 06:55 267阅读 0赞 
  1. package redis;
  3. import java.util.HashSet;
  4. import java.util.Set;
  6. import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
  8. import redis.clients.jedis.HostAndPort;
  9. import redis.clients.jedis.JedisCluster;
  11. public class ClusterDemo {
  12.     private static JedisCluster jedisCluster=null;
  13.     private static Set<HostAndPort> hostAndPorts=null;
  15.     public static  Set<HostAndPort> getHostAndPort(String hostAndPort){
  16.         Set<HostAndPort> hap = new HashSet<HostAndPort>();
  17.         String[] hosts = hostAndPort.split(",");
  18.         String[] hs = null;
  19.         for(String host:hosts){
  20.             hs=host.split(":");
  21.             hap.add(new HostAndPort(hs[0], Integer.parseInt(hs[1])));
  22.         }
  23.         return hap;
  24.     }
  26.     public static JedisCluster getJedisCluster(){
  27.         GenericObjectPoolConfig gopc = new GenericObjectPoolConfig();
  28.         gopc.setMaxTotal(32);
  29.         gopc.setMaxIdle(4);
  30.         gopc.setMaxWaitMillis(6000);
  31.         hostAndPorts = getHostAndPort("192.168.10.250:6379");
  32.         jedisCluster = new JedisCluster(hostAndPorts, 2000, 2000, 3,"redis123456",gopc);
  33.         return jedisCluster;
  34.     }
  36.     public static void main(String[] args) {
  37.         jedisCluster = getJedisCluster();
  38.         System.out.println(jedisCluster.get("name"));
  39.     }
  40. }

发表评论

表情：
评论列表 （有 0 条评论，267人围观）

还没有评论，来说两句吧...

相关阅读