GoFrame?gredis緩存DoVar及Conn連接對象的自動序列化
前言
上一篇文章為大家介紹了 GoFrame gcache使用實踐 | 緩存控制 淘汰策略 ,得到了大家積極的反饋。
后續(xù)幾篇文章再接再厲,仍然為大家介紹GoFrame框架緩存相關(guān)的知識點,以及自己項目使用中的一些總結(jié)思考,GoFrame框架下文簡稱gf。
這篇文章比較硬核,爆肝2千字,閱讀大約需要5~8分鐘。
詳細的介紹了gredis的使用,包括:Do/DoVar方法的使用及區(qū)別、復雜場景下使用Conn方法從連接池中獲取一個redis連接對象、當給定的參數(shù)為map, slice, struct時,gredis內(nèi)部支持自動對其使用json序列化,并且讀取數(shù)據(jù)時可使用gvar.Var的轉(zhuǎn)換功能實現(xiàn)反序列化。
GoFrame gredis
整體介紹
Redis客戶端由gredis模塊實現(xiàn),底層采用了鏈接池設(shè)計。
gredis使用了連接池來進行Redis連接管理,通過Config配置對象或者Set*方法可以對連接池的屬性進行管理,通過Stats方法可以獲取連接池的統(tǒng)計信息。
我們最常用的是Do/DoVar方法,執(zhí)行同步指令,通過向Redis Server發(fā)送對應(yīng)的Redis API命令,來使用Redis Server的服務(wù)。Do/Var方法最大的特點是內(nèi)部自行從連接池中獲取連接對象,使用完畢后自動丟回連接池中,開發(fā)者無需手動調(diào)用Close方法,方便使用。
Do/DoVar方法
我們最常用的是Do/DoVar方法,執(zhí)行同步指令,通過向Redis Server發(fā)送對應(yīng)的Redis API命令,來使用Redis Server的服務(wù)。
Do/Var方法最大的特點是內(nèi)部自行從連接池中獲取連接對象,使用完畢后自動丟回連接池中,開發(fā)者無需手動調(diào)用Close方法,方便使用。
小技巧
Do和DoVar的區(qū)別在于返回的結(jié)果類型不一樣,DoVar返回的是gvar.Var類型,該類型對象可以執(zhí)行非常方便的類型轉(zhuǎn)換。
gvar.Var類型 就像go原生提供的interface一樣,要了解更多的可以查看這篇文章:GoFrame 通用類型變量gvar | 對比 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 命令用于為哈希表中的字段賦值 。
如果哈希表不存在,一個新的哈希表被創(chuàng)建并進行 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", "王中陽") 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:王中陽] }
HMSET/HMGET操作
強烈推薦,非常好用:我們可以通過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": "王中陽", "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é)果 [王中陽] }
我們也可以通過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: "王中陽", 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é)果: [王中陽] }
Conn連接對象
使用Do/DoVar方法已經(jīng)能夠滿足絕大部分的場景需要,如果需要更復雜的Redis操作,我們可以使用Conn方法從連接池中獲取一個連接對象,隨后使用該連接對象進行操作。
需要注意的是,該連接對象不再使用時,應(yīng)當顯式調(diào)用Close方法進行關(guān)閉(丟回連接池)。
由于該Conn是個連接對象,注意該對象存在連接超時的限制,超時和服務(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í)行批量指令,并通過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 }
讓我想到了之前寫的一篇爆文:Redis 如何批量設(shè)置過期時間?PIPLINE的使用
訂閱/發(fā)布
我們可以通過Redis的SUBSCRIBE/PUBLISH命令實現(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ù)。
另外打開一個終端通過redis-cli命令進入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]
自動序列化/反序列化
當給定的參數(shù)為map, slice, struct時,gredis內(nèi)部支持自動對其使用json序列化,并且讀取數(shù)據(jù)時可使用gvar.Var的轉(zhuǎn)換功能實現(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": "王中陽", } ) _, 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":"王中陽"} fmt.Println("result.Map():", result.Map()) //result.Map(): map[id:7 name:王中陽] }
打印結(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: "王中陽", } ) _, 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 王中陽} fmt.Printf("id:%v, name:%v \n", user2.Id, user2.Name) //id:7, name:王中陽 }
打印結(jié)果
總結(jié)
詳細的介紹了gredis的使用,包括:Do/DoVar方法的使用及區(qū)別、復雜場景下使用Conn方法從連接池中獲取一個redis連接對象、當給定的參數(shù)為map, slice, struct時,gredis內(nèi)部支持自動對其使用json序列化,并且讀取數(shù)據(jù)時可使用gvar.Var的轉(zhuǎn)換功能實現(xiàn)反序列化,更多關(guān)于GoFrame gredis DoVar Conn連接對象 自動序列化的資料請關(guān)注腳本之家其它相關(guān)文章!
相關(guān)文章
Go?內(nèi)聯(lián)優(yōu)化讓程序員愛不釋手
這篇文章主要介紹了Go?內(nèi)聯(lián)優(yōu)化讓程序員愛不釋手,內(nèi)聯(lián)是在編譯過程中自動進行的一類基本優(yōu)化之一,文章圍繞主題展開更多詳細介紹,具有一定的參考價值,需要的小伙伴可以參考一下2022-06-06Golang實現(xiàn)IP地址轉(zhuǎn)整數(shù)的方法詳解
在 Go 語言中,將 IP 地址轉(zhuǎn)換為整數(shù)涉及到解析 IP 地址并處理其字節(jié)表示,本文給大家介紹了Golang實現(xiàn)IP地址轉(zhuǎn)整數(shù)的方法,文中有詳細的代碼示例供大家參考,需要的朋友可以參考下2024-02-02深入理解Golang中的Protocol Buffers及其應(yīng)用
本篇文章將深入探討 Go 語言中使用 Protobuf 的基礎(chǔ)知識、常見應(yīng)用以及最佳實踐,希望能幫大家了解如何在項目中高效利用 Protobuf2024-11-11Go語言并發(fā)之Sync包的6個關(guān)鍵概念總結(jié)
這篇文章主要為大家詳細介紹了Go語言并發(fā)中Sync包的6個關(guān)鍵概念,文中的示例代碼講解詳細,對我們深入學習Go語言有一定的幫助,需要的可以參考一下2023-05-05