一文搞懂Go語言操作Redis的方法

go get -u github.com/go-redis/redis/v8

package main

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

// 定義一個全域性變數
var redisdb *redis.Client
var ctx = context.Background()

func initRedis()(err error){
	redisdb = redis.NewClient(&redis.Options{
		Addr: "127.0.0.1:6379",  // 指定
		Password: "",
		DB:0,		// redis一共16個庫，指定其中一個庫即可
	})
	_,err = redisdb.Ping(ctx).Result()
	return
}

func main() {
	err := initRedis()
	if err != nil {
		fmt.Printf("connect redis failed! err : %vn",err)
		return
	}
	fmt.Println("redis連線成功！")
}

redisdb = redis.NewClient(&redis.Options{
		Addr: "127.0.0.1:6379",  // 指定
		Password: "",
		DB:0,		// redis一共16個庫，指定其中一個庫即可

		//連線池容量及閒置連線數量
		PoolSize:     15, // 連線池最大socket連線數，預設為4倍CPU數， 4 * runtime.NumCPU
		MinIdleConns: 10, //在啟動階段建立指定數量的Idle連線，並長期維持idle狀態的連線數不少於指定數量；。

		//超時
		DialTimeout:  5 * time.Second, //連線建立超時時間，預設5秒。
		ReadTimeout:  3 * time.Second, //讀超時，預設3秒， -1表示取消讀超時
		WriteTimeout: 3 * time.Second, //寫超時，預設等於讀超時
		PoolTimeout:  4 * time.Second, //當所有連線都處在繁忙狀態時，使用者端等待可用連線的最大等待時長，預設為讀超時+1秒。

		//閒置連線檢查包括IdleTimeout，MaxConnAge
		IdleCheckFrequency: 60 * time.Second, //閒置連線檢查的週期，預設為1分鐘，-1表示不做週期性檢查，只在使用者端獲取連線時對閒置連線進行處理。
		IdleTimeout:        5 * time.Minute,  //閒置超時，預設5分鐘，-1表示取消閒置超時檢查
		MaxConnAge:         0 * time.Second,  //連線存活時長，從建立開始計時，超過指定時長則關閉連線，預設為0，即不關閉存活時長較長的連線

		//命令執行失敗時的重試策略
		MaxRetries:      0,                      // 命令執行失敗時，最多重試多少次，預設為0即不重試
		MinRetryBackoff: 8 * time.Millisecond,   //每次計算重試間隔時間的下限，預設8毫秒，-1表示取消間隔
		MaxRetryBackoff: 512 * time.Millisecond, //每次計算重試間隔時間的上限，預設512毫秒，-1表示取消間隔

		//可自定義連線函數
		Dialer: func(ctx context.Context, network, addr string) (net.Conn, error) {
			netDialer := &net.Dialer{
				Timeout:   5 * time.Second,
				KeepAlive: 5 * time.Minute,
			}
			return netDialer.Dial("tcp", "127.0.0.1:6379")
		},

		//勾點函數
		OnConnect: func(ctx context.Context, conn *redis.Conn) error { //僅當用戶端執行命令時需要從連線池獲取連線時，如果連線池需要新建連線時則會呼叫此勾點函數
			fmt.Printf("conn=%vn", conn)
			return nil
		},
	})