在 Golang 中操作 Redis 集群模式下进行 SCAN 操作时,通常可以使用 ClusterClient 提供的 Iterate 方法。这个方法会自动遍历集群中的所有分片,并且可以应对分片迁移和节点变更等情况。
示例代码如下:
import (
"fmt"
"github.com/go-redis/redis/v8"
)
func main() {
client := redis.NewClusterClient(&redis.ClusterOptions{
Addrs: []string{"node1:6379", "node2:6379", "node3:6379"},
})
var cursor uint64 = 0
for {
keys, newCursor, err := client.Scan(ctx, cursor, "", 10).Result()
if err != nil {
fmt.Println("Error:", err)
return
}
for _, key := range keys {
fmt.Println("Key:", key)
// 这里可以执行其他操作,比如获取键值对等
}
cursor = newCursor
if cursor == 0 {
break
}
}
}
上述代码使用了 ClusterClient 的 Scan 方法进行遍历,在循环中处理每一批返回的键值对。不需要单独使用 ForEachMaster 方法来处理。
内容由零声教学AI助手提供,问题来源于学员提问