跳转至主要内容
版本: 5.0

订阅 (Subscription)

本节介绍 Apache RocketMQ 中订阅的定义、模型关系、内部属性和使用注意事项。

定义​

订阅是 Apache RocketMQ 中消费者获取和处理消息的规则与状态设置。

订阅由消费者组动态注册到服务端（Broker）。消息会根据订阅中定义的过滤规则进行匹配和消费。

通过配置订阅，您可以控制以下消息行为：

  • 消息过滤规则：这些规则用于定义消费者消费主题（Topic）中的哪些消息。通过配置消息过滤规则，消费者可以有效地获取所需的消息，并根据不同的业务场景指定消息接收范围。有关更多信息，请参阅 消息过滤。

  • 消费状态：默认情况下，Apache RocketMQ 服务端提供持久化订阅。也就是说，在消费者组订阅了某个服务端后，即使组内的消费者重新连接，它们也可以从上次停止消费的位置继续消费消息。

订阅的判定规则​

Apache RocketMQ 的订阅基于消费者组和主题进行设计。因此，订阅是指特定的消费者组对某个主题的订阅。以下描述了订阅的判定规则：

  • 一主题对多订阅：下图显示了两个消费者组（Group A 和 Group B）订阅了 Topic A。这两个订阅彼此独立，可以分别定义。 订阅关系分组不同

  • 一订阅对多主题：下图显示了一个消费者组（Group A）订阅了两个主题：Topic A 和 Topic B。Group A 中的消费者对 Topic A 和 Topic B 分别有两项独立的订阅。这两项订阅彼此独立，可以分别定义。 订阅关系分组不同

模型关系​

下图展示了订阅在 Apache RocketMQ 领域模型中的位置。订阅

  1. 消息由生产者初始化并发送到 Apache RocketMQ 服务端。

  2. 消息按到达 Apache RocketMQ 服务端的顺序存储在主题的指定队列中。

  3. 消费者根据指定的订阅关系从 Apache RocketMQ 服务端获取并消费消息。

内部属性​

过滤类型

  • 定义：消息过滤规则的类型。为订阅设置消息过滤规则后，系统会根据该规则匹配主题中的消息。只有满足条件的消息才会投递给消费者。此功能可帮助您根据需求对发送给消费者的消息进行分类。

  • 值

    • Tag 过滤：基于标签字符串进行全文本过滤和匹配。

    • SQL92 过滤：基于 SQL 语法对消息属性进行过滤和匹配。

过滤表达式

  • 定义：自定义过滤规则的表达式。

  • 值：有关更多信息，请参阅 过滤表达式语法。

行为约束​

订阅一致性

Apache RocketMQ 基于消费者组管理订阅。因此，同一个消费者组内的消费者必须保持相同的消费逻辑。否则，会发生消费冲突，进而导致部分消息被错误地消费。

  • 正确示例

    //Consumer c1
    Consumer c1 = ConsumerBuilder.build(groupA);
    c1.subscribe(topicA,"TagA");
    //Consumer c2
    Consumer c2 = ConsumerBuilder.build(groupA);
    c2.subscribe(topicA,"TagA");

  • 错误示例

    //Consumer c1
    Consumer c1 = ConsumerBuilder.build(groupA);
    c1.subscribe(topicA,"TagA");
    //Consumer c2Consumer 
    c2 = ConsumerBuilder.build(groupA);
    c2.subscribe(topicA,"TagB");

使用说明​

请勿频繁修改订阅。

在 Apache RocketMQ 中，订阅与元数据以及过滤规则、消费进度等配置相关联。系统必须确保消费者组中所有消费者的消费行为、消费逻辑和负载策略保持一致。这些因素导致需要管理的关系网络非常复杂。因此，我们建议不要在生产环境中频繁修改订阅以变更业务逻辑。否则，客户端需要不断调整负载分布，这会导致消息接收问题。