GO語言使用 Redis數(shù)據(jù)庫

可以參考： windows環(huán)境下redis的安裝

創(chuàng)新互聯(lián)是一家集網(wǎng)站建設,河池企業(yè)網(wǎng)站建設,河池品牌網(wǎng)站建設,網(wǎng)站定制,河池網(wǎng)站建設報價,網(wǎng)絡營銷,網(wǎng)絡優(yōu)化,河池網(wǎng)站推廣為一體的創(chuàng)新建站企業(yè)，幫助傳統(tǒng)企業(yè)提升企業(yè)形象加強企業(yè)競爭力。可充分滿足這一群體相比中小企業(yè)更為豐富、高端、多元的互聯(lián)網(wǎng)需求。同時我們時刻保持專業(yè)、時尚、前沿，時刻以成就客戶成長自我，堅持不斷學習、思考、沉淀、凈化自己，讓我們?yōu)楦嗟钠髽I(yè)打造出實用型網(wǎng)站。

啟動redis服務器：redis-server.exe redis.windows.conf

獲取包：

導入包

訪問：

Go語言與Docker操作Redis

首選，如果之前使用過redis容器，我們需要先remove掉之前的容器

然后創(chuàng)建redis容器，并運行

進入redis容器中

接著我們通過 redis-cli 連接測試使用 redis 服務

setex指令 可以設置數(shù)據(jù)存在的時間， setex key second value

MSET 一次設置多個key-value

MGET一次獲取多個key-value

HGET

HGETALL

Hlen和hexist

Lpush 和 Lrange

Lpop和Rpop 從鏈表取出并移走數(shù)據(jù)

刪除鏈表所有數(shù)據(jù) DEL

字符串無序 不能重復

從連接池中Get出一個conn連接

golang-redis系列——返回值助手函數(shù)(二)

從上一節(jié)的內(nèi)容可知，Do() 和 Receive() 等方法的返回值，除了 error 外，是一個 interface{} 類型的返回值，因此當我們的復雜操作返回的不是基本數(shù)據(jù)類型時，就需要我們自己解析返回值，例如，當我們利用 HMGET 方法獲取一批返回值時，就需要對返回結(jié)果進行解析，具體如下：

由于返回值是多條數(shù)據(jù)，因此需要先將 reply 轉(zhuǎn)成 []interface 類型，然后在遍歷結(jié)果時在分別轉(zhuǎn)成 []uint8 (byte數(shù)組)， 最后再轉(zhuǎn)成 string 類型。

隨著我們操作復雜度，數(shù)據(jù)解析的工作量也會非常大，(lua 腳本的使用，會使結(jié)果的解析更為復雜，因為可能存在多種類型的結(jié)果一起返回的情況，lua 腳本相關的內(nèi)容會在下一節(jié)介紹)。

redigo 包中的返回值助手函數(shù)的存在，就是為了幫助我們完成這些枯燥繁瑣的數(shù)據(jù)解析過程。

返回值助手函數(shù)相關源碼路徑為 github.com/gomodule/redigo/redis/reply.go 提供的主要方法如下：

上述返回值助手函數(shù)的具體使用，應該依據(jù)具體的命令進行選擇。如果大家還記得上一節(jié)介紹的 Redis 基本數(shù)據(jù)類型，可能會有些疑問，對于 redis 來說，其數(shù)據(jù)據(jù)存儲本質(zhì)都是 []bytes， 為什么可以解析出 Int、int64、float等類型的數(shù)據(jù)呢？

我們以 Float64() 為例進行說明，具體源碼如下：

其實，返回值助手函數(shù)是將 []byte 類型的原始數(shù)據(jù)，利用 strconv.ParseFloat(string(reply), 64) 轉(zhuǎn)換成了 float64類型，因此在我們使用過程中返回值助手函數(shù)的選擇，應該基于業(yè)務和實際存儲的數(shù)據(jù)格式為依據(jù)。我們以第一小節(jié)的示例為例，看返回值助手函數(shù)如何降低我們的工作量，具體如下：

除了使用返回值助手函數(shù)對上述固定結(jié)構(gòu)的結(jié)果進行解析外，redigo 包還提供了一個 Scan()函數(shù)用于解析自定義的復雜數(shù)據(jù)結(jié)構(gòu)，我們依然以上一個示例進行說明,具體示例如下：

