能否通过Jedis将读写请求分别路由至ElastiCache主节点与只读节点？

Jedis不像Lettuce那样提供开箱即用的ReadFrom路由配置，但可以通过以下两种方式实现读写请求分别路由到ElastiCache的Primary Endpoint和Reader Endpoint：

方案一：手动拆分读写逻辑，维护双连接池 #

直接创建两个独立的JedisPool，分别对应主节点和只读节点端点，在业务代码中显式区分读写操作使用的连接池：

// 初始化主节点连接池（用于写操作）
JedisPoolConfig poolConfig = new JedisPoolConfig();
// 根据实际需求配置池参数（最大连接数、超时等）
poolConfig.setMaxTotal(20);
poolConfig.setMaxIdle(10);

JedisPool primaryPool = new JedisPool(poolConfig, "primary-endpoint.xxx.cache.amazonaws.com", 6379);

// 初始化只读节点连接池（用于读操作）
JedisPool readerPool = new JedisPool(poolConfig, "reader-endpoint.xxx.cache.amazonaws.com", 6379);

// 写操作示例
try (Jedis jedis = primaryPool.getResource()) {
    jedis.set("key", "value");
}

// 读操作示例
try (Jedis jedis = readerPool.getResource()) {
    String value = jedis.get("key");
}

方案二：封装工具类自动路由请求 #

如果不想在业务代码中显式区分连接池，可以封装一个工具类，根据Redis命令的类型自动选择对应的连接池：

public class RedisRouter {
    private final JedisPool primaryPool;
    private final JedisPool readerPool;

    public RedisRouter(String primaryEndpoint, String readerEndpoint) {
        JedisPoolConfig poolConfig = new JedisPoolConfig();
        poolConfig.setMaxTotal(20);
        poolConfig.setMaxIdle(10);
        this.primaryPool = new JedisPool(poolConfig, primaryEndpoint, 6379);
        this.readerPool = new JedisPool(poolConfig, readerEndpoint, 6379);
    }

    // 判断是否为读命令（可根据需求扩展命令列表）
    private boolean isReadCommand(String command) {
        Set<String> readCommands = new HashSet<>(Arrays.asList("GET", "HGET", "HMGET", "LRANGE", "SMEMBERS", "ZRANGE"));
        return readCommands.contains(command.toUpperCase());
    }

    public <T> T execute(String command, Function<Jedis, T> action) {
        JedisPool targetPool = isReadCommand(command) ? readerPool : primaryPool;
        try (Jedis jedis = targetPool.getResource()) {
            return action.apply(jedis);
        }
    }
}

// 使用示例
RedisRouter router = new RedisRouter("primary-endpoint.xxx.cache.amazonaws.com", "reader-endpoint.xxx.cache.amazonaws.com");
// 写操作
router.execute("SET", jedis -> {
    jedis.set("key", "value");
    return null;
});
// 读操作
String value = router.execute("GET", jedis -> jedis.get("key"));

注意事项 #

• ElastiCache的Reader Endpoint本身会自动将请求负载均衡到所有可用的只读节点，无需额外配置节点列表
• 确保Reader Endpoint的访问权限仅允许读操作，避免误写
• 根据业务压力调整连接池的参数（如maxTotal、maxIdle），避免连接耗尽
• 可在工具类中添加故障降级逻辑，比如当只读节点池不可用时，自动 fallback到主节点池

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