带有 Jedis 连接工厂、Redis 独立配置和多线程的 Spring Redis 模板

Question

我在多线程环境中使用 Spring Redis 模板。一个线程将数据保存到 Redis 中，另一个线程（调度程序）从中获取数据。JedisConnectionFactory 用于 redis 模板。以下是获取redis连接的代码片段：

JedisConnectionFactory jedisConnectionFactory() {

    JedisConnectionFactory jedisConnectionFactory = null;

    try {
        RedisStandaloneConfiguration redisStandaloneConfiguration = new RedisStandaloneConfiguration(hostName,
                port);
        jedisConnectionFactory = new JedisConnectionFactory(redisStandaloneConfiguration);
    } catch (RedisConnectionFailureException e) {
        LOGGER.error("Connection break with redis " + e.getMessage());
    }

    return jedisConnectionFactory;
}

/**
 * Redis template.
 *
 * @return the redis template
 */
@Bean
public RedisTemplate<String, Object> redisTemplate() {
    final RedisTemplate<String, Object> template = new RedisTemplate<String, Object>();
    template.setConnectionFactory(jedisConnectionFactory());
    template.setValueSerializer(new GenericToStringSerializer<Object>(Object.class));
    template.setEnableTransactionSupport(true);
    return template;
}

redis模板的实例是通过构造函数自动连线获取的，如下：

@Autowired
public A(RedisTemplate<String, Object> redisTemplate) {
    this.redisTemplate = redisTemplate;
}

使用 redis 模板的“findAll()”方法从 Redis 获取数据时出现异常：

org.springframework.data.redis.RedisConnectionFailureException: java.net.SocketException: Connection reset by peer: socket write error; 嵌套异常是 redis.clients.jedis.exceptions.JedisConnectionException: java.net.SocketException: Connection reset by peer: socket write error

以下是我的发现：

1. 当 TCP 套接字要“关闭”并且您的代码尚未收到通知时，会发生对等异常的连接重置。（ findAll 的线程尚未收到已关闭连接的通知）。
2. Redis 模板是线程安全的（仅当使用连接池时）并自行处理连接管理。可能会发生这样的情况：当线程将数据保存到 redis 并关闭连接时，仅在此期间，才会发生 fetch 操作并需要数据。在这种情况下，服务器可能发出了 RST 命令，但 fetch 操作可能没有获得它。
3. 可以使用 Jedis 池配置；但是这里有一些折旧的方法，以后可能会导致升级问题。

请建议使用“JedisConnectionFactory”、“RedisStandAloneConfiguration”和“RedisTemplate”处理多线程的最佳方法。

Answer 1

这个问题的原因是：

Redis 模板是线程安全的，但仅当它使用连接池时；如果未使用连接池，则同时连接调用会导致来自任一端（服务器/客户端）的 RST 信号，从而引发“对等连接重置”异常。所以，如果我们需要使用 Redis 模板，那么创建一个连接池并为池配置设置“maxIdle”和“maxTotal”。此外，请确保系统在任何情况下都不应该停机（休眠）。

正常工作的代码：

@Bean
JedisConnectionFactory jedisConnectionFactory() {

    JedisConnectionFactory jedisConnectionFactory = null;

    try {
        RedisStandaloneConfiguration redisStandaloneConfiguration = new RedisStandaloneConfiguration(hostName,
                port);
        jedisConnectionFactory = new JedisConnectionFactory(redisStandaloneConfiguration);
        jedisConnectionFactory.getPoolConfig().setMaxTotal(50);
        jedisConnectionFactory.getPoolConfig().setMaxIdle(50);
    } catch (RedisConnectionFailureException e) {
        e.getMessage();
    }

    return jedisConnectionFactory;
}


@Bean
public RedisTemplate<String, Object> redisTemplate() {
    final RedisTemplate<String, Object> template = new RedisTemplate<String, Object>();
    template.setConnectionFactory(jedisConnectionFactory());
    template.setValueSerializer(new GenericToStringSerializer<Object>(Object.class));
    template.setEnableTransactionSupport(true);
    return template;
}