为ElastiCache主/从配置Spring Data Redis和莴苣

Question

我有一个带有一个主服务器和两个从服务器的Elasticache设置。我仍然不确定如何传递主从RedisURI列表以构建StatefulRedisMasterSlaveConnection用于LettuceConnectionFactory。我只看到对具有单个主机和端口的标准配置的支持。

LettuceClientConfiguration configuration = LettuceTestClientConfiguration.builder().readFrom(ReadFrom.SLAVE).build();
LettuceConnectionFactory factory = new LettuceConnectionFactory(SettingsUtils.standaloneConfiguration(),configuration);

我知道在为Redis主/从配置Spring Data Redis时会遇到类似的问题

但我认为它不适用于ElastiCache主/从设置，因为目前上述代码将尝试使用MasterSlaveTopologyProvider来发现从IP。但是，从属IP地址不可访问。那么，配置Spring Data Redis以使其与主/从ElastiCache兼容的正确方法是什么？在我看来，LettuceConnectionFactory需要接受endpoint列表并使用StaticMasterSlaveTopologyProvider才能工作。

Answer 1

目前，Spring Data Redis不支持提供endpoint的静态主/从。我开了一张罚单来支持这一点。

您可以通过子类化LettuceConnectionFactory、创建自己的配置和LettuceConnectionFactory来自己实现此功能。

您可以从以下内容开始：

public static class MyLettuceConnectionFactory extends LettuceConnectionFactory {

    private final MyMasterSlaveConfiguration configuration;

    public MyLettuceConnectionFactory(MyMasterSlaveConfiguration standaloneConfig,
            LettuceClientConfiguration clientConfig) {
        super(standaloneConfig, clientConfig);
        this.configuration = standaloneConfig;
    }

    @Override
    protected LettuceConnectionProvider doCreateConnectionProvider(AbstractRedisClient client, RedisCodec<?, ?> codec) {
        return new ElasticacheConnectionProvider((RedisClient) client, codec, getClientConfiguration().getReadFrom(),
                this.configuration);
    }
}

static class MyMasterSlaveConfiguration extends RedisStandaloneConfiguration {

    private final List<RedisURI> endpoints;

    public MyMasterSlaveConfiguration(List<RedisURI> endpoints) {
        this.endpoints = endpoints;
    }

    public List<RedisURI> getEndpoints() {
        return endpoints;
    }
}

您可以在此要点中找到所有代码，而不是在此处发布所有代码，因为这将是一堵代码墙。

Answer 2

AWS和莴苣有了进一步的改进，使支持主/从变得更加容易。

AWS最近的一个改进是，它为Redis启动了读卡器endpoint，在副本之间分配负载：Amazon ElastiCache为Redis启动了读卡器endpoint。

因此，使用Spring Data Redis连接到Redis的最佳方式是使用Redis集群的主要endpoint（主endpoint）和读取器endpoint（用于副本）。

您可以从AWS控制台获取它们。这是一个示例代码：

@Bean
public LettuceConnectionFactory redisConnectionFactory() {
    LettuceClientConfiguration clientConfig = LettuceClientConfiguration.builder()
            .readFrom(ReadFrom.SLAVE_PREFERRED)
            .build();
    RedisStaticMasterReplicaConfiguration redisStaticMasterReplicaConfiguration =
            new 
     RedisStaticMasterReplicaConfiguration(REDIS_CLUSTER_PRIMARY_ENDPOINT, redisPort);
    redisStaticMasterReplicaConfiguration.addNode(REDIS_CLUSTER_READER_ENDPOINT, redisPort);
    redisStaticMasterReplicaConfiguration.setPassword(redisPassword);
    return new LettuceConnectionFactory(redisStaticMasterReplicaConfiguration, clientConfig);
}