Linux 拨号vps windows公众号手机端

如何使用redis实现消息队列

lewis 7年前 (2018-11-16) 阅读数 11 #VPS/云服务器
文章标签 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()

版权声明

本文仅代表作者观点,不代表米安网络立场。

发表评论:

◎欢迎参与讨论,请在这里发表您的看法、交流您的观点。

热门