一个 Golang redigo 奇怪的问题

[hcyg]

在我服务初始化的时候创建了 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 的时候 这个时候订阅又是正常的了.. 问一下 这是啥问题...

[lewinlan]

redigo 的连接池他自己都没信心。换 go-redis 吧。

[BlackBerry999]

subConn.Subscribe(key) 放下面试试？？

[wzw]

@lewinlan #1 redis golang 的话 直接选 go-redis 吗?