您好,登錄后才能下訂單哦!
本文小編為大家詳細(xì)介紹“Go語(yǔ)言中怎么使用Redis”,內(nèi)容詳細(xì),步驟清晰,細(xì)節(jié)處理妥當(dāng),希望這篇“Go語(yǔ)言中怎么使用Redis”文章能幫助大家解決疑惑,下面跟著小編的思路慢慢深入,一起來(lái)學(xué)習(xí)新知識(shí)吧。
Go語(yǔ)言中使用第三方庫(kù)go-redis
go-redis支持連接哨兵及集群模式的Redis。
使用以下命令下載并安裝:
go get -u github.com/go-redis/redis/v8
新建go
文件,在項(xiàng)目中引入github.com/go-redis/redis/v8
,
初始化redis.Client
,廢話不多說(shuō),直接上代碼。
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連接成功!") }
注意: 最新版本的go-redis
庫(kù)的相關(guān)命令都需要傳遞context.Context
參數(shù)。
通過(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: "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, //寫(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(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 }, })
讀到這里,這篇“Go語(yǔ)言中怎么使用Redis”文章已經(jīng)介紹完畢,想要掌握這篇文章的知識(shí)點(diǎn)還需要大家自己動(dòng)手實(shí)踐使用過(guò)才能領(lǐng)會(huì),如果想了解更多相關(guān)內(nèi)容的文章,歡迎關(guān)注億速云行業(yè)資訊頻道。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。