溫馨提示×

如何使用redis實現消息隊列

小新
176
2020-12-25 09:17:31
欄目: 云計算

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

0
亚洲午夜精品一区二区_中文无码日韩欧免_久久香蕉精品视频_欧美主播一区二区三区美女