GoFrame?gredis怎么緩存DoVar?Conn連接對象實現自動序列化

這篇文章主要介紹了GoFrame gredis怎么緩存DoVar Conn連接對象實現自動序列化的相關知識，內容詳細易懂，操作簡單快捷，具有一定借鑒價值，相信大家閱讀完這篇GoFrame gredis怎么緩存DoVar Conn連接對象實現自動序列化文章都會有所收獲，下面我們一起來看看吧。

GoFrame gredis

整體介紹

Redis客戶端由gredis模塊實現，底層采用了鏈接池設計。

gredis使用了連接池來進行Redis連接管理，通過Config配置對象或者Set*方法可以對連接池的屬性進行管理，通過Stats方法可以獲取連接池的統計信息。

我們最常用的是Do/DoVar方法，執行同步指令，通過向Redis Server發送對應的Redis API命令，來使用Redis Server的服務。Do/Var方法最大的特點是內部自行從連接池中獲取連接對象，使用完畢后自動丟回連接池中，開發者無需手動調用Close方法，方便使用。

Do/DoVar方法

我們最常用的是Do/DoVar方法，執行同步指令，通過向Redis Server發送對應的Redis API命令，來使用Redis Server的服務。

Do/Var方法最大的特點是內部自行從連接池中獲取連接對象，使用完畢后自動丟回連接池中，開發者無需手動調用Close方法，方便使用。

小技巧

Do和DoVar的區別在于返回的結果類型不一樣，DoVar返回的是gvar.Var類型，該類型對象可以執行非常方便的類型轉換。

基本使用

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 命令用于為哈希表中的字段賦值 。

如果哈希表不存在，一個新的哈希表被創建并進行 HSET 操作。

如果字段已經存在于哈希表中，舊值將被覆蓋。

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()) //打印結果： map[id:10000 name:王中陽]
}

HMSET/HMGET操作

強烈推薦，非常好用：我們可以通過map參數執行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())  //打印結果 [王中陽]
}

我們也可以通過struct參數執行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()) //打印結果： [王中陽]
}

Conn連接對象

使用Do/DoVar方法已經能夠滿足絕大部分的場景需要，如果需要更復雜的Redis操作，我們可以使用Conn方法從連接池中獲取一個連接對象，隨后使用該連接對象進行操作。

需要注意的是，該連接對象不再使用時，應當顯式調用Close方法進行關閉（丟回連接池）。

由于該Conn是個連接對象，注意該對象存在連接超時的限制，超時和服務端配置有關。

基本使用

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)) //打印結果：v
}

Send批量指令

Send可以執行批量指令，并通過Receive方法一一獲取返回結果。

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))  //打印結果：bar
}

讓我想到了之前寫的一篇爆文：Redis 如何批量設置過期時間？PIPLINE的使用

訂閱/發布

我們可以通過Redis的SUBSCRIBE/PUBLISH命令實現訂閱/發布模式。

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))
    }
}

執行后，程序將阻塞等待獲取數據。

另外打開一個終端通過redis-cli命令進入Redis Server，發布一條消息：

$ redis-cli
127.0.0.1:6379> publish channel test
(integer) 1
127.0.0.1:6379>

隨后程序終端立即打印出從Redis Server獲取的數據：

[message channel test]

自動序列化/反序列化

當給定的參數為map, slice, struct時，gredis內部支持自動對其使用json序列化，并且讀取數據時可使用gvar.Var的轉換功能實現反序列化。

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:王中陽]
}

打印結果

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:王中陽
}

打印結果

關于“GoFrame gredis怎么緩存DoVar Conn連接對象實現自動序列化”這篇文章的內容就介紹到這里，感謝各位的閱讀！相信大家對“GoFrame gredis怎么緩存DoVar Conn連接對象實現自動序列化”知識都有一定的了解，大家如果還想學習更多知識，歡迎關注億速云行業資訊頻道。