
rc = redis.Redis(host = '127.0.0.1')#创建Redis对象
###############################
rc.lpush('msglist', msg)#从左边开始存入消息队列,msglist就对应着key,后面的msg就是valuelist,从左侧存入列表,最后一个存入的就应该是列表的第一个元素,比较容易理解。
job = rc.brpop("msglist",3)#从msglist中移除最后一个value,如果列表为空,就等待3s.
rc.set('msglist', 'Done') # 将msglist中的msg修改为Done
rc.llen('msglist') #msglist中msg的长度啊
###############################
rc.publish('msg_channel',msg )#将消息msg,发送到msg_channel频道
ps = rc.pubsub()
ps.subscribe('msg_channel') # 从msg_channel订阅消息
for item in ps.listen(): #监听状态:有消息发布了就拿过来
if item['type'] == 'message':
print(item['channel']) # msg_channel频道
print(item['data']) # msg
###############################
欢迎分享,转载请注明来源:内存溢出
微信扫一扫
支付宝扫一扫
评论列表(0条)