Redis组件介绍(六)

写在前面

今天学习redis最后的知识。

Redis 的发布与订阅

发布/订阅模式

Redis 提供了两种发布/订阅模式:

  • 基于频道 (Channel) 的发布/订阅
  • 基于模式 (Pattern) 的发布/订阅

相关命令

  1. 订阅频道

    subscribe channel [channel ...]
    

    订阅给定的一个或多个频道。

  2. 退订频道

    unsubscribe channel [channel ...]
    

    退订给定的频道。若没有指定频道,则默认退订所有频道。

  3. 发布消息

    publish channel message
    

    将消息发送给指定频道 channel。返回结果:接收到信息的订阅者数量,无订阅者返回 0。

  4. 查看活跃频道

    pubsub channels [argument [argument ...]]
    

    查看订阅与发布系统的状态。返回活跃频道列表(即至少有一个订阅者的频道,订阅模式的客户端除外)。

  5. 按模式订阅

    psubscribe pattern1 [pattern ...]
    

    订阅一个或多个符合给定模式的频道。每个模式以 * 作为匹配符;例如 shujia* 匹配所有以 shujia 开头的频道,如 shujia.javashujia.hadoop

  6. 按模式退订

    punsubscribe [pattern [pattern ...]]
    

    退订所有给定模式的频道。若 pattern 未指定,则退订所有模式;否则只退订指定的模式。

消息队列

在 Redis 中,List 数据类型可以用于排队数据,按照顺序取出,但无法精确获取(双端队列)。这种方式存在两个局限性:

  • 不能支持一对多的消息分发。
  • 如果生产者生成的速度远大于消费者的消费速度,易堆积大量未消费的消息。

角色

  • 发布者(Publisher):使用 PUBLISH 命令将消息发布到指定的频道。
  • 订阅者(Subscriber):使用 SUBSCRIBE 命令订阅一个或多个频道以接收消息。所有订阅同一频道的订阅者都会收到此消息。
  • 频道(Channel):频道是消息的通道,发布者通过指定频道来发布消息,订阅者通过订阅频道来接收相关消息。
  • 消息(Message):由发布者发送给订阅者的数据。

注意

  1. 订阅者使用 SUBSCRIBE 命令订阅频道后,将会一直等待新消息。可以使用 UNSUBSCRIBE 命令取消订阅。
  2. Redis 的发布订阅模式不保证消息的可靠传递。如果订阅者在消息发布之前已断开连接,则无法接收到已发布的消息。换句话说,如果先发布消息,再订阅频道,不会收到订阅之前就发布到该频道的消息!
  3. Redis 提供了其他相关命令和功能,如按模式订阅 (PSUBSCRIBE)、取消订阅 (UNSUBSCRIBE) 等。可以查阅 Redis 文档以获取更多信息。

请注意:在高吞吐量和大规模发布订阅场景下,Redis 的发布订阅模式可能不是最佳选择,可以考虑使用专门的消息队列系统来替代。

状态解释

localhost:7000> subscribe xiaohu1
Reading messages... (press Ctrl-C to quit)
1) "subscribe"  # 返回值类型:表示订阅成功!
2) "xiaohu1"   # 订阅频道的名称
3) (integer) 1  # 当前客户端已订阅频道的数量

示意图

  • 频道订阅:订阅频道时先检查字段内部是否存在;不存在则为当前频道创建一个字典,并创建一个链表存储客户端 ID;否则直接将客户端 ID 插入到链表中。
  • 取消频道订阅:取消时将客户端 ID 从对应的链表中删除;如果删除之后链表为空,则将会把这个频道从字典中删除。
  • 发布:首先根据 channel 定位到字典的键,然后将信息发送给字典值链表中的所有客户端。