GoFrame?gredis緩存DoVar及Conn連接對(duì)象的自動(dòng)序列化
前言
上一篇文章為大家介紹了 GoFrame gcache使用實(shí)踐 | 緩存控制 淘汰策略 ，得到了大家積極的反饋。
后續(xù)幾篇文章再接再厲，仍然為大家介紹GoFrame框架緩存相關(guān)的知識(shí)點(diǎn)，以及自己項(xiàng)目使用中的一些總結(jié)思考，GoFrame框架下文簡(jiǎn)稱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客戶端由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é)果類型不一樣，DoVar返回的是gvar.Var類型，該類型對(duì)象可以執(zhí)行非常方便的類型轉(zhuǎn)換。
gvar.Var類型 就像go原生提供的interface一樣，要了解更多的可以查看這篇文章：GoFrame 通用類型變量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
}
讓我想到了之前寫的一篇爆文：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)文章
這篇文章主要為大家介紹了go語(yǔ)言編程二維碼的生成及識(shí)別示例演示，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2022-04-04
這篇文章主要討論Go語(yǔ)言 是傳值還是傳引用?文章先從Go 官方的定義展開(kāi)，隨后是傳值和傳引用得介紹到map 和 slice得區(qū)別,需要的小伙伴可以參考一下文章得具體內(nèi)容2021-10-10
這篇文章主要介紹了Golang如何將上傳的文件壓縮成zip(小案例),這是一個(gè)簡(jiǎn)單的golang壓縮文件小案例,可做很多的拓展,這里使用的庫(kù)是archive/zip,在gopkg里面搜zip就行,需要的朋友可以參考下2024-01-01
Golang基礎(chǔ)學(xué)習(xí)之map的示例詳解
哈希表是常見(jiàn)的數(shù)據(jù)結(jié)構(gòu)，有的語(yǔ)言會(huì)將哈希稱作字典或者映射，在Go中，哈希就是常見(jiàn)的數(shù)據(jù)類型map，本文就來(lái)聊聊Golang中map的相關(guān)知識(shí)吧2023-03-03
創(chuàng)建第一個(gè)Go語(yǔ)言程序Hello,Go!
這篇文章主要介紹了創(chuàng)建第一個(gè)Go語(yǔ)言程序Hello,Go!本文詳細(xì)的給出項(xiàng)目創(chuàng)建、代碼編寫的過(guò)程,同時(shí)講解了GOPATH、Go install等內(nèi)容,需要的朋友可以參考下2014-10-10
本文主要介紹了安裝Sublime?Text支持Go插件的方法步驟，文中通過(guò)示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2022-01-01
GoLand 中設(shè)置默認(rèn)項(xiàng)目文件夾的實(shí)現(xiàn)
本文主要介紹了GoLand 中設(shè)置默認(rèn)項(xiàng)目文件夾的實(shí)現(xiàn),默認(rèn)項(xiàng)目文件夾會(huì)在你打開(kāi)或新建項(xiàng)目時(shí)自動(dòng)預(yù)選,避免每次都需要手動(dòng)導(dǎo)航到目標(biāo)目錄,感興趣的可以了解一下2025-03-03
反射是程序在運(yùn)行期間獲取變量的類型和值、或者執(zhí)行變量的方法的能力。這篇文章主要為大家介紹了Golang反射獲取變量類型和值的方法，需要的可以參考一下2022-12-12
本文主要介紹了Golang中的深拷貝與淺拷貝使用，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2023-04-04
這篇文章主要為大家介紹了GO語(yǔ)言中err接口及defer延遲異常處理的示例分析，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步早日升職加薪2022-04-04