领域模型概述_云消息队列 RocketMQ 版(RocketMQ)-阿里云帮助中心

本文为您介绍云消息队列 RocketMQ 版的领域模型。

产品定位

云消息队列 RocketMQ 版是一款典型的分布式架构下的中间件产品，使用异步通信方式和发布订阅的消息传输模型。

通信方式和传输模型的具体说明，请参见下文通信方式介绍和消息传输模型介绍。

云消息队列 RocketMQ 版产品具备异步通信的优势，系统拓扑简单、上下游耦合较弱，主要应用于异步解耦，流量削峰填谷等场景。

对于同步链路，需要实时返回调用结果的场景，建议使用RPC调用方案。

您在进行产品选型时，请明确您的业务场景和主要需求。

领域模型

如上图所示，云消息队列 RocketMQ 版中消息的生命周期主要分为消息生产、消息存储、消息消费这三部分。

生产者生产消息并发送至云消息队列 RocketMQ 版服务端，消息被存储在服务端的主题中，消费者通过订阅主题消费消息。

生产者（Producer）：云消息队列 RocketMQ 版中用于产生消息的运行实体，一般集成于业务调用链路的上游。生产者是轻量级匿名无身份的。

主题（Topic）：云消息队列 RocketMQ 版消息传输和存储的分组容器，主题内部由多个队列组成，消息的存储和水平扩展实际是通过主题内的队列实现的。
队列（MessageQueue）：云消息队列 RocketMQ 版消息传输和存储的实际单元容器，类比于Kafka中的分区。云消息队列 RocketMQ 版通过流式特性的无限队列结构来存储消息，消息在队列内具备顺序性存储特征。
消息（Message）：云消息队列 RocketMQ 版的最小传输单元。消息具备不可变性，在初始化发送和完成存储后即不可变。

消费者分组（ConsumerGroup）：云消息队列 RocketMQ 版发布订阅模型中定义的独立的消费身份分组，用于统一管理底层运行的多个消费者（Consumer）。同一个消费组的多个消费者必须保持消费逻辑和配置一致，共同分担该消费组订阅的消息，实现消费能力的水平扩展。
消费者（Consumer）：云消息队列 RocketMQ 版消费消息的运行实体，一般集成在业务调用链路的下游。消费者必须被指定到某一个消费组中。
订阅关系（Subscription）：云消息队列 RocketMQ 版发布订阅模型中消息过滤、重试、消费进度的规则配置。订阅关系以消费组粒度进行管理，消费组通过定义订阅关系控制指定消费组下的消费者如何实现消息过滤、消费重试及消费进度恢复等。
云消息队列 RocketMQ 版的订阅关系除过滤表达式之外都是持久化的，即服务端重启或请求断开，订阅关系依然保留。

分布式系统架构思想下，将复杂系统拆分为多个独立的子模块，例如微服务模块。此时就需要考虑子模块间的远程通信，典型的通信模式分为以下两种，一种是同步的RPC远程调用；一种是基于中间件代理的异步通信方式。

同步调用

同步RPC调用模型下，不同系统之间直接进行调用通信，每个请求直接从调用方发送到被调用方，然后要求被调用方立即返回响应结果给调用方，以确定本次调用结果是否成功。

重要

此处的同步并不代表RPC的编程接口方式，RPC也可以有异步非阻塞调用的编程方式，但本质上仍然是需要在指定时间内得到目标端的直接响应。

异步调用

异步消息通信模式下，各子系统之间无需强耦合直接连接，调用方只需要将请求转化成异步事件（消息）发送给中间代理，发送成功即可认为该异步链路调用完成，剩下的工作中间代理会负责将事件可靠通知到下游的调用系统，确保任务执行完成。该中间代理一般就是消息中间件。

异步通信的优势如下：

主流的消息中间件的传输模型主要为点对点模型和发布订阅模型。

点对点模型也叫队列模型，具有如下特点：

消费匿名：消息上下游沟通的唯一的身份就是队列，下游消费者从队列获取消息无法声明独立身份。
一对一通信：基于消费匿名特点，下游消费者即使有多个，但都没有自己独立的身份，因此共享队列中的消息，每一条消息都只会被唯一一个消费者处理。因此点对点模型只能实现一对一通信。

发布订阅模型具有如下特点：

点对点模型和发布订阅模型各有优势，点对点模型更为简单，而发布订阅模型的扩展性更高。云消息队列 RocketMQ 版使用的传输模型为发布订阅模型，因此也具有发布订阅模型的特点。