【RocketMQ】各组件概念介绍

超、凢脫俗 2021-10-19 06:40 432阅读 0赞

**【引言】**

关于RocketMQ的安装教程和Spring Boot的集成，在前面的两篇博客中做了相关总结。本篇博客主要总结RocketMQ中的相关组件，这也是了解其原理必须要知道的理论知识。

**【核心概念】**

*  **生产者（Producer）**

生产者是指将由业务系统产生的消息发送到brokers中。RocketMQ提供了多种发送消息的模式：同步的、异步的和单向的。

*  **生产组（Producer Group）**

具有相同角色的生产者组合在一起。如果原始生产者在事务之后崩溃，在相同组中的生产者的另一个不同的实例则可以通过broker联系，提交或回滚事务。

*  **消费者（Consumer）**

消费者从brokers中拉取消息，并且将消息传递给业务系统。从用户应用的角度看，提供了两种类型的消费者：

1.  **拉取（PullConsumer）**：主动的从brokers拉取消息，一旦有消息，业务系统便会开始消费进程。
2.  **推送（PushConsumer）**：实际上封装了拉取消息，在内部进行消费进程，并且维持其他工作；为用户留下接口，以实现消息到达时被执行。

*  **消费组（Consumer Group）**

类似生产组，具有相同角色的消费者组合在一起叫做消费组。在消息消费方面达到负载均衡和容错目标非常简单。

*  **主题（Topic）**

主题是生产者生产消息和消费者消费消息的类别。主题与生产者和消费者的关系非常松散。具体而言，主题可能有0个、1个或者多个生产者向其发送消息；

相反地，一个生产者可以向不同主题发送消息。从消费者的角度，一个主题可能被0个、1个或者多个消费者组订阅。类似地，消费者组可以订阅一个或多个主题，只需要该组的实例保证订阅一致即可。

*  **消息（Message）**

消息就是被传递的信息。消息必须要有一个主题，可以将其解释为邮件地址。消息还可以有可选的标记及键值对。比如说，我们可以为消息设置一个业务key值，从而在开发过程中用来在broker服务器中查找问题。

*  **消息队列（Message Queue）**

主题可以被分为一个或多个子主题，称为消息队列。

*  **标记（Tag）**

标记，换而言之子主题，给用户提供更大的便利性。有了标记，来自同一业务模块具有不同目的的消息可以具有相同的主题和不同的标记。标记有利于保持代码的清晰和连贯，并且标记也方便了RocketMQ提供的查询系统的使用。

*  **经纪人（Broker）**

RocketMQ系统中重要的组成部分。它用来接收生产者收到的消息，存储消息并且准备处理消费者的拉取请求。它也存储消息的元数据，例如消费组，消费进程的偏移量以及主题/队列信息。

*  **名称服务器（Name Server）**

用来充当路由信息提供者。消费者和生产者客户端查找主题以查找相应的代理列表。

*  **消息模式（Message Model）**

1.  **集群模式（Clustering）**

在Clustering模式下，同一个ConsumerGroup（GroupName）里的每个Consumer只消费所订阅消息的一部分内容，同一个ConsumerGroup里所有的Consumer消费的内容合起来才是所订阅Topic内容的整体，从而达到负载均衡的目的。

1.  **广播模式（Broadcasting）**

在Broadcasting模式下，同一个ConsumerGroup里的每个Consumer都能消费到所订阅Topic的全部消息，也就是一个消息会被多次分发，被多个Consumer消费。

*  **消息顺序（Message Order）**

当使用DefaultMQPushConsumer时，可以按顺序或同时使用消息。

1.  **顺序（Orderly）**：按顺序消费消息意味着是按照生产者发送的顺序进行消费。如果使用全局顺序场景，必须确保使用该主题的只有一个消息队列。

注意：如果指定了是有序消费，那么最大并发量是消费者组订阅的消息队列的数量。

1.  **并发（Concurrently）**：如果指定了并发消费消息，最大的并发量是为每个使用者客户端指定的线程池的数量。

注意：消息的顺序在此模式下是不能保证的。

**【总结】**

有了实际应用的集成过程，对于这些概念也是比较容易理解的。相互地，理解了这些概念，结合实际应用的场景，也就能够选择合适的模式。

发表评论取消回复

表情：

评论列表（有 0 条评论，432人围观）

还没有评论，来说两句吧...

相关阅读

相关 Mina各组件介绍

ina各组件介绍上一篇文章已经系统的介绍了Mina的运行流程，Apache推出的Mina性能上很是高效，上章节我们知道内部有很多的类，各个类之间的依赖也是很多，他们之家都...

末蓝、/ 2024年04月17日 05:24/ 0 赞/ 57 阅读

相关 RocketMQ 介绍及基本概念

1 介绍 RocketMQ作为一款纯java、分布式、队列模型的开源消息中间件，支持事务消息、顺序消息、批量消息、定时消息、消息回溯等。 1.1 RocketMQ 特

缺乏、安全感/ 2023年10月01日 16:35/ 0 赞/ 4 阅读

相关 RocketMQ各组件介绍

Rocket 架构主要分为4部分： Producer 消息发布者，支持分布式集群部署。Produer 通过 MQ 负载均衡模块选择相应 Broker 中的 queu

桃扇骨/ 2023年06月01日 05:49/ 0 赞/ 8 阅读

相关 RocketMQ基本概念

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ub

逃离我推掉我的手/ 2022年11月08日 11:56/ 0 赞/ 200 阅读

相关 RocketMQ 中Topic、Tag、GroupName基本概念介绍

本文主要介绍RocketMQ中Topic、Tag、GroupName的概念、设计初衷以及使用方法。一.Topic 首先看看官方的定义： > Topic是生产者在发送

妖狐艹你老母/ 2022年10月18日 12:50/ 0 赞/ 455 阅读

相关 rocketmq概念总结

一、RocketMQ是一款分布式、队列模型的消息中间件，单机支持1万以上的持久化队列，前提是足够的内存、硬盘空间。消息队列主要的应用场景：异步处理，应用解耦，流量削峰，消息

太过爱你忘了你带给我的痛/ 2022年07月13日 12:16/ 0 赞/ 228 阅读

相关 RocketMQ概念模型

RocketMQ概念模型一前言对于任何一款中间件产品而言，清晰的概念模型是帮助用户正确理解使用它的关键。由于RocketMQ并没有遵循业界现有的JMS或AMQP规

灰太狼/ 2022年04月23日 07:38/ 0 赞/ 234 阅读

相关 RocketMQ基本概念

基本概念消息模型（Message Model） RocketMQ主要由 Producer、Broker、Consumer 三部分组成，其中Producer 负责生

小咪咪/ 2022年02月24日 10:42/ 0 赞/ 243 阅读

相关 SpringMVC执行流程以及各组件介绍

什么是SpringMVC SpringMvc 是Spring 的一个基于MVC开发的一个框架，用来处理前端请求，可以和Spring无缝整合描述 SpringMVC的

深碍√TFBOYSˉ_/ 2021年11月23日 01:31/ 0 赞/ 335 阅读

相关【RocketMQ】各组件概念介绍

【引言】关于RocketMQ的安装教程和Spring Boot的集成，在前面的两篇博客中做了相关总结。本篇博客主要总结RocketMQ中的相关组件，这也是了解其原理必须要知

超、凢脫俗/ 2021年10月19日 06:40/ 0 赞/ 433 阅读