首页 > 代码库 > Redis七（发布订阅）
Redis七（发布订阅）
发布与订阅（pub/sub）
介绍
Redis 通过 PUBLISH 、 SUBSCRIBE 等命令实现了订阅与发布模式， 这个功能提供两种信息机制， 分别是订阅/发布到频道和订阅/发布到模式
订阅者可以订阅一个或多个频道，发布者向一个频道发送消息后，所有订阅这个频道的订阅者都将收到消息，而发布者也将收到一个数值，这个数值是收到消息的订阅者的数量。订阅者只能收到自它开始订阅后发布者所发布的消息，而之前发布的消息是收不到的。
运行原理：
Redis 的 SUBSCRIBE 命令可以让客户端订阅任意数量的频道， 每当有新信息发送到被订阅的频道时， 信息就会被发送给所有订阅指定频道的客户端。
当有新消息通过 PUBLISH 命令发送给频道 channel1 时， 这个消息就会被发送给订阅它的三个客户端：
Python下实现Redis的发布和订阅
Demo如下：
redisPubSub.py
#用来连接redis server并封装了发布与订阅的功能import redisclass RedisPubSubHelper(): def __init__(self): # redis连接对象 self.__conn = redis.Redis(host=‘192.168.49.130‘) def publish(self, message, channel): # redis对象的publish方法（发布） # 往指定的频道中发布信息 self.__conn.publish(channel, message) return True def subscribe(self, channel): # 返回了一个发布订阅的对象 pub = self.__conn.pubsub() # 订阅到指定的频道上 pub.subscribe(channel) pub.parse_response() return pub
订阅者：
#!/usr/bin/env/ python# -*-coding:utf-8 -*-import redisPubSub# 创建一个连接redis的对象（使用发布与订阅模式的redis对象）r = redisPubSub.RedisPubSubHelper()#创建发布订阅的对象redis_sub=r.subscribe(‘fm104.9‘)# 指定订阅频道while True:# 接收频道中的内容，代码会阻塞到这里，直到收到消息 msg=redis_sub.parse_response() print(msg)
发布者：
#!/usr/bin/env/ python# -*-coding:utf-8 -*-import redisPubSub# 创建一个连接redis的对象（使用发布与订阅模式的redis对象）r = redisPubSub.RedisPubSubHelper()# 向指定的频道发布消息r.publish(‘hello world‘, ‘fm104.9‘)
更多参见：https://github.com/andymccurdy/redis-py/
http://doc.redisfans.com/
Redis七（发布订阅）
声明：以上内容来自用户投稿及互联网公开渠道收集整理发布，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任，若内容有误或涉及侵权可进行投诉： 投诉/举报 工作人员会在5个工作日内联系你，一经查实，本站将立刻删除涉嫌侵权内容。