结果处理

可以看到通过客户端方法Do/Receive获取的数据都是二进制形式[]byte的,需要开发者手动进行数据转换。

当然,gredis模块也提供了DoVar/ReceiveVar方法,用以获取可供方便转换的gvar.Var通用变量结果。通过gvar.Var的强大转换功能可以转换为任意的数据类型,如基本数据类型Int,String,Strings,或者结构体Struct等等。

DoVar示例

  1. package main
  2. import (
  3. "fmt"
  4. "github.com/gogf/gf/frame/g"
  5. "github.com/gogf/gf/util/gconv"
  6. )
  7. func main() {
  8. conn := g.Redis().Conn()
  9. defer conn.Close()
  10. conn.Do("SET", "k", "v")
  11. v, _ := conn.DoVar("GET", "k")
  12. fmt.Println(v.String())
  13. }

执行后,输出结果为:

  1. v

ReceiveVar示例

  1. package main
  2. import (
  3. "fmt"
  4. "github.com/gogf/gf/frame/g"
  5. )
  6. func main() {
  7. conn := g.Redis().Conn()
  8. defer conn.Close()
  9. _, err := conn.Do("SUBSCRIBE", "channel")
  10. if err != nil {
  11. panic(err)
  12. }
  13. for {
  14. reply, err := conn.ReceiveVar()
  15. if err != nil {
  16. panic(err)
  17. }
  18. fmt.Println(reply.Strings())
  19. }
  20. }

执行后,程序将阻塞等待获取数据。

另外打开一个终端通过redis-cli命令进入Redis Server,发布一条消息:

  1. $ redis-cli
  2. 127.0.0.1:6379> publish channel test
  3. (integer) 1
  4. 127.0.0.1:6379>

随后程序终端立即打印出从Redis Server获取的数据:

  1. [message channel test]

HashSet示例

HashSet是我们比较常用的Redis数据结构,我们可以非常方便地将Redis中的HashSet获取并转换为Golang Map

  1. package main
  2. import (
  3. "fmt"
  4. "github.com/gogf/gf/container/gvar"
  5. "github.com/gogf/gf/frame/g"
  6. )
  7. func main() {
  8. var (
  9. err error
  10. result *gvar.Var
  11. key = "user"
  12. )
  13. _, err = g.Redis().Do("HSET", key, "id", 10000)
  14. if err != nil {
  15. panic(err)
  16. }
  17. _, err = g.Redis().Do("HSET", key, "name", "john")
  18. if err != nil {
  19. panic(err)
  20. }
  21. result, err = g.Redis().DoVar("HGETALL", key)
  22. if err != nil {
  23. panic(err)
  24. }
  25. fmt.Println(result.Map())
  26. // May Output:
  27. // map[id:10000 name:john]
  28. }