如果返回結(jié)果為結(jié)構(gòu)化切片，也可以使用 canSlice() 方法，從而簡化 loop 處理的部分，具體示例如下：

通過上述的示例，我們介紹了 scan 函數(shù)的基本用法，但是細心的同學可能會發(fā)現(xiàn)嗎，為什么數(shù)據(jù)寫入時，value 的類型為 []int64 但是讀取時只能按照 string 類型讀取呢。這是因為 Redis 底層存儲的數(shù)據(jù)本質(zhì)都是 string 類型，。 無論是 HMSET 還是 MSET 最終都只能按照 string 類型讀取，因為其本質(zhì)都是 hash 結(jié)構(gòu)，不同之處僅在于 HMSET 是嵌套的 hash類型。 因此，[]int64 數(shù)據(jù)在寫入階段，就已經(jīng)被自動處理為 []byte，寫入 redis 之后，len 和 類型 屬性會丟失。

如果強行按照 []int64解析將出錯：

如果 value 必須以結(jié)構(gòu)化的數(shù)據(jù)存儲，那么可以提前對要寫入的數(shù)據(jù)進行編碼，例如 json、protobuf 等，取出后再進行解碼獲得原始數(shù)據(jù)。

如何在 Go 語言中使用 Redis 連接池

一、關于連接池

一個數(shù)據(jù)庫服務器只擁有有限的資源，并且如果你沒有充分使用這些資源，你可以通過使用更多的連接來提高吞吐量。一旦所有的資源都在使用，那么你就不 能通過增加更多的連接來提高吞吐量。事實上，吞吐量在連接負載較大時就開始下降了。通常可以通過限制與可用的資源相匹配的數(shù)據(jù)庫連接的數(shù)量來提高延遲和吞 吐量。

如何在Go語言中使用Redis連接池

如果不使用連接池，那么，每次傳輸數(shù)據(jù)，我們都需要進行創(chuàng)建連接，收發(fā)數(shù)據(jù)，關閉連接。在并發(fā)量不高的場景，基本上不會有什么問題，一旦并發(fā)量上去了，那么，一般就會遇到下面幾個常見問題：

性能普遍上不去

CPU 大量資源被系統(tǒng)消耗

網(wǎng)絡一旦抖動，會有大量 TIME_WAIT 產(chǎn)生，不得不定期重啟服務或定期重啟機器

服務器工作不穩(wěn)定，QPS 忽高忽低

要想解決這些問題，我們就要用到連接池了。連接池的思路很簡單，在初始化時，創(chuàng)建一定數(shù)量的連接，先把所有長連接存起來，然后，誰需要使用，從這里取走，干完活立馬放回來。 如果請求數(shù)超出連接池容量，那么就排隊等待、退化成短連接或者直接丟棄掉。

二、使用連接池遇到的坑

最近在一個項目中，需要實現(xiàn)一個簡單的 Web Server 提供 Redis 的 HTTP interface，提供 JSON 形式的返回結(jié)果。考慮用 Go 來實現(xiàn)。

首先，去看一下 Redis 官方推薦的 Go Redis driver。官方 Star 的項目有兩個：Radix.v2 和 Redigo。經(jīng)過簡單的比較后，選擇了更加輕量級和實現(xiàn)更加優(yōu)雅的 Radix.v2。

Radix.v2 包是根據(jù)功能劃分成一個個的 sub package，每一個 sub package 在一個獨立的子目錄中，結(jié)構(gòu)非常清晰。我的項目中會用到的 sub package 有 redis 和 pool。

由于我想讓這種被 fork 的進程最好簡單點，做的事情單一一些，所以，在沒有深入去看 Radix.v2 的 pool 的實現(xiàn)之前，我選擇了自己實現(xiàn)一個 Redis pool。(這里，就不貼代碼了。后來發(fā)現(xiàn)自己實現(xiàn)的 Redis pool 與 Radix.v2 實現(xiàn)的 Redis pool 的原理是一樣的，都是基于 channel 實現(xiàn)的, 遇到的問題也是一樣的。)

不過在測試過程中，發(fā)現(xiàn)了一個詭異的問題。在請求過程中經(jīng)常會報 EOF 錯誤。而且是概率性出現(xiàn)，一會有問題，一會又好了。通過反復的測試，發(fā)現(xiàn) bug 是有規(guī)律的，當程序空閑一會后，再進行連續(xù)請求，會發(fā)生3次失敗，然后之后的請求都能成功，而我的連接池大小設置的是3。再進一步分析，程序空閑300秒 后，再請求就會失敗，發(fā)現(xiàn)我的 Redis server 配置了 timeout 300，至此，問題就清楚了。是連接超時 Redis server 主動斷開了連接。客戶端這邊從一個超時的連接請求就會得到 EOF 錯誤。

