【Redis】已解决：redis.clients.jedis.exceptions.JedisClusterMaxRedirectionsException: Too many Cluster red

屿小夏

发布于 2024-08-11 08:22:30

1340

发布于 2024-08-11 08:22:30

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

已解决：redis.clients.jedis.exceptions.JedisClusterMaxRedirectionsException: Too many Cluster redirections

一、分析问题背景

在使用Jedis与Redis集群进行交互时，开发者可能会遇到redis.clients.jedis.exceptions.JedisClusterMaxRedirectionsException: Too many Cluster redirections的报错。该异常通常发生在访问Redis集群时，由于集群节点的重定向次数过多，导致操作失败。

典型场景是当应用程序频繁访问Redis集群并尝试进行数据读写操作时，遇到了节点重定向次数超过默认限制的问题。以下是一个典型的代码片段：

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

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

public class RedisClusterExample {

    public static void main(String[] args) {
        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));
        
        JedisCluster jedisCluster = new JedisCluster(jedisClusterNodes);

        // 执行读写操作
        jedisCluster.set("key", "value");
        System.out.println(jedisCluster.get("key"));
    }
}

在上述代码中，如果Redis集群配置不当或网络不稳定，可能会导致JedisClusterMaxRedirectionsException异常。

二、可能出错的原因

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

集群节点配置错误：Redis集群节点配置错误或节点状态不稳定，导致频繁的重定向。
网络不稳定：网络连接不稳定，导致集群节点之间的通信出现问题。
重定向次数限制：Jedis客户端默认的最大重定向次数限制过低，无法处理复杂的重定向场景。

三、错误代码示例

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

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

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

public class RedisClusterExample {

    public static void main(String[] args) {
        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));
        
        // 创建JedisCluster对象，但未设置最大重定向次数
        JedisCluster jedisCluster = new JedisCluster(jedisClusterNodes);

        // 执行读写操作
        jedisCluster.set("key", "value");
        System.out.println(jedisCluster.get("key"));
    }
}

错误分析：

未设置最大重定向次数：在创建JedisCluster对象时，未设置最大重定向次数，导致在重定向次数过多时抛出异常。

四、正确代码示例

为了解决该报错问题，我们可以增加最大重定向次数，并确保集群节点配置正确。以下是正确的代码示例：

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

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

public class RedisClusterExample {

    public static void main(String[] args) {
        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));
        
        // 创建JedisPoolConfig对象，并设置最大重定向次数
        JedisPoolConfig poolConfig = new JedisPoolConfig();
        poolConfig.setMaxTotal(10); // 最大连接数
        poolConfig.setMaxRedirections(10); // 最大重定向次数

        JedisCluster jedisCluster = new JedisCluster(jedisClusterNodes, poolConfig);

        // 执行读写操作
        jedisCluster.set("key", "value");
        System.out.println(jedisCluster.get("key"));
    }
}

通过上述代码，我们设置了最大重定向次数，并确保了Redis集群节点配置的正确性，从而避免JedisClusterMaxRedirectionsException异常。