Redis中发布订阅模式用法

1、发布订阅模式介绍

        发布和订阅是进程间的一种消息通信模式：发送者（publisher）将消息发送给一个第三方，订阅者（subscriber）从第三方那里接收消息。

        这个第三方我们通常称之为 消息中间件，消息中间件主要是用来做系统之间的异步通信，常见的消息中间件有：ActiveMQ，RocketMQ，RabbitMQ，Kafka 等。 
        Redis 一般不用来做消息中间件，只用它做缓存，但是它仍然提供了这个功能。

2、应用场景

如：订阅了头条上的某个栏目的新闻，当这个栏目有新的新闻的时候，头条（服务端）会主动推送给我们，而我们（客户端）无需主动请求。

3、优缺点

3.1 优点

        由于我们所需的消息并不是从服务器直接请求得来，而是从消息中间件获得，因此缓解了服务端在高并发量情况下的压力。

3.2 缺点

• 如果消费者不在线，消息可能接受不到（当然可以通过持久化存储的方式来解决）。
• 实时性相对于服务器-客户端这种一对一的通信方式来说低一些。

4、Redis实现发布订阅模式

涉及到的命令：

• subscribe c1 c2 c3 ...：订阅 c1，c2，c3，…等频道。
• psubscribe new*：订阅前缀为 new 的频道。
• publish channel message：向 channel 频道发送 message 消息。

4.1 打开多个窗口分别作为生产者和消费者

4.2 输入subscribe x y z后进入等待状态，等待订阅的频道发送消息

subscribe x y z

4.3 向频道发布消息

publish x hello_world

4.4 通过通配符订阅多个频道

psubscribe new*

5、python实现发布订阅模式

• publish：将信息发布到指定的频道；
• subscribe：订阅一个或者多个频道；
• psubscribe：订阅一个或多个符合特定模式的频道；
• unsubscribe：退订一个或多个频道；
• punsubscribe：退订一个或多个特定模式的频道。

5.1 订阅端

示例代码：

import redisres = redis.from_url('redis://192.168.124.49')
print(res)p = res.pubsub()
p.subscribe(['test1', 'test2', 'test3'])
p.subscribe(['aaa', 'bbb', 'aaaAAA'])for item in p.listen():if item['type'] == 'pmessage' or item['type'] == 'message':print(item['channel'], item['data'])p.unsubscribe('test2')

5.2 发布端

示例代码：

import redis
import timeres = redis.from_url('redis://192.168.124.49')
print(res)while True:time.sleep(1)res.publish('test1', '123')res.publish('test2', '456')res.publish('test3', '789')res.publish('aaa', 'aaa123')res.publish('bbb', 'bbb123')res.publish('aaaAAA', 'aaa456')res.publish('aaaaaa', 'aaaaaa123')

本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场，不承担相关法律责任。如若转载，请注明出处。 如若内容造成侵权/违法违规/事实不符，请点击【内容举报】进行投诉反馈！