GoFrame?gredis緩存DoVar及Conn連接對(duì)象的自動(dòng)序列化
前言
上一篇文章為大家介紹了 GoFrame gcache使用實(shí)踐 | 緩存控制 淘汰策略 ，得到了大家積極的反饋。
后續(xù)幾篇文章再接再厲，仍然為大家介紹GoFrame框架緩存相關(guān)的知識(shí)點(diǎn)，以及自己項(xiàng)目使用中的一些總結(jié)思考，GoFrame框架下文簡(jiǎn)稱(chēng)gf。
這篇文章比較硬核，爆肝2千字，閱讀大約需要5~8分鐘。
詳細(xì)的介紹了gredis的使用，包括：Do/DoVar方法的使用及區(qū)別、復(fù)雜場(chǎng)景下使用Conn方法從連接池中獲取一個(gè)redis連接對(duì)象、當(dāng)給定的參數(shù)為map, slice, struct時(shí)，gredis內(nèi)部支持自動(dòng)對(duì)其使用json序列化，并且讀取數(shù)據(jù)時(shí)可使用gvar.Var的轉(zhuǎn)換功能實(shí)現(xiàn)反序列化。
GoFrame gredis
整體介紹
Redis客戶(hù)端由gredis模塊實(shí)現(xiàn)，底層采用了鏈接池設(shè)計(jì)。
gredis使用了連接池來(lái)進(jìn)行Redis連接管理，通過(guò)Config配置對(duì)象或者Set*方法可以對(duì)連接池的屬性進(jìn)行管理，通過(guò)Stats方法可以獲取連接池的統(tǒng)計(jì)信息。
我們最常用的是Do/DoVar方法，執(zhí)行同步指令，通過(guò)向Redis Server發(fā)送對(duì)應(yīng)的Redis API命令，來(lái)使用Redis Server的服務(wù)。Do/Var方法最大的特點(diǎn)是內(nèi)部自行從連接池中獲取連接對(duì)象，使用完畢后自動(dòng)丟回連接池中，開(kāi)發(fā)者無(wú)需手動(dòng)調(diào)用Close方法，方便使用。
Do/DoVar方法
我們最常用的是Do/DoVar方法，執(zhí)行同步指令，通過(guò)向Redis Server發(fā)送對(duì)應(yīng)的Redis API命令，來(lái)使用Redis Server的服務(wù)。
Do/Var方法最大的特點(diǎn)是內(nèi)部自行從連接池中獲取連接對(duì)象，使用完畢后自動(dòng)丟回連接池中，開(kāi)發(fā)者無(wú)需手動(dòng)調(diào)用Close方法，方便使用。
小技巧
Do和DoVar的區(qū)別在于返回的結(jié)果類(lèi)型不一樣，DoVar返回的是gvar.Var類(lèi)型，該類(lèi)型對(duì)象可以執(zhí)行非常方便的類(lèi)型轉(zhuǎn)換。
gvar.Var類(lèi)型 就像go原生提供的interface一樣，要了解更多的可以查看這篇文章：GoFrame 通用類(lèi)型變量gvar | 對(duì)比 interface{}
基本使用
package main
import (
"fmt"
"github.com/gogf/gf/frame/g"
)
func main() {
g.Redis().Do("SET", "k", "v")
v, _ := g.Redis().DoVar("GET", "k")
fmt.Println(v.String())
}
HSET/HGETALL操作
Hset 命令用于為哈希表中的字段賦值 。
如果哈希表不存在，一個(gè)新的哈希表被創(chuàng)建并進(jìn)行 HSET 操作。
如果字段已經(jīng)存在于哈希表中，舊值將被覆蓋。
package main
import (
"fmt"
"github.com/gogf/gf/container/gvar"
"github.com/gogf/gf/frame/g"
)
func main() {
var (
err error
result *gvar.Var
key = "user"
)
_, err = g.Redis().Do("HSET", key, "id", 10000)
if err != nil {
panic(err)
}
_, err = g.Redis().Do("HSET", key, "name", "王中陽(yáng)")
if err != nil {
panic(err)
}
result, err = g.Redis().DoVar("HGETALL", key)
if err != nil {
panic(err)
}
fmt.Println(result.Map()) //打印結(jié)果： map[id:10000 name:王中陽(yáng)]
}
HMSET/HMGET操作
強(qiáng)烈推薦，非常好用：我們可以通過(guò)map參數(shù)執(zhí)行HMSET操作。
package main
import (
"fmt"
"github.com/gogf/gf/frame/g"
"github.com/gogf/gf/util/gutil"
)
func main() {
var (
key = "user_100"
data = g.Map{
"name": "王中陽(yáng)",
"sex": 0,
"score": 100,
}
)
_, err := g.Redis().Do("HMSET", append(g.Slice{key}, gutil.MapToSlice(data)...)...)
if err != nil {
g.Log().Fatal(err)
}
v, err := g.Redis().DoVar("HMGET", key, "name")
if err != nil {
g.Log().Fatal(err)
}
fmt.Println(v.Slice()) //打印結(jié)果 [王中陽(yáng)]
}
我們也可以通過(guò)struct參數(shù)執(zhí)行HMSET操作。
package main
import (
"fmt"
"github.com/gogf/gf/frame/g"
"github.com/gogf/gf/util/gutil"
)
func main() {
type User struct {
Name string `json:"name"`
Sex int `json:"sex"`
Score int `json:"score"`
}
var (
key = "user_100"
data = &User{
Name: "王中陽(yáng)",
Sex: 0,
Score: 100,
}
)
_, err := g.Redis().Do("HMSET", append(g.Slice{key}, gutil.StructToSlice(data)...)...)
if err != nil {
g.Log().Fatal(err)
}
v, err := g.Redis().DoVar("HMGET", key, "name")
if err != nil {
g.Log().Fatal(err)
}
fmt.Println(v.Slice()) //打印結(jié)果： [王中陽(yáng)]
}
Conn連接對(duì)象
使用Do/DoVar方法已經(jīng)能夠滿足絕大部分的場(chǎng)景需要，如果需要更復(fù)雜的Redis操作，我們可以使用Conn方法從連接池中獲取一個(gè)連接對(duì)象，隨后使用該連接對(duì)象進(jìn)行操作。
需要注意的是，該連接對(duì)象不再使用時(shí)，應(yīng)當(dāng)顯式調(diào)用Close方法進(jìn)行關(guān)閉（丟回連接池）。
由于該Conn是個(gè)連接對(duì)象，注意該對(duì)象存在連接超時(shí)的限制，超時(shí)和服務(wù)端配置有關(guān)。
基本使用
package main
import (
"fmt"
"github.com/gogf/gf/frame/g"
"github.com/gogf/gf/util/gconv"
)
func main() {
conn := g.Redis().Conn()
defer conn.Close()
conn.Do("SET", "k", "v")
v, _ := conn.Do("GET", "k")
fmt.Println(gconv.String(v)) //打印結(jié)果：v
}
Send批量指令
Send可以執(zhí)行批量指令，并通過(guò)Receive方法一一獲取返回結(jié)果。
package main
import (
"fmt"
"github.com/gogf/gf/frame/g"
"github.com/gogf/gf/util/gconv"
)
func main() {
conn := g.Redis().Conn()
defer conn.Close()
conn.Send("SET", "foo", "bar")
conn.Send("GET", "foo")
conn.Flush()
// reply from SET
conn.Receive()
// reply from GET
v, _ := conn.Receive()
fmt.Println(gconv.String(v)) //打印結(jié)果：bar
}
讓我想到了之前寫(xiě)的一篇爆文：Redis 如何批量設(shè)置過(guò)期時(shí)間？PIPLINE的使用
訂閱/發(fā)布
我們可以通過(guò)Redis的SUBSCRIBE/PUBLISH命令實(shí)現(xiàn)訂閱/發(fā)布模式。
package main
import (
"fmt"
"github.com/gogf/gf/frame/g"
"github.com/gogf/gf/util/gconv"
)
func main() {
conn := g.Redis().Conn()
defer conn.Close()
_, err := conn.Do("SUBSCRIBE", "channel")
if err != nil {
panic(err)
}
for {
reply, err := conn.Receive()
if err != nil {
panic(err)
}
fmt.Println(gconv.Strings(reply))
}
}
執(zhí)行后，程序?qū)⒆枞却@取數(shù)據(jù)。
另外打開(kāi)一個(gè)終端通過(guò)redis-cli命令進(jìn)入Redis Server，發(fā)布一條消息：
$ redis-cli 127.0.0.1:6379> publish channel test (integer) 1 127.0.0.1:6379>
隨后程序終端立即打印出從Redis Server獲取的數(shù)據(jù)：
[message channel test]
自動(dòng)序列化/反序列化
當(dāng)給定的參數(shù)為map, slice, struct時(shí)，gredis內(nèi)部支持自動(dòng)對(duì)其使用json序列化，并且讀取數(shù)據(jù)時(shí)可使用gvar.Var的轉(zhuǎn)換功能實(shí)現(xiàn)反序列化。
map存取
package test
import (
"fmt"
"github.com/gogf/gf/container/gvar"
"github.com/gogf/gf/frame/g"
)
func Run1() {
var (
err error
result *gvar.Var
key = "test_user"
data = g.Map{
"id": 7,
"name": "王中陽(yáng)",
}
)
_, err = g.Redis().Do("SET", key, data)
if err != nil {
panic(err)
}
result, err = g.Redis().DoVar("GET", key)
if err != nil {
panic(err)
}
fmt.Println("result:", result) //result: {"id":7,"name":"王中陽(yáng)"}
fmt.Println("result.Map():", result.Map()) //result.Map(): map[id:7 name:王中陽(yáng)]
}
打印結(jié)果
struct存取
package test
import (
"fmt"
"github.com/gogf/gf/container/gvar"
"github.com/gogf/gf/frame/g"
)
func Run1() {
type User struct {
Id int
Name string
}
var (
err error
result *gvar.Var
key = "test_user"
user = &User{
Id: 007,
Name: "王中陽(yáng)",
}
)
_, err = g.Redis().Do("SET", key, user)
if err != nil {
panic(err)
}
result, err = g.Redis().DoVar("GET", key)
if err != nil {
panic(err)
}
var user2 *User
if err = result.Struct(&user2); err != nil {
panic(err)
}
fmt.Println("user2:", user2) //user2: &{7 王中陽(yáng)}
fmt.Printf("id:%v, name:%v \n", user2.Id, user2.Name) //id:7, name:王中陽(yáng)
}
打印結(jié)果
總結(jié)
詳細(xì)的介紹了gredis的使用，包括：Do/DoVar方法的使用及區(qū)別、復(fù)雜場(chǎng)景下使用Conn方法從連接池中獲取一個(gè)redis連接對(duì)象、當(dāng)給定的參數(shù)為map, slice, struct時(shí)，gredis內(nèi)部支持自動(dòng)對(duì)其使用json序列化，并且讀取數(shù)據(jù)時(shí)可使用gvar.Var的轉(zhuǎn)換功能實(shí)現(xiàn)反序列化，更多關(guān)于GoFrame gredis DoVar Conn連接對(duì)象 自動(dòng)序列化的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！
相關(guān)文章
這篇文章主要介紹了golang去除多余空白字符(含制表符)的操作，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2021-04-04
Go?內(nèi)聯(lián)優(yōu)化讓程序員愛(ài)不釋手
這篇文章主要介紹了Go?內(nèi)聯(lián)優(yōu)化讓程序員愛(ài)不釋手，內(nèi)聯(lián)是在編譯過(guò)程中自動(dòng)進(jìn)行的一類(lèi)基本優(yōu)化之一，文章圍繞主題展開(kāi)更多詳細(xì)介紹，具有一定的參考價(jià)值，需要的小伙伴可以參考一下2022-06-06
這篇文章主要介紹了GoLang中的sync包Once使用執(zhí)行示例，沒(méi)有學(xué)習(xí)Once前，大家可能想到 聲明一個(gè)標(biāo)識(shí)，表示是否初始化過(guò)，然后初始化這個(gè)標(biāo)識(shí)加鎖，更新這個(gè)標(biāo)識(shí)，Once包主要用于在并發(fā)執(zhí)行代碼的時(shí)候，某部分代碼只會(huì)被執(zhí)行一次2023-03-03
Golang實(shí)現(xiàn)IP地址轉(zhuǎn)整數(shù)的方法詳解
在 Go 語(yǔ)言中,將 IP 地址轉(zhuǎn)換為整數(shù)涉及到解析 IP 地址并處理其字節(jié)表示,本文給大家介紹了Golang實(shí)現(xiàn)IP地址轉(zhuǎn)整數(shù)的方法,文中有詳細(xì)的代碼示例供大家參考,需要的朋友可以參考下2024-02-02
Go Gin實(shí)現(xiàn)文件上傳下載的示例代碼
這篇文章主要介紹了Go Gin實(shí)現(xiàn)文件上傳下載的示例代碼，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2021-04-04
深入理解Golang中的Protocol Buffers及其應(yīng)用
本篇文章將深入探討 Go 語(yǔ)言中使用 Protobuf 的基礎(chǔ)知識(shí)、常見(jiàn)應(yīng)用以及最佳實(shí)踐,希望能幫大家了解如何在項(xiàng)目中高效利用 Protobuf2024-11-11
Go語(yǔ)言并發(fā)之Sync包的6個(gè)關(guān)鍵概念總結(jié)
這篇文章主要為大家詳細(xì)介紹了Go語(yǔ)言并發(fā)中Sync包的6個(gè)關(guān)鍵概念，文中的示例代碼講解詳細(xì)，對(duì)我們深入學(xué)習(xí)Go語(yǔ)言有一定的幫助，需要的可以參考一下2023-05-05
Go語(yǔ)言指針訪問(wèn)結(jié)構(gòu)體的方法
go語(yǔ)言代碼生成器code?generator使用示例介紹