python - Tornado -redis : Why the 'listen' and the 'brpop' of tornado-redis can't work at the same time

Question

代码如下:

from tornadoredis import Client
from tornado.ioloop import IOLoop
from tornado.gen import coroutine, Task

rds = Client()

@coroutine
def listen_pub():
    def handle(msg):
        print msg

    yield Task(rds.subscribe, channels='pub')
    rds.listen(handle)


@coroutine
def listen_list():
    while True:
        res = yield Task(rds.brpop, keys='list')
        print res


def test():
    listen_pub()
    listen_list()

test()
IOLoop.current().start()

当我运行上面的代码时，只有“listen_list”可以接收消息。为什么“listen_list”不起作用？如何同时收听来自 LIST 和 PUB/SUB 的消息？

Answer 1

看一下redis文档:

A client subscribed to one or more channels should not issue commands, although it can subscribe and unsubscribe to and from other channels. The reply of the SUBSCRIBE and UNSUBSCRIBE operations are sent in the form of messages, so that the client can just read a coherent stream of messages where the first element indicates the type of message.

你必须使用两个连接客户端。
来源:http://redis.io/topics/pubsub