第一文搞懂Go語(yǔ)言操作Redis的方法目錄前言安裝依賴包連接redisredis連接池總結(jié)

前言

Redis是一個(gè)開(kāi)源的內(nèi)存數(shù)據(jù)庫(kù)，在項(xiàng)目開(kāi)發(fā)中redis的使用也比較頻繁，本文介紹了Go語(yǔ)言中g(shù)o-redis庫(kù)的基本使用。感興趣的小伙伴們可以參考借鑒，希望對(duì)大家能有所幫助。

安裝依賴包

Go語(yǔ)言中使用第三方庫(kù)go-redis

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

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

goget-u/go-redis/redis/v8

連接redis

新建go文件，在項(xiàng)目中引入/go-redis/redis/v8，

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

packagemain

import(

"context"

"fmt"

"/go-redis/redis/v8"

//定義一個(gè)全局變量

varredisdb*redis.Client

varctx=context.Background()

funcinitRedis()(errerror){

redisdb=redis.NewClient(redis.Options{

Addr:":6379",//指定

Password:"",

DB:0,//redis一共16個(gè)庫(kù)，指定其中一個(gè)庫(kù)即可

_,err=redisdb.Ping(ctx).Result()

return

funcmain(){

err:=initRedis()

iferr!=nil{

fmt.Printf("connectredisfailed!err:%v\n",err)

return

fmt.Println("redis連接成功！")

}

注意：最新版本的go-redis庫(kù)的相關(guān)命令都需要傳遞context.Context參數(shù)。

redis連接池

通過(guò)golang對(duì)redis操作，還可以通過(guò)redis連接池，流程如下：

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

（2）當(dāng)go需要操作redis時(shí)，直接從連接池取出連接即可；

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

go-redis模塊自帶連接池，所有參數(shù)都是可選的，參數(shù)配置說(shuō)明示例如下：

redisdb=redis.NewClient(redis.Options{

Addr:":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,//寫(xiě)超時(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)建開(kāi)始計(jì)時(shí)，超過(guò)指定時(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(ctxcontext.Context,network,addrstring)(net.Conn,error){

netDialer:=net.Dialer{

Timeout:5*time.Second,

KeepAlive:5*time.Minute,

returnnetDialer.Dial("tcp",":6379")

//鉤子函數(shù)

OnConnect:func(ctxcontext.Context,conn*redis.Conn)error{//僅當(dāng)客戶端執(zhí)行命令時(shí)需要從連接池獲取連接時(shí)，如果連接池需要新建連接時(shí)則會(huì)調(diào)用