RocketMQ消费者的原理架构_云消息队列 RocketMQ 版(RocketMQ)-阿里云帮助中心

本文介绍云消息队列 RocketMQ 版中消费者（Consumer）的定义、模型关系、内部属性、行为约束、版本兼容性及使用建议。

定义

消费者是云消息队列 RocketMQ 版中用来接收并处理消息的运行实体。

消费者通常被集成在业务系统中，从云消息队列 RocketMQ 版服务端获取消息，并将消息转化成业务可理解的信息，供业务逻辑处理。

在消息消费端，可以定义如下传输行为：

消费者身份：消费者必须关联一个指定的消费者分组，以获取分组内统一定义的行为配置和消费状态。
消费者类型：云消息队列 RocketMQ 版面向不同的开发场景提供了多样的消费者类型，包括PushConsumer类型、SimpleConsumer类型等。具体信息，请参见消费者分类。
消费者本地运行配置：消费者根据不同的消费者类型，控制消费者客户端本地的运行配置。例如消费者客户端的线程数，消费并发度等，实现不同的传输效果。

在云消息队列 RocketMQ 版的领域模型中，消费者的位置和流程如下：

消费者分组名称

客户端ID

通信参数

预绑定订阅关系列表

定义：指定消费者的订阅关系列表。
云消息队列 RocketMQ 版服务端可在消费者初始化阶段，根据预绑定的订阅关系列表对目标主题进行权限及合法性校验，无需等到应用启动后才能校验。
取值：建议在消费者初始化阶段明确订阅关系即要订阅的主题列表，若未设置，或订阅的主题动态变更，云消息队列 RocketMQ 版会对目标主题进行动态补充校验。

消费监听器

在云消息队列 RocketMQ 版领域模型中，消费者的管理通过消费者分组实现，同一分组内的消费者共同分摊消息进行消费。因此，为了保证分组内消息的正常负载和消费，云消息队列 RocketMQ 版要求同一分组下的所有消费者以下消费行为保持一致：

如行为约束中所述，同一分组内所有消费者的投递顺序和消费重试策略需要保持一致。

云消息队列 RocketMQ 版服务端5.x版本：上述消费者的消费行为从关联的消费者分组中统一获取，因此，同一分组内所有消费者的消费行为必然是一致的，客户端无需关注。
云消息队列 RocketMQ 版服务端3.x/4.x历史版本：上述消费逻辑由消费者客户端接口定义，因此，您需要自己在消费者客户端设置时保证同一分组下的消费者的消费行为一致。

若您使用云消息队列 RocketMQ 版服务端5.x版本，客户端使用历史版本SDK，则消费者的消费逻辑以消费者客户端接口的设置为准。

云消息队列 RocketMQ 版的消费者在通信协议层面支持非阻塞传输模式，网络通信效率较高，并且支持多线程并发访问。因此，大部分场景下，单一进程内同一个消费分组只需要初始化唯一的一个消费者即可，开发过程中应避免以相同的配置初始化多个消费者。

云消息队列 RocketMQ 版的消费者是可以重复利用的底层资源，类似数据库的连接池。因此不需要在每次接收消息时动态创建消费者，且在消费完成后销毁消费者。这样频繁地创建销毁会在服务端产生大量短连接请求，严重影响系统性能。

正确示例

Consumer c = ConsumerBuilder.build();
  for (int i =0;i<n;i++)
    {
      Message m= c.receive();
      //process message
    }
c.shutdown();

典型错误示例

for (int i =0;i<n;i++)
  {
    Consumer c = ConsumerBuilder.build();
    Message m= c.receive();
    //process message
    c.shutdown();
  }