【Redis】已解决：redis.clients.jedis.exceptions.JedisNoReachableClusterNodeException: No reachable node in

屿小夏

发布于 2024-08-12 08:19:25

3030

发布于 2024-08-12 08:19:25

文章被收录于专栏：IT杂谈学习

已解决：redis.clients.jedis.exceptions.JedisNoReachableClusterNodeException: No reachable node in cluster

一、分析问题背景

在使用Jedis客户端连接Redis集群时，开发者可能会遇到redis.clients.jedis.exceptions.JedisNoReachableClusterNodeException: No reachable node in cluster的报错。该异常通常发生在尝试连接Redis集群的过程中，表示无法找到可访问的集群节点。以下是一个典型的场景：

场景：在一个Java应用程序中，开发者尝试连接一个Redis集群来进行缓存操作，但是在初始化JedisCluster对象时遇到了上述异常。

示例代码片段：

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

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

public class RedisClusterConnection {

    public static void main(String[] args) {
        Set<HostAndPort> nodes = new HashSet<>();
        nodes.add(new HostAndPort("127.0.0.1", 7000));
        nodes.add(new HostAndPort("127.0.0.1", 7001));
        nodes.add(new HostAndPort("127.0.0.1", 7002));

        JedisCluster jedisCluster = new JedisCluster(nodes);
        System.out.println("Connected to Redis cluster");
    }
}

在上述代码中，如果Redis集群节点不可达，将会抛出JedisNoReachableClusterNodeException。

二、可能出错的原因

导致JedisNoReachableClusterNodeException报错的原因主要有以下几点：

网络问题：客户端与Redis集群之间的网络连接存在问题，导致无法访问集群节点。
集群节点配置错误：配置的Redis集群节点信息错误或节点未启动。
防火墙设置：防火墙设置阻止了客户端与Redis集群之间的通信。
Redis集群状态异常：Redis集群节点处于故障状态或未正确配置。

三、错误代码示例

以下是一个可能导致该报错的代码示例，并解释其错误之处：

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

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

public class RedisClusterConnection {

    public static void main(String[] args) {
        Set<HostAndPort> nodes = new HashSet<>();
        // 配置了错误的端口
        nodes.add(new HostAndPort("127.0.0.1", 7000));
        nodes.add(new HostAndPort("127.0.0.1", 7001));
        nodes.add(new HostAndPort("127.0.0.1", 9999)); // 错误的端口

        JedisCluster jedisCluster = new JedisCluster(nodes);
        System.out.println("Connected to Redis cluster");
    }
}

错误分析：

错误的节点端口配置：代码中配置了一个错误的端口（9999），导致无法连接到Redis集群的所有节点。

四、正确代码示例

为了解决该报错问题，我们需要确保配置正确的集群节点信息，并确保网络连接正常。以下是正确的代码示例：

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

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

public class RedisClusterConnection {

    public static void main(String[] args) {
        Set<HostAndPort> nodes = new HashSet<>();
        // 正确配置Redis集群节点
        nodes.add(new HostAndPort("127.0.0.1", 7000));
        nodes.add(new HostAndPort("127.0.0.1", 7001));
        nodes.add(new HostAndPort("127.0.0.1", 7002));

        // 添加连接超时和读取超时参数
        int timeout = 2000; // 2秒
        int maxAttempts = 5; // 最大重试次数

        JedisCluster jedisCluster = new JedisCluster(nodes, timeout, timeout, maxAttempts, "password", new JedisPoolConfig());
        System.out.println("Connected to Redis cluster");

        // 使用jedisCluster执行操作
        jedisCluster.set("key", "value");
        System.out.println("Value for 'key': " + jedisCluster.get("key"));
    }
}

通过上述代码，我们可以确保正确配置Redis集群节点，并增加连接和读取超时参数，确保在网络状况不佳时能够进行重试。