redis遇到的坑

PUBSUB发布订阅模式的listen坑

• demo

r = redis.Redis(host=host, port=port, db=db)
p = r.pubsub()
p.psubscribe('channel')

for message in p.listen():
    print(message)

上面代码订阅者进入监听, 如果要停止监听在windows环境和linux有区别
windows:
在其他线程停止监听，只需要调p.close()
linux:
在其他线程停止监听, 需要先取消订阅，再调p.close()。如果只调了p.close()。连接是断掉了，但是listen仍然阻塞，需要等待下一个消息上来的时候才会报I/O已经断开。

p.punsubscribe('channel')
p.close()