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

Posted on by

前言

Redis是一個開源的內存數據庫，在項目開發中redis的使用也比較頻繁，本文介紹瞭Go語言中go-redis庫的基本使用。感興趣的小夥伴們可以參考借鑒，希望對大傢能有所幫助。

安裝依賴包

Go語言中使用第三方庫go-redis

go-redis支持連接哨兵及集群模式的Redis。

使用以下命令下載並安裝:

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

連接redis

新建go文件，在項目中引入github.com/go-redis/redis/v8，

初始化redis.Client，廢話不多說，直接上代碼。

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 : %v\n",err)
		return
	}
	fmt.Println("redis連接成功！")
}

註意： 最新版本的go-redis庫的相關命令都需要傳遞context.Context參數。

redis連接池

通過golang對redis操作，還可以通過redis連接池，流程如下：

（1）事先初始化一定數量的連接，投入到連接池；

（2）當go需要操作redis時，直接從連接池取出連接即可；

（3）這樣可以節省臨時獲取redis的時間，從而提高效率；

go-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=%v\n", conn)
			return nil
		},
	})

總結

本文主要為您介紹瞭，如何使用go的第三方包go-redis連接Redis。

更多詳情操作請查看官方文檔

到此這篇關於一文搞懂Go語言操作Redis的方法的文章就介紹到這瞭,更多相關Go語言操作Redis內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet！

推薦閱讀：