【Redis】已解决：redis.clients.jedis.exceptions.JedisRedirectionException

屿小夏

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

840

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

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

已解决：redis.clients.jedis.exceptions.JedisRedirectionException

一、分析问题背景

在使用Redis进行缓存或数据存储时，开发者通常会用到Jedis客户端库来与Redis服务器进行交互。有时会遇到redis.clients.jedis.exceptions.JedisRedirectionException的报错。此异常通常发生在Redis集群环境中，当客户端请求被重定向到不同的Redis节点时出现问题。

场景：在一个Spring Boot项目中，开发者使用Jedis客户端连接到Redis集群进行数据存取操作。以下是一个典型的代码片段：

import redis.clients.jedis.JedisCluster;
import redis.clients.jedis.HostAndPort;
import java.util.HashSet;
import java.util.Set;

public class RedisClient {
    public static void main(String[] args) {
        Set<HostAndPort> jedisClusterNodes = new HashSet<>();
        jedisClusterNodes.add(new HostAndPort("127.0.0.1", 6379));
        JedisCluster jedisCluster = new JedisCluster(jedisClusterNodes);

        // 尝试存取数据
        jedisCluster.set("key", "value");
        String value = jedisCluster.get("key");
        System.out.println("Value: " + value);
    }
}

在上述代码中，如果Redis集群的节点配置或请求路由出现问题，就可能抛出JedisRedirectionException异常。

二、可能出错的原因

导致redis.clients.jedis.exceptions.JedisRedirectionException报错的原因主要有以下几点：

Redis集群配置错误：节点配置不正确，导致请求无法正确路由。
节点故障或不可用：集群中的某些节点不可用或故障，导致请求无法完成。
客户端版本不兼容：Jedis客户端版本与Redis服务器版本不兼容，导致重定向请求处理失败。
网络问题：客户端与Redis服务器之间的网络连接不稳定，导致请求失败。

三、错误代码示例

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

import redis.clients.jedis.JedisCluster;
import redis.clients.jedis.HostAndPort;
import java.util.HashSet;
import java.util.Set;

public class RedisClient {
    public static void main(String[] args) {
        Set<HostAndPort> jedisClusterNodes = new HashSet<>();
        jedisClusterNodes.add(new HostAndPort("127.0.0.1", 6379));  // 仅配置一个节点

        JedisCluster jedisCluster = new JedisCluster(jedisClusterNodes);

        // 尝试存取数据
        jedisCluster.set("key", "value");  // 可能抛出JedisRedirectionException
        String value = jedisCluster.get("key");
        System.out.println("Value: " + value);
    }
}

错误分析：

节点配置不完整：仅配置了一个节点，没有包含集群中的所有节点，导致请求无法正确路由。

四、正确代码示例

为了解决该报错问题，我们可以确保配置了所有Redis集群节点，并确保集群节点之间的通信正常。以下是正确的代码示例：

import redis.clients.jedis.JedisCluster;
import redis.clients.jedis.HostAndPort;
import java.util.HashSet;
import java.util.Set;

public class RedisClient {
    public static void main(String[] args) {
        Set<HostAndPort> jedisClusterNodes = new HashSet<>();
        jedisClusterNodes.add(new HostAndPort("127.0.0.1", 6379));
        jedisClusterNodes.add(new HostAndPort("127.0.0.1", 6380));
        jedisClusterNodes.add(new HostAndPort("127.0.0.1", 6381));
        // 添加所有集群节点
        jedisClusterNodes.add(new HostAndPort("127.0.0.1", 6382));
        jedisClusterNodes.add(new HostAndPort("127.0.0.1", 6383));
        jedisClusterNodes.add(new HostAndPort("127.0.0.1", 6384));

        JedisCluster jedisCluster = new JedisCluster(jedisClusterNodes);

        // 尝试存取数据
        jedisCluster.set("key", "value");
        String value = jedisCluster.get("key");
        System.out.println("Value: " + value);
    }
}

通过上述代码，我们确保了所有集群节点都已正确配置，能够避免JedisRedirectionException异常。