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

package main

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

// 定義一個(gè)全局變量
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個(gè)庫(kù)，指定其中一個(gè)庫(kù)即可
	})
	_,err = redisdb.Ping(ctx).Result()
	return
}

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

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

		//連接池容量及閑置連接數(shù)量
		PoolSize:     15, // 連接池最大socket連接數(shù)，默認(rèn)為4倍CPU數(shù)， 4 * runtime.NumCPU
		MinIdleConns: 10, //在啟動(dòng)階段創(chuàng)建指定數(shù)量的Idle連接，并長(zhǎng)期維持idle狀態(tài)的連接數(shù)不少于指定數(shù)量；。

		//超時(shí)
		DialTimeout:  5 * time.Second, //連接建立超時(shí)時(shí)間，默認(rèn)5秒。
		ReadTimeout:  3 * time.Second, //讀超時(shí)，默認(rèn)3秒， -1表示取消讀超時(shí)
		WriteTimeout: 3 * time.Second, //寫超時(shí)，默認(rèn)等于讀超時(shí)
		PoolTimeout:  4 * time.Second, //當(dāng)所有連接都處在繁忙狀態(tài)時(shí)，客戶端等待可用連接的最大等待時(shí)長(zhǎng)，默認(rèn)為讀超時(shí)+1秒。

		//閑置連接檢查包括IdleTimeout，MaxConnAge
		IdleCheckFrequency: 60 * time.Second, //閑置連接檢查的周期，默認(rèn)為1分鐘，-1表示不做周期性檢查，只在客戶端獲取連接時(shí)對(duì)閑置連接進(jìn)行處理。
		IdleTimeout:        5 * time.Minute,  //閑置超時(shí)，默認(rèn)5分鐘，-1表示取消閑置超時(shí)檢查
		MaxConnAge:         0 * time.Second,  //連接存活時(shí)長(zhǎng)，從創(chuàng)建開始計(jì)時(shí)，超過指定時(shí)長(zhǎng)則關(guān)閉連接，默認(rèn)為0，即不關(guān)閉存活時(shí)長(zhǎng)較長(zhǎng)的連接

		//命令執(zhí)行失敗時(shí)的重試策略
		MaxRetries:      0,                      // 命令執(zhí)行失敗時(shí)，最多重試多少次，默認(rèn)為0即不重試
		MinRetryBackoff: 8 * time.Millisecond,   //每次計(jì)算重試間隔時(shí)間的下限，默認(rèn)8毫秒，-1表示取消間隔
		MaxRetryBackoff: 512 * time.Millisecond, //每次計(jì)算重試間隔時(shí)間的上限，默認(rèn)512毫秒，-1表示取消間隔

		//可自定義連接函數(shù)
		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")
		},

		//鉤子函數(shù)
		OnConnect: func(ctx context.Context, conn *redis.Conn) error { //僅當(dāng)客戶端執(zhí)行命令時(shí)需要從連接池獲取連接時(shí)，如果連接池需要新建連接時(shí)則會(huì)調(diào)用此鉤子函數(shù)
			fmt.Printf("conn=%v\n", conn)
			return nil
		},
	})