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

Question

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;
}

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

我在使用Redis模板的“findAll（）”方法从Redis获取数据时遇到一个异常：

org.springframework.data.redis.redisconnectionfailureexception：java.net.socketexception：对等体重置连接：套接字写入错误；嵌套异常为redis.clients.jedis.exceptions.jedisconnectionexception：java.net.socketexception：对等体重置连接：套接字写入错误

以下是我的发现：

null

Answer 1

这个问题的原因是：

Redis模板是线程安全的，但仅当它使用连接池时；如果不使用连接池，那么同时进行的连接调用将导致来自（服务器/客户端）任何一方的RST信号，从而引发“对等端的连接重置”异常。因此，如果我们需要使用Redis模板，那么创建一个连接池，并为池配置设置“max idle”和“max total”。此外，确保系统在任何情况下都不应该关闭（Hibernate）。

正常工作的代码：

@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;
}