Redis 实用技术——消息发布和订阅

桃扇骨 2022-11-19 01:11 287阅读 0赞

# 引言 #

发布订阅模型是redis的重要功能，它可以像网站动态一样，将消息发送到多个订阅者的主页里。

# 一、常用命令 #

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQ3NDUwNjk_size_16_color_FFFFFF_t_70][]

# 二、消息格式 #

消息是一个有三个元素的多块响应：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQ3NDUwNjk_size_16_color_FFFFFF_t_70 1][]

如上图，**发布者**向 mysub 频道发送了一条消息，redis会返回当前订阅者数量。

而**订阅者**这边，当第一次订阅时，响应块分为 3 行，

> 第一行表示**消息类型**，subscribe ：订阅成功 ；unsubscribe：表示取消订阅；message ：表示这个响应块是一个发布的消息
> 
> 第二行表示**频道名称**
> 
> 第三行根据消息类型不同，subscribe/unsubscribe 时会响应**目前订阅频道数量**，message 时会响应具体**消息内容**。

> 注意：发布订阅与key所在空间没有任何关系，它不受任何级别的干扰，例如，db1可以订阅db10的发布消息。如果需要区分某些频道，只能使用频道名称来区分，比如在频道名称前加上环境信息：dev-xxx，test-xxx，prod-xxxx等等。

# 三、模式匹配订阅 #

**psubscribe** 配合通配符来匹配多个频道，如下命令可以匹配到 dev.msg 、dev.tag.other 等符合 dev.\* 模式的全部频道：

PSUBSCRIBE dev.*

当作模式匹配结果的消息会以不同的格式发送:

> 消息类型是**pmessage**，这是另一客户端发出的PUBLISH命令的结果,匹配一个模式匹配订阅。第一个元素是原匹配的模式，第三个元素是原频道名称，最后一个元素是实际消息内容。

如果既使用了模式匹配，又使用了普通的订阅方式，例如：

subscribe foo
    psubscribe f*

那么如果一个消息被发布到 foo，客户端会接收到两条消息：一条是 message 类型，另一条是 pmessage类型。

# 四、发布订阅的使用场景与注意事项 #

Redis的发布订阅功能可以应用到哪些场景？聊天室？网站用户的动态发布？

首先，需要注意一个问题，当客户端订阅了一个频道后，那么它只能接收到订阅之后发布的消息，也就是说，**发布的消息是实时的**。

因此，我们可以用它来做一个简易聊天室，或弹幕功能。但面对更复杂一些的场景，例如，如果想在客户端加载以前发布的消息又该如何解决这个问题呢？

这里的需求是，客户端即可以接受实时消息，又可以通过某些操作获取到订阅前的历史消息，如何实现？

这时，我们就可以结合redis的其他缓存功能，例如 ZSet 来存储 3天内的发布消息，再往前的数据就持久化到数据库。

这样，我们即实现了实时的订阅发布，也细分了历史数据——三天内和更久的数据：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQ3NDUwNjk_size_16_color_FFFFFF_t_70 2][]

对于三天内的数据，如何存放在ZSet中？有两种方案，需要根据业务具体考虑，要么是根据时间，要么是根据数据数量，比如某些数据就是只需要存100条。

按时间缓存，如上图中的 3 天，是比较常见的常见，我们可以在 socre 中标记日期，以此来维持数据的容量，参考使用 zremrangebyscore（按分数，即时间戳）或zremrangebyrank（按数据量，如最后100条）。

那么具体一点的实现模型就可以是这样：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQ3NDUwNjk_size_16_color_FFFFFF_t_70 3][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQ3NDUwNjk_size_16_color_FFFFFF_t_70]: /images/20221022/c41174be468b49c7a3d149f48292e3b5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQ3NDUwNjk_size_16_color_FFFFFF_t_70 1]: /images/20221022/2a995f5c34324741a13c530aefe16990.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQ3NDUwNjk_size_16_color_FFFFFF_t_70 2]: /images/20221022/9925d71c2ba945e197d2e7853dd25f3f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQ3NDUwNjk_size_16_color_FFFFFF_t_70 3]: /images/20221022/38ea8dbcc39749da9e1a28b0ea47ce1a.png