Spring data redis与莴苣客户端和AWS elasticcache

Question

我使用springboot 2.3.9.RELEASE的莴苣客户端连接AWS redis elasticcache主/从。I'am able to write and read but a error is抛出每隔5000ms一次

这项服务对我的pourpose很好，但我想删除错误或知道如何修复它。

我已经读了很多关于它的书，用AWS配置spring数据redis的最好方法是使用RedisticMasterReplicaConfiguration来写主副本和从副本读取。

这是bean配置

    @Bean
    public LettuceConnectionFactory redisConnectionFactory() {

        LettuceClientConfiguration.LettuceClientConfigurationBuilder lettuceConfigBuilder = LettuceClientConfiguration.builder()
                .readFrom(ReadFrom.REPLICA_PREFERRED);
        lettuceConfigBuilder.useSsl();

        RedisStaticMasterReplicaConfiguration redisConfiguration = new RedisStaticMasterReplicaConfiguration(master, port); //master value is the Primary Endpoint value from aws elasticcache info
        redisConfiguration.addNode(replica, port); //replica value is the Reader Endpoint value from aws elasticcache info
        redisConfiguration.setPassword(password);

        return new LettuceConnectionFactory(redisConfiguration, lettuceConfigBuilder.build());
    }

当应用程序启动时，我能够写入和读取，但每5秒就会从RedisMessageListenerContainer抛出错误

"level":"ERROR","className":"org.springframework.data.redis.listener.RedisMessageListenerContainer","message":"Connection failure occurred. Restarting subscription task after 5000 ms "

但这是RedisMessageListenerContainer.handleSubscriptionException的原始错误

java.lang.UnsupportedOperationException: Pub/Sub connections not supported with Master/Replica configurations

Answer 1

遗憾的是，RedisticMasterReplicaConfiguration不支持发布/订阅。详见下文。

https://docs.spring.io/html" target="_blank">spring-data/redis/docs/current/reference/html/#redis:write-从复制副本中主控读取

对于通过INFO命令报告非公共地址的环境（例如，当使用AWS时），请使用redisticmasterreplicationconfiguration而不是redistandaloneconfiguration。请注意，RedisticMasterReplicaConfiguration不支持发布/订阅，因为在各个服务器之间缺少发布/订阅消息传播。