生菜-Java-AWS ElastiCache-Redis-连接超时

Question

我对Redis和AWS弹性缓存服务完全陌生。我创建了一个Redis集群（5.0.6 v），其中包含1个碎片，2个节点，没有加密传输，没有静态加密，没有Redis Auth和多AZ禁用。

我可以看到主endpoint，阅读器endpoint和单击集群，可以看到两个节点endpoint不同于主endpoint和阅读器endpoint。

我正在使用带有普通maven项目的莴苣进行连接，但连接超时。我尝试了以上所有endpoint的组合，但没有成功。我已经将我的ec2instance（运行代码的地方）添加到ElastiCache子网组中。还是不走运。

使用的代码：

RedisClusterClient clusterClient = RedisClusterClient.create(Arrays.asList(node1, node2));
StatefulRedisClusterConnection<String, String> connection = clusterClient.connect();
RedisAdvancedClusterAsyncCommands<String, String> asyncCommands = connection.async();

POM（仅依赖项）：

 <dependency>
            <groupId>io.lettuce</groupId>
            <artifactId>lettuce-core</artifactId>
            <version>5.2.2.RELEASE</version>
 </dependency>

我有普通java-maven的用例，没有像Spring引导这样的框架

谢谢你的帮助。

Answer 1

如果有人在寻找连接到ElastiCache primary的类似问题，这可能会有所帮助：修改安全组入站流量，并解决以下客户端创建模型：

RedisURI upstreamUri = RedisURI.Builder.redis(primayNodeUrl, 6379).build();
RedisClient redisClient = RedisClient.create();
StatefulRedisMasterReplicaConnection<String, String> connection = 
MasterReplica.connect(
                redisClient,
                StringCodec.UTF8,
                upstreamUri);
connection.setReadFrom(ReadFrom.REPLICA_PREFERRED);
RedisAsyncCommands<String, String> asyncCommands = connection.async();