Conn
对象如果需要实现长链接性的Redis
操作(例如订阅发布),那么我们可以使用Conn
方法从连接池中获取一个连接对象,随后使用该连接对象进行操作。但需要注意的是,该连接对象不再使用时,应当显式调用Close
方法进行关闭(丢回连接池)。
由于该 |
我们可以通过Redis
的Conn
实现订阅/发布模式。
package main import ( "fmt" _ "github.com/gogf/gf/contrib/nosql/redis/v2" "github.com/gogf/gf/v2/frame/g" "github.com/gogf/gf/v2/os/gctx" ) func main() { var ( ctx = gctx.New() channel = "channel" ) conn, _ := g.Redis().Conn(ctx) defer conn.Close(ctx) _, err := conn.Subscribe(ctx, channel) if err != nil { g.Log().Fatal(ctx, err) } for { msg, err := conn.ReceiveMessage(ctx) if err != nil { g.Log().Fatal(ctx, err) } fmt.Println(msg.Payload) } } |
执行后,程序将阻塞等待获取数据。
另外打开一个终端通过redis-cli
命令进入Redis Server
,发布一条消息:
$ redis-cli 127.0.0.1:6379> publish channel test (integer) 1 127.0.0.1:6379> |
随后程序终端立即打印出从Redis Server
获取的数据:
test |