云服务器网：购买云服务器和VPS必上的网站!

怎样使用redis实现消息队列

专栏 yuntue 2023年8月9日评论

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

怎样使用redis实现消息队列

使用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()

本文来源：https://www.yuntue.com/post/57702.html | 云服务器网，转载请注明出处！