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
}
}
}
在上面的代码中(取自Redigo doc),如果连接丢失,所有订阅也会丢失。什么是更好的方式来恢复丢失的连接和重新订阅。如何在Redlang(redigo)Pubsub中更好地编写Golang中的Receive()?
如何创建['redis.Pool'(https://godoc.org/github.com/garyburd/redigo/redis#Pool),其'拨号'功能也订阅适当的渠道。 –
@ tim-cooper很干净的方式。 +1 – kic