使用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()
了解更多如何使用redis实现消息队列相关的解答,就上多想派(www.duoxiangpai.com)。
本文章由用户七点生活分享,版权归原作者,如侵犯,请联系(点这里联系),经核实,我们将第一时间删除。如若转载,请注明出处:https://www.duoxiangpai.com/64651.html