中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

溫馨提示×

如何使用redis實現消息隊列

小新
151
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
罗源县| 邻水| 渝中区| 微博| 九龙县| 定安县| 安顺市| 新竹县| 改则县| 奉化市| 万山特区| 襄垣县| 东阳市| 威海市| 宜君县| 于田县| 涞源县| 龙游县| 濉溪县| 泌阳县| 夏邑县| 文山县| 靖西县| 年辖:市辖区| 毕节市| 邓州市| 新安县| 肇庆市| 定南县| 准格尔旗| 西林县| 巴彦淖尔市| 额尔古纳市| 时尚| 丹江口市| 广宗县| 新乡市| 邢台县| 汪清县| 美姑县| 峨眉山市|