Vertx RedisClient连接关闭集群模式ElastiCache读分流配置

配置未生效的核心原因 #

之前读命令没有分流的问题，和Vertx客户端的适配逻辑、AWS托管架构的特点直接相关：

• AWS文档提到的集群只读端点，本质是挂载了所有从节点地址的DNS轮询域名，并不是Redis协议层面支持自动读分流的路由入口。Vertx默认的Redis客户端会永久缓存DNS解析结果，一旦第一次解析拿到某一个从节点的地址，就只会和这个固定节点维持连接池通信，根本不会自动轮询切换其他从节点。
• 之前尝试配置的RedisRole.SENTINEL，适配的是自建开源哨兵模式的场景：客户端需要主动和哨兵节点通信，拉取实时的主从拓扑结构来路由命令。但AWS ElastiCache集群模式禁用的场景下，哨兵逻辑是AWS内部托管的，所有对外暴露的业务节点都不响应SENTINEL协议的查询命令，配置这个角色后客户端根本拿不到拓扑信息，自然识别不到从节点做分流。

实际可落地的实现方案 #

这种非分片的主从副本集群场景下，Vertx客户端没有内置适配AWS托管拓扑的自动发现逻辑，最稳定的实现方式是读写客户端拆分，手动路由，步骤如下：

• 先从AWS控制台拿到主节点、所有从节点的独立可访问端点，不要把只读域名当唯一连接入口。
• 构造写入专用的独立客户端，只绑定主节点的连接地址，所有写操作、强一致要求的读操作都走这个客户端，示例配置：

  RedisOptions writeClientOptions = new RedisOptions()
      .setType(RedisClientType.STANDALONE)
      .addConnectionString("redis://<主节点独立端点>:6379")
      .setPassword("<集群访问密码>")
      .setMaxPoolSize(8); // 按业务写入峰值调整连接池大小
  Redis writeClient = Redis.createClient(vertx, writeClientOptions);
  

• 构造读取专用的独立客户端，把所有从节点的独立端点逐个加入连接列表，客户端会自动在所有配置的从节点连接之间做轮询负载，把读命令均匀分发到不同从节点上，示例配置：

  RedisOptions readClientOptions = new RedisOptions()
      .setType(RedisClientType.STANDALONE)
      // 逐个填入所有从节点的独立端点
      .addConnectionString("redis://<从节点1独立端点>:6379")
      .addConnectionString("redis://<从节点2独立端点>:6379")
      .addConnectionString("redis://<从节点3独立端点>:6379")
      .setPassword("<集群访问密码>")
      .setMaxPoolSize(16); // 按每个从节点分配2-3个连接的规模调整
  Redis readClient = Redis.createClient(vertx, readClientOptions);
  

• 业务代码层面做路由分流：所有写入操作、需要读取最新数据的强一致读操作走writeClient，允许最终一致的普通读操作走readClient。

额外优化提示：如果不想硬编码从节点地址列表，可以写一个轻量定时任务，每隔1-2分钟调用AWS资源接口拉取当前集群的所有从节点端点，动态更新读客户端的连接池配置，节点扩缩容、主从切换时也不需要手动修改代码重启服务。

内容的提问来源于stack exchange，提问作者ליאור יעקובוב