Redis:20---常用功能之（发布与订阅）

向右看齐 2022-12-30 13:53 119阅读 0赞

# **一、发布与订阅概述** #

*  Redis提供了基于“发布/订阅”模式的消息机制，此种模式下，消息发布者和订阅者不进行直接通信，发布者客户端向指定的频道（channel）发布消息，订阅该频道的每个客户端都可以收到该消息。
 *   下图展示了频道 channel1 ， 以及订阅这个频道的三个客户端 —— client2 、 client5 和 client1 之间的关系：

![format_png][]

当有新消息通过 PUBLISH 命令发送给频道 channel1 时， 这个消息就会被发送给订阅它的三个客户端：

![format_png 1][]

*  
 *  Redis主要提供了发布消息、订阅频道、取消订阅以及按照模式订阅和取消订阅等命令

# **二、发布消息（publish）** #

PUBLISH <channel> <message>

*  当一个客户端执行PUBLISH命令的时候，会将消息message发送给频道channel
 *  例如：下面操作会向channel:sports频道发布一条消息“Tim won the championship”，返回结果为订阅者个数，因为此时没有订阅，所以返回结果为0

publish channel:sports "Tim won the championship"

![format_png 2][]

# **二、订阅消息（subscribe）** #

subscribe channel [channel...]

*  订阅者可以订阅一个或多个频道
 *  注意事项：
 *   *  客户端在执行订阅命令之后进入了订阅状态，只能接收subscribe、 psubscribe、unsubscribe、punsubscribe的四个命令
     *  新开启的订阅客户端，无法收到该频道之前的消息，因为Redis不会对发布的消息进行持久化

### 演示案例 ###

*  下面操作为当前客户端订阅了channel：sports频道：

subscribe channel:sports

![format_png 3][]

*  此时右侧另一个客户端向channel：sports频道发布一条消息，右侧客户端会收到这条消息

publish channel:sports "James lost the championship"

![format_png 4][]

*  开发提示：和很多专业的消息队列系统（例如Kafka、RocketMQ）相比，Redis的发布订阅略显粗糙，例如无法实现消息堆积和回溯。但胜在足够简单，如果当前场景可以容忍的这些缺点，也不失为一个不错的选择

# **三、取消订阅（unsubscribe）** #

unsubscribe [channel [channel ...]]

*  客户端可以通过unsubscribe命令取消对指定频道的订阅，取消成功后， 不会再收到该频道的发布消息
 *  取消订阅只对本个客户端有效，不会对其他客户端造成影响
 *  例如：

![format_png 5][]

# **四、模式订阅/取消模式订阅（psubscribe、punsubscribe）** #

psubscribe pattern [pattern...]
    punsubscribe [pattern [pattern ...]]

*  psubscribe和punsubscribe是支持glob风格的订阅/取消订阅，称之为“模式订阅”

### 例如： ###

*  下面左侧客户端订阅以it开头的所有频道

psubscribe it*

![format_png 6][]

*  右侧客户端向itformation频道发送一条消息，左侧客户端可以收到这条消息

![format_png 7][]

# **五、查询订阅** #

### ①查询活跃的频道 ###

pubsub channels [pattern]

*  所谓活跃的频道是指当前频道至少有一个订阅者，其中\[pattern\]是可以指定具体的模式
 *  例如，下面左侧客户端订阅一个名为“it\_redis”的频道，右侧使用pubsub查询，结果会显示出来

![format_png 8][]

*  当然，我们也可以具体指出查询哪个频道，如果频道不存在会返回空

![format_png 9][]

*  当有模式订阅时，也可以检测出来

![format_png 10][]

### ②查看频道订阅数 ###

pubsub numsub [channel ...]

*  该命令不仅可以检测出是否有活跃的频道，还能检测出频道的订阅数
 *  例如，左侧一个客户端订阅channel:sports频道，右侧客户端查询结果为1

![format_png 11][]

### ③查看模式订阅数 ###

pubsub numpat

*  该命令可以查询出当前服务器中有多少个模式订阅
 *  例如，当前所有客户端中只有左侧一个订阅，并且不是模式订阅，所以右侧结果显示为0

![format_png 12][]

*  现在我们在左侧开启模式订阅，右侧查询结果显示为1

![format_png 13][]

# **六、发布-订阅的使用场景** #

*  聊天室、公告牌、服务之间利用消息解耦都可以使用发布订阅模式
 *  下面以简单的服务解耦进行说明。如下图所示，图中有两套业务：
 *   *  上面为视频管理系统，负责管理视频信息
     *  下面为视频服务面向客户，用户可以通过各种客户端（手机、浏览器、接口）获取到视频信息

![format_png 14][]

*  假如视频管理员在视频管理系统中对视频信息进行了变更，希望及时通知给视频服务端，就可以采用发布订阅的模式，发布视频信息变化的消息到指定频道，视频服务订阅这个频道及时更新视频信息，通过这种方式可以有效解决两个业务的耦合性
 *  视频服务订阅video：changes频道如下：

subscribe video:changes

*  视频管理系统发布消息到video：changes频道如下：

publish video:changes "video1,video3,video5"

*  当视频服务收到消息，对视频信息进行更新，如下所示：

