可以參考: windows環境下redis的安裝

創新互聯建站堅持“要么做到,要么別承諾”的工作理念,服務領域包括:成都網站設計、成都網站制作、企業官網、英文網站、手機端網站、網站推廣等服務,滿足客戶于互聯網時代的施甸網站設計、移動媒體設計的需求,幫助企業找到有效的互聯網解決方案。努力成為您成熟可靠的網絡建設合作伙伴!
啟動redis服務器:redis-server.exe redis.windows.conf
獲取包:
導入包
訪問:
1.在創建連接池之后,起一個 go routine,每隔一段 idleTime 發送一個 PING 到 Redis server。其中,idleTime 略小于 Redis server 的 timeout 配置。
2.連接池初始化部分代碼如下:
p, err := pool.New("tcp", u.Host, concurrency) errHndlr(err) go func() { for { p.Cmd("PING") time.Sleep(idelTime * time.Second) } }()
3.使用 redis 傳輸數據部分代碼如下:
func redisDo(p *pool.Pool, cmd string, args ...interface{}) (reply *redis.Resp, err error) { reply = p.Cmd(cmd, args...) if err = reply.Err; err != nil { if err != io.EOF { Fatal.Println("redis", cmd, args, "err is", err) } } return }
4.其中,Radix.v2 連接池內部進行了連接池內連接的獲取和放回,代碼如下:
// Cmd automatically gets one client from the pool, executes the given command // (returning its result), and puts the client back in the pool func (p *Pool) Cmd(cmd string, args ...interface{}) *redis.Resp { c, err := p.Get() if err != nil { return redis.NewResp(err) } defer p.Put(c) return c.Cmd(cmd, args...) }
這樣,就有了系統 keep alive 的機制,不會出現 time out 的連接了,從 redis 連接池里面取出的連接都是可用的連接了。看似簡單的代碼,卻完美的解決了連接池里面超時連接的問題。同時,就算 Redis server 重啟等情況,也能保證連接自動重連。
從上一節的內容可知,Do() 和 Receive() 等方法的返回值,除了 error 外,是一個 interface{} 類型的返回值,因此當我們的復雜操作返回的不是基本數據類型時,就需要我們自己解析返回值,例如,當我們利用 HMGET 方法獲取一批返回值時,就需要對返回結果進行解析,具體如下:
由于返回值是多條數據,因此需要先將 reply 轉成 []interface 類型,然后在遍歷結果時在分別轉成 []uint8 (byte數組), 最后再轉成 string 類型。
隨著我們操作復雜度,數據解析的工作量也會非常大,(lua 腳本的使用,會使結果的解析更為復雜,因為可能存在多種類型的結果一起返回的情況,lua 腳本相關的內容會在下一節介紹)。
redigo 包中的返回值助手函數的存在,就是為了幫助我們完成這些枯燥繁瑣的數據解析過程。
返回值助手函數相關源碼路徑為 github.com/gomodule/redigo/redis/reply.go 提供的主要方法如下:
上述返回值助手函數的具體使用,應該依據具體的命令進行選擇。如果大家還記得上一節介紹的 Redis 基本數據類型,可能會有些疑問,對于 redis 來說,其數據據存儲本質都是 []bytes, 為什么可以解析出 Int、int64、float等類型的數據呢?
我們以 Float64() 為例進行說明,具體源碼如下:
其實,返回值助手函數是將 []byte 類型的原始數據,利用 strconv.ParseFloat(string(reply), 64) 轉換成了 float64類型,因此在我們使用過程中返回值助手函數的選擇,應該基于業務和實際存儲的數據格式為依據。我們以第一小節的示例為例,看返回值助手函數如何降低我們的工作量,具體如下:
除了使用返回值助手函數對上述固定結構的結果進行解析外,redigo 包還提供了一個 Scan()函數用于解析自定義的復雜數據結構,我們依然以上一個示例進行說明,具體示例如下:
如果返回結果為結構化切片,也可以使用 canSlice() 方法,從而簡化 loop 處理的部分,具體示例如下:
通過上述的示例,我們介紹了 scan 函數的基本用法,但是細心的同學可能會發現嗎,為什么數據寫入時,value 的類型為 []int64 但是讀取時只能按照 string 類型讀取呢。這是因為 Redis 底層存儲的數據本質都是 string 類型,。 無論是 HMSET 還是 MSET 最終都只能按照 string 類型讀取,因為其本質都是 hash 結構,不同之處僅在于 HMSET 是嵌套的 hash類型。 因此,[]int64 數據在寫入階段,就已經被自動處理為 []byte,寫入 redis 之后,len 和 類型 屬性會丟失。
如果強行按照 []int64解析將出錯:
如果 value 必須以結構化的數據存儲,那么可以提前對要寫入的數據進行編碼,例如 json、protobuf 等,取出后再進行解碼獲得原始數據。
首選,如果之前使用過redis容器,我們需要先remove掉之前的容器
然后創建redis容器,并運行
進入redis容器中
接著我們通過 redis-cli 連接測試使用 redis 服務
setex指令 可以設置數據存在的時間, setex key second value
MSET 一次設置多個key-value
MGET一次獲取多個key-value
HGET
HGETALL
Hlen和hexist
Lpush 和 Lrange
Lpop和Rpop 從鏈表取出并移走數據
刪除鏈表所有數據 DEL
字符串無序 不能重復
從連接池中Get出一個conn連接
分享名稱:go語言redis搶紅包 redis實現搶紅包
分享URL:http://www.kartarina.com/article42/ddddoec.html
成都網站建設公司_創新互聯,為您提供企業建站、網站導航、網站內鏈、做網站、微信小程序、網站改版
聲明:本網站發布的內容(圖片、視頻和文字)以用戶投稿、用戶轉載內容為主,如果涉及侵權請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網站立場,如需處理請聯系客服。電話:028-86922220;郵箱:631063699@qq.com。內容未經允許不得轉載,或轉載時需注明來源: 創新互聯