redis断线重连 springboot

在 Spring Boot 中使用 Redis 的过程中，如果 Redis 服务器由于某些原因宕机或网络中断，那么就需要重新连接 Redis 服务器。以下是在 Spring Boot 中实现 Redis 断线重连的步骤：

1. 在 application.properties 或 application.yml 文件中配置 Redis 连接参数，例如：

spring.redis.host=127.0.0.1
spring.redis.port=6379
spring.redis.password=
spring.redis.database=0

2. 创建 RedisConnectionFactory 实例，并设置 Redis 连接参数。可以使用默认的 JedisConnectionFactory 或自定义的 LettuceConnectionFactory。例如：

@Configuration
public class RedisConfig {

    @Value("${spring.redis.host}")
    private String host;

    @Value("${spring.redis.port}")
    private int port;

    @Value("${spring.redis.password}")
    private String password;

    @Value("${spring.redis.database}")
    private int database;

    @Bean
    public RedisConnectionFactory redisConnectionFactory() {
        LettuceConnectionFactory lettuceConnectionFactory = new LettuceConnectionFactory();
        lettuceConnectionFactory.setHostName(host);
        lettuceConnectionFactory.setPort(port);
        lettuceConnectionFactory.setPassword(password);
        lettuceConnectionFactory.setDatabase(database);
        lettuceConnectionFactory.afterPropertiesSet();
        return lettuceConnectionFactory;
    }
}

3. 创建 RedisTemplate 实例，并设置 RedisConnectionFactory。例如：

@Configuration
public class RedisConfig {

    ...

    @Bean
    public RedisTemplate<String, Object> redisTemplate() {
        RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
        redisTemplate.setConnectionFactory(redisConnectionFactory());
        redisTemplate.setKeySerializer(new StringRedisSerializer());
        redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());
        redisTemplate.afterPropertiesSet();
        return redisTemplate;
    }
}

4. 在 RedisConnectionFactory 上添加 ConnectionListener 监听器，用于监听 Redis 连接状态变化。例如：

@Configuration
public class RedisConfig {

    ...

    @Bean
    public RedisConnectionFactory redisConnectionFactory() {
        LettuceConnectionFactory lettuceConnectionFactory = new LettuceConnectionFactory();
        lettuceConnectionFactory.setHostName(host);
        lettuceConnectionFactory.setPort(port);
        lettuceConnectionFactory.setPassword(password);
        lettuceConnectionFactory.setDatabase(database);
        lettuceConnectionFactory.afterPropertiesSet();

        lettuceConnectionFactory.addConnectionListener(new RedisConnectionListener());

        return lettuceConnectionFactory;
    }

    private static class RedisConnectionListener implements RedisConnectionFailureListener {

        private final Logger logger = LoggerFactory.getLogger(RedisConnectionListener.class);

        @Override
        public void onMasterFailure(RedisException e) {
            logger.error("Redis master failure", e);
        }

        @Override
        public void onSlaveFailure(RedisException e) {
            logger.error("Redis slave failure", e);
        }

        @Override
        public void onRefresh(RedisConnection connection) {
            logger.info("Redis connection refresh");
        }
    }
}

在 RedisConnectionFailureListener 中，可以根据不同的 RedisException 进行不同的处理。例如，当 RedisException 是连接异常时，可以进行重连操作，例如：

@Override
public void onMasterFailure(RedisException e) {
    logger.error("Redis master failure", e);
    if (e instanceof RedisConnectionException) {
        redisConnectionFactory.resetConnection();
    }
}

这样，在 Redis 服务器宕机或网络中断时，RedisConnectionFactory 就会自动进行重连操作。