for video in video1,video3,video5
    update {video}

[format_png]: /images/20221120/42de0c665ed14599bcf121ed15cf17ef.png
[format_png 1]: /images/20221120/662c8ab3ab454e6785ff5c9d30a152e6.png
[format_png 2]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X3BuZy9iYW5mR29Ka1ZZamdQNTh5MFpOcE5kS2N4WGdvMXJsSU9neDFKcEQydUltZ250OWd2U0FJWURpYkZuMzNFc0pFN0JCdUR2ZDVnNlFpYXRWc2o0Ukw2c1dnLzY0MA?x-oss-process=image/format,png
[format_png 3]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X3BuZy9iYW5mR29Ka1ZZamdQNTh5MFpOcE5kS2N4WGdvMXJsSXZ1M2JpY0wxeE12SXlNbVRPZ2VHNjNINWJuRDc5NDNkRmZpYmJzVXhpYnpJS2czdDBqbXlXa0Z4Zy82NDA?x-oss-process=image/format,png
[format_png 4]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X3BuZy9iYW5mR29Ka1ZZamdQNTh5MFpOcE5kS2N4WGdvMXJsSWxxWVBSRjltU1ZtSnh0RUhnYktwOTVYTW5CV3MyaWIxY2xzRTB0UnM1U0dwYkZ0NEtZcDl2NVEvNjQw?x-oss-process=image/format,png
[format_png 5]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X3BuZy9iYW5mR29Ka1ZZamdQNTh5MFpOcE5kS2N4WGdvMXJsSUI4VGZQeUo5U1lZM3JraFVQaHZmT0w4Y3l1bEV4OXlKdWRpY2xFRTdiTlNzQ1lvSUk0TEpNbUEvNjQw?x-oss-process=image/format,png
[format_png 6]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X3BuZy9iYW5mR29Ka1ZZamdQNTh5MFpOcE5kS2N4WGdvMXJsSVhYbXJLT1c5Skc3MGJuaWI5WVFEY0NCeWlhSTQ1QmY0V3RQMDNvTWJlNHA4aWJZZmxId0FGc0hGQS82NDA?x-oss-process=image/format,png
[format_png 7]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL3N6X21tYml6X3BuZy9hVU1CVWxxMEk0ZXlDcDY2UUt1S2ZpY2lhaWFnY0VMR0lpYzQ1N3p1Ym81aDNsYWUxSFh2R3p5cmhSWFI5VFhJRlo0T2g1bHdWQkkyeHFvbk1FVU0xZ2dTYUEvNjQw?x-oss-process=image/format,png
[format_png 8]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X3BuZy9iYW5mR29Ka1ZZamdQNTh5MFpOcE5kS2N4WGdvMXJsSXlyd0doREdncUNqY2liNnVYNzVFekV2RU1iUXRCQWV5ODdkbGZDY2FnU1NQWDR2YllpYXlSbG9RLzY0MA?x-oss-process=image/format,png
[format_png 9]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X3BuZy9iYW5mR29Ka1ZZamdQNTh5MFpOcE5kS2N4WGdvMXJsSWtMaWE4SGlia2NGc1JpY3VEcUd2VWRCZjByWDFVVDllWXVUUDZWeWRXU1lpY2VvT2RBOFVpY1hIeVVBLzY0MA?x-oss-process=image/format,png
[format_png 10]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X3BuZy9iYW5mR29Ka1ZZamdQNTh5MFpOcE5kS2N4WGdvMXJsSTlMa0tsb2M5V2RqV1dPRHpmMjJNZ1NtVDNUQTJJMEl3eHdpYVBpY3AxMThWVTV1QmxVOU1BOGVBLzY0MA?x-oss-process=image/format,png
[format_png 11]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X3BuZy9iYW5mR29Ka1ZZamdQNTh5MFpOcE5kS2N4WGdvMXJsSWxyZnhOYlZGOXg1eHFiTFNIUndkTEQzMVhOQ0RtZzZCN2ZpYUU0elVlUVd5RXI0Y2hGaFA0b3cvNjQw?x-oss-process=image/format,png
[format_png 12]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X3BuZy9iYW5mR29Ka1ZZamdQNTh5MFpOcE5kS2N4WGdvMXJsSTJrd0QwbEVjc0l0SHJHdnI3dW9SaWNKOHF2MlppY2FiaWNyTHduaWN2WFR1NEJ0dnY5N015TXVndGcvNjQw?x-oss-process=image/format,png
[format_png 13]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X3BuZy9iYW5mR29Ka1ZZamdQNTh5MFpOcE5kS2N4WGdvMXJsSWRzZFBpY0VwZTFqYUtDRWlhUnU3RXhSTUtiMmY3UWt6NFlpYVlpYVkxTTkwd2NpYmliTjZFUkxqWmliQmcvNjQw?x-oss-process=image/format,png
[format_png 14]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X3BuZy9iYW5mR29Ka1ZZaWF0dkZndGljUUlGY0RqM0QxTzREdHI4ZkxnMzY5YmZPUGliVUVlVkZpY1VOWlFQM2lhS2dCY3NHNXZGVFpuTUZ6UUVFQ0JoOExuaWFiU1cxUS82NDA?x-oss-process=image/format,png