然后我看了一下 Radix.v2 的 pool 包的源碼，發(fā)現(xiàn)這個庫本身并沒有檢測壞的連接，并替換為新server{location/pool{content_by_lua_block{localredis=require"resty.redis"localred=redis:new()localok,err=red:connect("127.0.0.1",6379)ifnotokthenngx.say("failedtoconnect:",err)returnendok,err=red:set("hello","world")ifnotokthenreturnendred:set_keepalive(10000,100)}}}

發(fā)現(xiàn)有個 set_keepalive 的方法，查了一下官方文檔，方法的原型是 syntax: ok, err = red:set_keepalive(max_idle_timeout, pool_size) 貌似 max_idle_timeout 這個參數(shù)，就是我們所缺少的東西，然后進一步跟蹤源碼，看看里面是怎么保證連接有效的。

function_M.set_keepalive(self,...)localsock=self.sockifnotsockthenreturnnil,"notinitialized"endifself.subscribedthenreturnnil,"subscribedstate"endreturnsock:setkeepalive(...)end

至此，已經(jīng)清楚了，使用了 tcp 的 keepalive 心跳機制。

于是，通過與 Radix.v2 的作者一些討論，選擇自己在 redis 這層使用心跳機制，來解決這個問題。

四、最后的解決方案

在創(chuàng)建連接池之后，起一個 goroutine，每隔一段 idleTime 發(fā)送一個 PING 到 Redis server。其中，idleTime 略小于 Redis server 的 timeout 配置。連接池初始化部分代碼如下：

p,err:=pool.New("tcp",u.Host,concurrency)errHndlr(err)gofunc(){for{p.Cmd("PING")time.Sleep(idelTime*time.Second)}}()

使用 redis 傳輸數(shù)據(jù)部分代碼如下：

funcredisDo(p*pool.Pool,cmdstring,args...interface{})(reply*redis.Resp,errerror){reply=p.Cmd(cmd,args...)iferr=reply.Err;err!=nil{iferr!=io.EOF{Fatal.Println("redis",cmd,args,"erris",err)}}return}

其中，Radix.v2 連接池內(nèi)部進行了連接池內(nèi)連接的獲取和放回，代碼如下：

//Cmdautomaticallygetsoneclientfromthepool,executesthegivencommand//(returningitsresult),andputstheclientbackinthepoolfunc(p*Pool)Cmd(cmdstring,args...interface{})*redis.Resp{c,err:=p.Get()iferr!=nil{returnredis.NewResp(err)}deferp.Put(c)returnc.Cmd(cmd,args...)}

這樣，我們就有了 keepalive 的機制，不會出現(xiàn) timeout 的連接了，從 redis 連接池里面取出的連接都是可用的連接了。看似簡單的代碼，卻完美的解決了連接池里面超時連接的問題。同時，就算 Redis server 重啟等情況，也能保證連接自動重連。

golang redis事務 --- 2022-04-03

redis事務可以一次執(zhí)行多個命令， 并且?guī)в幸韵聝蓚€重要的保證：

事務是一個單獨的隔離操作：事務中的所有命令都會序列化、按順序地執(zhí)行。事務在執(zhí)行的過程中，不會被其他客戶端發(fā)送來的命令請求所打斷。

事務是一個原子操作：事務中的命令要么全部被執(zhí)行，要么全部都不執(zhí)行。

下面介紹golang redis事務用法。

go redis事務常用函數(shù)：

TxPipeline - 以Pipeline的方式操作事務

Watch - redis樂觀鎖支持

1.TxPipeline

以Pipeline的方式操作事務

2.watch

redis樂觀鎖支持，可以通過watch監(jiān)聽一些Key, 如果這些key的值沒有被其他人改變的話，才可以提交事務。

網(wǎng)站名稱：go語言的redis庫,redis是什么語言開發(fā)的
網(wǎng)頁鏈接：http://chinadenli.net/article41/dsehhed.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供微信公眾號、網(wǎng)站排名、手機網(wǎng)站建設、定制開發(fā)、網(wǎng)頁設計公司、微信小程序

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)