在我服务初始化的时候创建了 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) 放下面试试?? |