redis - 如何获得tornadoredis听取值(value)

我想写一个聊天演示与龙卷风和redis。我使用redis订阅，但我写的不是工作。当我运行代码时，iterm输出

listening 8000
GroupChat here
getMsg here
None
None

我在redis cli中发布testc helloword，iterm输出：

[I 150401 18:30:57 web:1825] 304 GET /groupchat?key=testc (127.0.0.1) 2.40ms
Message(kind=u'message', channel=u'testc', body=u'helloword', pattern=u'testc')

我只想在groupchat.get中获取消息，但没有。有人帮我吗？
这里是群聊代码：

class GroupChat(tornado.web.RequestHandler):
    def initialize(self):
        print 'GroupChat here'
        self.c = tornadoredis.Client(host=CONFIG['REDIS_HOST'], port=CONFIG['REDIS_PORT'], password=CONFIG['REDIS_AUTH'])
        self.channelMsgModel = channelMsgModel(self.c)
    @tornado.gen.coroutine
    def get(self):
        try:
            key = self.get_argument('key')
            info = yield self.channelMsgModel.getMsg(key)
            print info
            self.finish(info)
        except Exception, e:
            print e
        pass

channelmsgmodel代码如下：
导入tornado.gen

class channelMsgModel :
    timeout = 10
    def __init__(self, redisobj):
        self.redisobj = redisobj

    @tornado.gen.coroutine
    def getMsg(self, key):
        print 'getMsg here'
        yield tornado.gen.Task(self.redisobj.subscribe, key)
        info = self.redisobj.listen(self.on_message)
        print info
        raise tornado.gen.Return(info)

    def on_message(self, msg):
        if (msg.kind == 'message'):
            print msg
            return msg
        elif (msg.kind == 'unsubscribe'):
            self.redisobj.disconnect()
            # raise tornado.gen.Return(False)

最佳答案

使用toro.Queue（即将发布的版本4.2中包含在Tornado中）：

class channelMsgModel:
    def __init__(self, redisobj):
        self.redisobj = redisobj
        self.queue = toro.Queue()

    @gen.coroutine
    def getMsg(self, key):
        yield gen.Task(self.redisobj.subscribe, key)
        self.redisobj.listen(self.on_message)
        info = yield self.queue.get()
        raise tornado.gen.Return(info)

    def on_message(self, msg):
        if (msg.kind == 'message'):
            self.queue.put_nowait(msg)
        elif (msg.kind == 'unsubscribe'):
            self.redisobj.disconnect()

关于redis - 如何获得tornadoredis听取值(value)，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/29388620/