java客户端测试redis集群

package com.hr.cluster; import java.io.IOException; import java.util.HashSet; import java.util.Set; import redis.clients.jedis.HostAndPort; import redis.clients.jedis.JedisCluster; public class JedisDemo { public static void main(String[] args) throws IOException { Set<HostAndPort> nodes = new HashSet<>(); nodes.add(new HostAndPort("192.168.33.128", 7001)); nodes.add(new HostAndPort("192.168.33.128", 7002)); nodes.add(new HostAndPort("192.168.33.128", 7003)); nodes.add(new HostAndPort("192.168.33.128", 7004)); nodes.add(new HostAndPort("192.168.33.128", 7005)); nodes.add(new HostAndPort("192.168.33.128", 7006)); nodes.add(new HostAndPort("192.168.33.128", 7007)); JedisCluster cluster = new JedisCluster(nodes); cluster.set("s5", "5555"); String result = cluster.get("s5"); System.out.println("cluster=========>"+result); cluster.close(); } }