禁用集群模式下，AWS ElastiCache Redis读写分离实现及Go语言库问询

嘿，刚好踩过这个坑，来给你详细说下怎么搞：

AWS ElastiCache禁用集群模式的Redis是标准的主从架构（1个主节点+N个副本节点），要实现读写分离核心在客户端路由逻辑，具体步骤如下：

• 获取正确的端点：在ElastiCache控制台找到你的Redis集群，你会看到两个关键端点：
  • 「主端点（Primary Endpoint）」：指向当前的主节点，所有写操作必须走这里，强一致性场景的读操作也可以走这里。
  • 「集群只读端点（Cluster Reader Endpoint）」：这是AWS提供的负载均衡端点，会自动轮询所有可用的副本节点，普通读操作走这个端点即可，不用自己维护多个副本的地址。
• 客户端路由配置：
  • 写请求（比如SET、DEL、HSET等）：绑定主端点的连接，所有写操作都通过这个连接发送。
  • 读请求（比如GET、HGET、SMEMBERS等）：绑定集群只读端点的连接，利用AWS的自动负载均衡分发到副本节点。
• 额外注意事项：
  • 主从同步存在毫秒级延迟，如果业务要求强一致性读（比如写完立刻读），还是得走主节点；如果能接受最终一致性，用副本读即可。
  • 主节点故障自动切换后，主端点会自动指向新选举的主节点，客户端无需手动修改地址，非常省心。

你之前找到的可能是专门针对集群模式的库，其实主流Go Redis库都完美支持这种非集群模式的主从读写分离，推荐两个最常用的：

1. redis/go-redis（原go-redis/redis） #

这是目前最流行的Go Redis客户端，API友好、文档齐全、社区活跃，完全适配你的场景。核心思路是创建两个独立的客户端：一个连主节点负责读写，一个连只读端点负责只读。

示例代码：

package main

import (
    "context"
    "fmt"
    "github.com/redis/go-redis/v9"
)

func main() {
    // 初始化主节点客户端（负责所有写操作，强一致性读也可以用）
    primaryClient := redis.NewClient(&redis.Options{
        Addr:     "your-primary-endpoint:6379",
        Password: "", // 有密码的话填这里
        DB:       0,
    })

    // 初始化副本只读客户端（负责普通读操作）
    replicaClient := redis.NewClient(&redis.Options{
        Addr:     "your-cluster-reader-endpoint:6379",
        Password: "",
        DB:       0,
    })

    // 写操作示例
    err := primaryClient.Set(context.Background(), "username", "john_doe", 0).Err()
    if err != nil {
        panic(err)
    }

    // 读操作示例
    username, err := replicaClient.Get(context.Background(), "username").Result()
    if err != nil {
        panic(err)
    }
    fmt.Println("读取到用户名：", username)
}

2. redigo #

老牌轻量级Redis客户端，适合喜欢底层连接控制的开发者。可以创建两个连接池，分别绑定主节点和只读端点，写操作从主池拿连接，读操作从副本池拿连接。

示例代码：

package main

import (
    "github.com/gomodule/redigo/redis"
    "log"
)

// 初始化主节点和副本节点的连接池
var primaryPool *redis.Pool
var replicaPool *redis.Pool

func init() {
    primaryPool = &redis.Pool{
        MaxIdle: 10, // 最大空闲连接数
        Dial: func() (redis.Conn, error) {
            return redis.Dial("tcp", "your-primary-endpoint:6379")
        },
    }

    replicaPool = &redis.Pool{
        MaxIdle: 10,
        Dial: func() (redis.Conn, error) {
            return redis.Dial("tcp", "your-cluster-reader-endpoint:6379")
        },
    }
}

func main() {
    // 写操作
    conn := primaryPool.Get()
    defer conn.Close()
    _, err := conn.Do("SET", "age", 28)
    if err != nil {
        log.Fatalf("写操作失败：%v", err)
    }

    // 读操作
    conn = replicaPool.Get()
    defer conn.Close()
    age, err := redis.Int(conn.Do("GET", "age"))
    if err != nil {
        log.Fatalf("读操作失败：%v", err)
    }
    log.Printf("读取到年龄：%d", age)
}

• 不要用集群模式的客户端（比如redis.NewClusterClient），因为你的集群禁用了集群模式，普通客户端完全够用。
• 优先使用AWS提供的「集群只读端点」，不用自己手动管理副本节点列表，AWS会自动处理副本的增减和故障切换。

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