psc := redis.PubSubConn{c}
psc.Subscribe("example")
func Receive() {
for {
switch v := psc.Receive().(type) {
case redis.Message:
fmt.Printf("%s: message: %s\n", v.Channel, v.Data)
case redis.Subscription:
fmt.Printf("%s: %s %d\n", v.Channel, v.Kind, v.Count)
case error:
return v
}
}
}
Run Code Online (Sandbox Code Playgroud)
在上面的代码中(取自Redigo doc),如果连接丢失,所有订阅也会丢失.什么是从丢失的连接恢复和重新订阅更好的方法.