Python&Redis 发布订阅

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了Python&Redis 发布订阅，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含938字，纯文字阅读大概需要2分钟。

内容图文

1、Redis控制台操作

先开启一个Redis控制台开启订阅：

SUBSCRIBE fm666

返回参数解释：
subscribe，表示订阅成功
unsubscribe，表示取消订阅成功
message，表示其它终端发布消息
然后开启一个Redis控制台开始发布消息：

PUBLISH fm666 "hello redis"

这是注意第一个订阅的Redis控制台会有相应的消息输出

2、Python操作Redis订阅发布

封装一个订阅发布的类

# redis_publish.py
import redis

class RedisHelper:
    def __init__(self):
        self.__conn = redis.Redis(host='111.231.135.184',port=6379)
        self.chan_sub = 'fm666'
        self.chan_pub = 'fm666'

    def public(self,msg):
        self.__conn.publish(self.chan_pub,msg)
        return True

    def subscribe(self):
        pub = self.__conn.pubsub() # 打开收音机
        pub.subscribe(self.chan_sub) # 调频道
        pub.parse_response() # 准备接收
        return pub

订阅端代码：

from redis_publish import RedisHelper

obj = RedisHelper()
redis_sub = obj.subscribe()

while True:
    msg = redis_sub.parse_response()
    print(msg)

'''
运行此程序后，在redis控制台 PUBLISH fm666 "hello redis" 
就会实时的输出
'''

内容总结

以上是互联网集市为您收集整理的Python&Redis 发布订阅全部内容，希望文章能够帮你解决Python&Redis 发布订阅所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端