91超碰碰碰碰久久久久久综合_超碰av人澡人澡人澡人澡人掠_国产黄大片在线观看画质优化_txt小说免费全本

溫馨提示×

如何使用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
根河市| 清水河县| 武山县| 西贡区| 万安县| 南宁市| 柞水县| 伊宁市| 康平县| 稷山县| 霍林郭勒市| 乌兰察布市| 昌图县| 乌鲁木齐市| 博客| 惠水县| 柳江县| 五常市| 夏河县| 沙坪坝区| 临朐县| 大名县| 西充县| 土默特右旗| 白玉县| 木里| 铁岭县| 通山县| 罗城| 东台市| 渝中区| 连南| 宽城| 平顺县| 耿马| 岐山县| 金秀| 潼南县| 南宁市| 鹤岗市| 民勤县|