Golang连接Redis集群

安装redis集群

https://www.cnblogs.com/wxx999/p/14855040.html

Demo

建立连接

RedisCluster/connect/connect.go

package connect

import (
	"github.com/go-redis/redis/v8"
	"time"
)

var Cluster *redis.ClusterClient

func init() {
	Cluster = redis.NewClusterClient(&redis.ClusterOptions{
		Addrs:              []string{
			"192.168.31.251:7001",
			"192.168.31.251:7002",
			"192.168.31.251:7003",
			"192.168.31.251:7004",
			"192.168.31.251:7005",
			"192.168.31.251:7006",
		},
		DialTimeout:        100 * time.Microsecond,
		ReadTimeout:        100 * time.Microsecond,
		WriteTimeout:       100 * time.Microsecond,
	})
}

写入并读取

RedisCluster/demo/sample.go

package demo

import (
	"RedisCluster/connect"
	"context"
	"fmt"
	"time"
)

const SampleDemoKey = "SampleDemoKey"

func SampleDemo()  {
	// 写入数据，并设置10分钟缓存
	connect.Cluster.Set(context.TODO(), SampleDemoKey, "666", 10 * time.Minute)

	cmd := connect.Cluster.Get(context.TODO(), SampleDemoKey)

	result, err := cmd.Result()
	fmt.Println("err:", err)
	fmt.Println("result:", result)
}

测试
main.go

package main

import "RedisCluster/demo"

func main() {
	demo.SampleDemo()
}

demo地址

https://github.com/wxxhub/GoDemo/tree/main/RedisCluster