ADADADADAD

如何使用redis实现消息队列[ 建站问答 ]

建站问答时间：2024-12-01 19:15:45

作者：文/会员上传

幻兽帕鲁孵化器制作在哪里

简介：

使用redis实现消息队列的示例：redis的pubsub功能实现发布订阅模式，代码：import redisclass Task(object):def __init__(self):self.rcon = redis.StrictRedis(host='localhost'

以下为本文的正文内容，内容仅供参考！本站为公益性网站，复制本文以及下载DOC文档全部免费。

使用redis实现消息队列的示例：

redis的pubsub功能实现发布订阅模式，代码：

import redis
class Task(object):
def __init__(self):
self.rcon = redis.StrictRedis(host='localhost', db=5)
self.ps = self.rcon.pubsub()
self.ps.subscribe('task:pubsub:channel')
def listen_task(self):
for i in self.ps.listen():
if i['type'] == 'message':
print "Task get", i['data']
if __name__ == '__main__':
print 'listen task channel'
Task().listen_task()