Redis开发与运维. 3.7　发布订阅

3.7 发布订阅

Redis提供了基于“发布/订阅”模式的消息机制，此种模式下，消息发布者和订阅者不进行直接通信，发布者客户端向指定的频道（channel）发布消息，订阅该频道的每个客户端都可以收到该消息，如图3-16所示。Redis提供了若干命令支持该功能，在实际应用开发时，能够为此类问题提供实现方法。

 

图3-16 Redis发布订阅模型

3.7.1 命令

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

1.?发布消息

publish channel message

下面操作会向channel:sports频道发布一条消息“Tim won the championship”，返回结果为订阅者个数，因为此时没有订阅，所以返回结果为0：

127.0.0.1:6379 publish channel:sports "Tim won the championship"

(integer) 0

2.?订阅消息

subscribe channel [channel ...]

订阅者可以订阅一个或多个频道，下面操作为当前客户端订阅了channel:sports频道：

127.0.0.1:6379 subscribe channel:sports

Reading messages... (press Ctrl-C to quit)

1) "subscribe"

2) "channel:sports"

3) (integer) 1

此时另一个客户端发布一条消息：

127.0.0.1:6379 publish channel:sports "James lost the championship"

(integer) 1

当前订阅者客户端会收到如下消息：

127.0.0.1:6379 subscribe channel:sports

Reading messages... (press Ctrl-C to quit)

...

1) "message"

2) "channel:sports"

3) "James lost the championship"

如果有多个客户端同时订阅了channel:sports，整个过程如图3-17所示。

有关订阅命令有两点需要注意：

客户端在执行订阅命令之后进入了订阅状态，只能接收subscribe、psubscribe、unsubscribe、punsubscribe的四个命令。

新开启的订阅客户端，无法收到该频道之前的消息，因为Redis不会对发布的消息进行持久化。

 

图3-17 多个客户端同时订阅频道channel:sports

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

3.?取消订阅

unsubscribe [channel [channel ...]]

客户端可以通过unsubscribe命令取消对指定频道的订阅，取消成功后，不会再收到该频道的发布消息：

127.0.0.1:6379 unsubscribe channel:sports

1) "unsubscribe"

2) "channel:sports"

3) (integer) 0

4.?按照模式订阅和取消订阅

psubscribe pattern [pattern...]

punsubscribe [pattern [pattern ...]]

除了subcribe和unsubscribe命令，Redis命令还支持glob风格的订阅命令psubscribe

和取消订阅命令punsubscribe，例如下面操作订阅以it开头的所有频道：

127.0.0.1:6379 psubscribe it*

Reading messages... (press Ctrl-C to quit)

1) "psubscribe"

2) "it*"

3) (integer) 1

5.?查询订阅

（1）查看活跃的频道

pubsub channels [pattern]

所谓活跃的频道是指当前频道至少有一个订阅者，其中[pattern]是可以指定具体的模式：

127.0.0.1:6379 pubsub channels

1) "channel:sports"

2) "channel:it"

3) "channel:travel"

 

127.0.0.1:6379 pubsub channels channel:*r*

1) "channel:sports"

2) "channel:travel"

（2）查看频道订阅数

pubsub numsub [channel ...]

当前channel:sports频道的订阅数为2：

127.0.0.1:6379 pubsub numsub channel:sports

1) "channel:sports"

2) (integer) 2

（3） 查看模式订阅数

pubsub numpat

当前只有一个客户端通过模式来订阅：

127.0.0.1:6379 pubsub numpat

(integer) 1

3.7.2 使用场景

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

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

视频服务订阅video:changes频道如下：

subscribe video:changes

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

publish video:changes "video1,video3,video5"

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

for video in video1,video3,video5

    update {video}

Spring boot整合Redis实现发布订阅（超详细） Redis发布订阅（pub/sub）是一种消息通信模式：发送者（pub）发送消息，订阅者（sub）接收信息。微信，微博，关注系统 Redis客户端可以订阅任意数量的频道