python Redis速记

python Redis速记,第1张

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
###############################

欢迎分享,转载请注明来源:内存溢出

原文地址:https://54852.com/langs/787353.html

(0)
打赏 微信扫一扫微信扫一扫 支付宝扫一扫支付宝扫一扫
上一篇 2022-05-05
下一篇2022-05-05

发表评论

登录后才能评论

评论列表(0条)

    保存