在我服务初始化的时候创建了 redis 连接池 当我想使用订阅功能的时候报了错 代码如下
//conn := p.pool.Get()
conn , _ := redis.Dial("tcp","192.168.31.226:16379")
subConn := redis.PubSubConn{conn}
subConn.Subscribe(key)
go func() {
for {
fmt.Println("wait")
switch res := subConn.Receive().(type) {
case redis.Message:
pattern := (*string)(unsafe.Pointer(&res.Pattern))
channel := (*string)(unsafe.Pointer(&res.Channel))
message := (*string)(unsafe.Pointer(&res.Data))
callback(*pattern,*channel,*message)
case redis.Subscription:
fmt.Printf("%s: %s %d\n", res.Channel, res.Kind, res.Count)
case error:
fmt.Println(res.Error())
continue
}
}
}()
当我 p.pool.Get()获取一个 redis 连接的时候 就会报错 read tcp 192.168.224.30:53698->192.168.31.226:16379: use of closed network connection 如果我注释掉这个 用了 redis.Dial 的时候 这个时候订阅又是正常的了.. 问一下 这是啥问题...
1
lewinlan 2020-03-16 23:42:18 +08:00 via Android
redigo 的连接池他自己都没信心。换 go-redis 吧。
|
2
BlackBerry999 2020-03-17 08:48:34 +08:00
subConn.Subscribe(key) 放下面试试??
|