GoFrame?gredis緩存DoVar及Conn連接對象的自動序列化
前言
上一篇文章為大家介紹了 GoFrame gcache使用實踐 | 緩存控制 淘汰策略 ，得到了大家積極的反饋。
后續(xù)幾篇文章再接再厲，仍然為大家介紹GoFrame框架緩存相關(guān)的知識點(diǎn)，以及自己項目使用中的一些總結(jié)思考，GoFrame框架下文簡稱gf。
這篇文章比較硬核，爆肝2千字，閱讀大約需要5~8分鐘。
詳細(xì)的介紹了gredis的使用，包括：Do/DoVar方法的使用及區(qū)別、復(fù)雜場景下使用Conn方法從連接池中獲取一個redis連接對象、當(dāng)給定的參數(shù)為map, slice, struct時，gredis內(nèi)部支持自動對其使用json序列化，并且讀取數(shù)據(jù)時可使用gvar.Var的轉(zhuǎn)換功能實現(xiàn)反序列化。
GoFrame gredis
整體介紹
Redis客戶端由gredis模塊實現(xiàn)，底層采用了鏈接池設(shè)計。
gredis使用了連接池來進(jìn)行Redis連接管理，通過Config配置對象或者Set*方法可以對連接池的屬性進(jìn)行管理，通過Stats方法可以獲取連接池的統(tǒng)計信息。
我們最常用的是Do/DoVar方法，執(zhí)行同步指令，通過向Redis Server發(fā)送對應(yīng)的Redis API命令，來使用Redis Server的服務(wù)。Do/Var方法最大的特點(diǎn)是內(nèi)部自行從連接池中獲取連接對象，使用完畢后自動丟回連接池中，開發(fā)者無需手動調(diào)用Close方法，方便使用。
Do/DoVar方法
我們最常用的是Do/DoVar方法，執(zhí)行同步指令，通過向Redis Server發(fā)送對應(yīng)的Redis API命令，來使用Redis Server的服務(wù)。
Do/Var方法最大的特點(diǎn)是內(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)建并進(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", "王中陽")
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操作
強(qiáng)烈推薦，非常好用：我們可以通過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)能夠滿足絕大部分的場景需要，如果需要更復(fù)雜的Redis操作，我們可以使用Conn方法從連接池中獲取一個連接對象，隨后使用該連接對象進(jìn)行操作。
需要注意的是，該連接對象不再使用時，應(yīng)當(dāng)顯式調(diào)用Close方法進(jìn)行關(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命令進(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)給定的參數(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é)
詳細(xì)的介紹了gredis的使用，包括：Do/DoVar方法的使用及區(qū)別、復(fù)雜場景下使用Conn方法從連接池中獲取一個redis連接對象、當(dāng)給定的參數(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語言編程二維碼的生成及識別示例演示，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2022-04-04
這篇文章主要討論Go語言 是傳值還是傳引用?文章先從Go 官方的定義展開，隨后是傳值和傳引用得介紹到map 和 slice得區(qū)別,需要的小伙伴可以參考一下文章得具體內(nèi)容2021-10-10
這篇文章主要介紹了Golang如何將上傳的文件壓縮成zip(小案例),這是一個簡單的golang壓縮文件小案例,可做很多的拓展,這里使用的庫是archive/zip,在gopkg里面搜zip就行,需要的朋友可以參考下2024-01-01
Golang基礎(chǔ)學(xué)習(xí)之map的示例詳解
哈希表是常見的數(shù)據(jù)結(jié)構(gòu)，有的語言會將哈希稱作字典或者映射，在Go中，哈希就是常見的數(shù)據(jù)類型map，本文就來聊聊Golang中map的相關(guān)知識吧2023-03-03
這篇文章主要介紹了創(chuàng)建第一個Go語言程序Hello,Go!本文詳細(xì)的給出項目創(chuàng)建、代碼編寫的過程,同時講解了GOPATH、Go install等內(nèi)容,需要的朋友可以參考下2014-10-10
本文主要介紹了安裝Sublime?Text支持Go插件的方法步驟，文中通過示例代碼介紹的非常詳細(xì)，具有一定的參考價值，感興趣的小伙伴們可以參考一下2022-01-01
GoLand 中設(shè)置默認(rèn)項目文件夾的實現(xiàn)
本文主要介紹了GoLand 中設(shè)置默認(rèn)項目文件夾的實現(xiàn),默認(rèn)項目文件夾會在你打開或新建項目時自動預(yù)選,避免每次都需要手動導(dǎo)航到目標(biāo)目錄,感興趣的可以了解一下2025-03-03
反射是程序在運(yùn)行期間獲取變量的類型和值、或者執(zhí)行變量的方法的能力。這篇文章主要為大家介紹了Golang反射獲取變量類型和值的方法，需要的可以參考一下2022-12-12
本文主要介紹了Golang中的深拷貝與淺拷貝使用，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2023-04-04
這篇文章主要為大家介紹了GO語言中err接口及defer延遲異常處理的示例分析，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步早日升職加薪2022-04-04