Spring Data Redis：如何实现每个RedisTemplate独占共享Lettuce连接

问题根源
当设置sharedNativeConnection=true时，LettuceConnectionFactory默认会复用同一个RedisClient实例（尤其是Spring Boot自动配置场景下）。而RedisClient是Lettuce连接的核心管理器，它会维护自身的连接池与共享连接。如果两个ConnectionFactory共用同一个RedisClient，即便配置了不同主机，也会出现连接跨实例共享的情况，导致操作错误关联到其他主机的连接。

解决方案 #

1. 为每个LettuceConnectionFactory创建独立的RedisClient实例 #

必须确保每个连接工厂拥有专属的RedisClient，绝对禁止复用。手动创建RedisClient并绑定到对应ConnectionFactory：

@Configuration
public class MultiRedisConfig {

    // 第一个Redis实例的配置
    @Bean("redisTemplateHost1")
    public RedisTemplate<String, Object> redisTemplateHost1() {
        RedisTemplate<String, Object> template = new RedisTemplate<>();
        template.setConnectionFactory(connectionFactoryHost1());
        configureDefaultSerializer(template);
        return template;
    }

    @Bean("connectionFactoryHost1")
    public LettuceConnectionFactory connectionFactoryHost1() {
        RedisStandaloneConfiguration standaloneConfig = new RedisStandaloneConfiguration("host1", 6379);
        // 创建独立的RedisClient
        RedisClient redisClient = RedisClient.create(standaloneConfig.getUrl());
        
        LettuceClientConfiguration clientConfig = LettuceClientConfiguration.builder()
                .sharedNativeConnection(true)
                .build();
        
        LettuceConnectionFactory factory = new LettuceConnectionFactory(standaloneConfig, clientConfig);
        factory.setRedisClient(redisClient);
        factory.afterPropertiesSet();
        return factory;
    }

    // 第二个Redis实例的配置
    @Bean("redisTemplateHost2")
    public RedisTemplate<String, Object> redisTemplateHost2() {
        RedisTemplate<String, Object> template = new RedisTemplate<>();
        template.setConnectionFactory(connectionFactoryHost2());
        configureDefaultSerializer(template);
        return template;
    }

    @Bean("connectionFactoryHost2")
    public LettuceConnectionFactory connectionFactoryHost2() {
        RedisStandaloneConfiguration standaloneConfig = new RedisStandaloneConfiguration("host2", 6379);
        // 必须创建新的RedisClient，不能复用host1的实例
        RedisClient redisClient = RedisClient.create(standaloneConfig.getUrl());
        
        LettuceClientConfiguration clientConfig = LettuceClientConfiguration.builder()
                .sharedNativeConnection(true)
                .build();
        
        LettuceConnectionFactory factory = new LettuceConnectionFactory(standaloneConfig, clientConfig);
        factory.setRedisClient(redisClient);
        factory.afterPropertiesSet();
        return factory;
    }

    // 通用序列化配置
    private void configureDefaultSerializer(RedisTemplate<String, Object> template) {
        StringRedisSerializer stringSerializer = new StringRedisSerializer();
        template.setKeySerializer(stringSerializer);
        template.setHashKeySerializer(stringSerializer);
        template.setValueSerializer(new GenericJackson2JsonRedisSerializer());
        template.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());
        template.afterPropertiesSet();
    }
}

2. 隔离连接池配置（如果使用连接池） #

如果启用了Lettuce连接池（如GenericObjectPool），需确保每个ConnectionFactory使用独立的池配置实例，禁止共用同一个GenericObjectPoolConfig对象：

// 在每个ConnectionFactory的创建方法中单独初始化池配置
GenericObjectPoolConfig poolConfig = new GenericObjectPoolConfig();
poolConfig.setMaxTotal(20);
poolConfig.setMaxIdle(10);

LettuceClientConfiguration clientConfig = LettuceClientConfiguration.builder()
        .sharedNativeConnection(true)
        .poolConfig(poolConfig)
        .build();

3. 排除自动配置的RedisClient复用 #

若使用Spring Boot，默认的RedisAutoConfiguration会创建全局RedisClient，可能被多个ConnectionFactory复用。可通过以下方式排除自动配置，完全手动管理所有Redis连接组件：

@SpringBootApplication(exclude = RedisAutoConfiguration.class)
public class YourApplication {
    public static void main(String[] args) {
        SpringApplication.run(YourApplication.class, args);
    }
}

4. 验证配置有效性 #

调试时打印每个ConnectionFactory的RedisClient哈希值，确认它们是不同的实例：

// 在配置类或测试代码中执行
System.out.println("ConnectionFactory1 RedisClient hashCode: " + connectionFactoryHost1().getRedisClient().hashCode());
System.out.println("ConnectionFactory2 RedisClient hashCode: " + connectionFactoryHost2().getRedisClient().hashCode());

若两个哈希值不同，说明RedisClient已完全独立，连接不会再跨实例共享。

内容的提问来源于stack exchange，提问作者aneri