Redis中发布订阅模式用法

飞熊 • 2023年5月10日下午10:55 • 后端笔记 • 阅读 162

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 redis

res = 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 time

res = 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')