# 查看集群信息
redis-cli -p 7000 cluster info

# 列出集群節(jié)點(diǎn)
redis-cli -p 7000 cluster nodes

# 檢查節(jié)點(diǎn)狀態(tài)
redis-cli -p 7000 ping

<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>4.0.1</version>
</dependency>

import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.JedisCluster;
import redis.clients.jedis.exceptions.JedisConnectionException;

import java.util.HashSet;
import java.util.Set;

public class RedisClusterCommunicationExample {
    public static void main(String[] args) {
        // 定義 Redis 集群節(jié)點(diǎn)
        Set<HostAndPort> jedisClusterNodes = new HashSet<>();
        jedisClusterNodes.add(new HostAndPort("127.0.0.1", 7000));
        jedisClusterNodes.add(new HostAndPort("127.0.0.1", 7001));
        jedisClusterNodes.add(new HostAndPort("127.0.0.1", 7002));
        jedisClusterNodes.add(new HostAndPort("127.0.0.1", 7003));
        jedisClusterNodes.add(new HostAndPort("127.0.0.1", 7004));
        jedisClusterNodes.add(new HostAndPort("127.0.0.1", 7005));

        // 創(chuàng)建 JedisCluster 對(duì)象
        try (JedisCluster jedisCluster = new JedisCluster(jedisClusterNodes)) {
            // 檢測(cè)節(jié)點(diǎn)狀態(tài)
            for (HostAndPort node : jedisClusterNodes) {
                try {
                    String result = jedisCluster.ping();
                    System.out.println("Node " + node + " is online: " + result);
                } catch (JedisConnectionException e) {
                    System.err.println("Node " + node + " is offline.");
                }
            }

            // 手動(dòng)發(fā)送 PING 命令檢測(cè)某個(gè)節(jié)點(diǎn)狀態(tài)
            try (redis.clients.jedis.Jedis jedis = new redis.clients.jedis.Jedis("127.0.0.1", 7000)) {
                String pingResponse = jedis.ping();
                System.out.println("PING response from node 7000: " + pingResponse);
            }

            // 模擬 MEET 命令將新節(jié)點(diǎn)加入集群
            // Note: 需要手動(dòng)啟動(dòng) redis-server 并配置為此示例中的新節(jié)點(diǎn)
            try (redis.clients.jedis.Jedis jedis = new redis.clients.jedis.Jedis("127.0.0.1", 7000)) {
                String meetResponse = jedis.clusterMeet("127.0.0.1", 7006);
                System.out.println("MEET response: " + meetResponse);
            }
            
            // 獲取集群節(jié)點(diǎn)信息
            String clusterNodes = jedisCluster.clusterNodes();
            System.out.println("Cluster nodes:\n" + clusterNodes);

        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}