update format

L-shuai · Sep 23, 2022 · 98da0aa · 98da0aa
1 parent d02da44
commit 98da0aa
Showing 1 changed file with 23 additions and 6 deletions.
diff --git a/src/main/java/com/other/middleware/MESSAGEQUEUE.md b/src/main/java/com/other/middleware/MESSAGEQUEUE.md
@@ -583,23 +583,23 @@ Kafka会将Partition以消息日志的方式(落磁盘)存储起来，通过 顺
 # RocketMQ
 
 ## 基本概念
-消息生产者(Producer)：负责生产消息，一般由业务系统负责生产消息。RocketMQ提供多种发送方式，同步发送、异步发送、顺序发送、单向发送。同步和异步方式均需要Broker返回确认信息，单向发送不需要。
+**消息生产者**(Producer)：负责生产消息，一般由业务系统负责生产消息。RocketMQ提供多种发送方式，同步发送、异步发送、顺序发送、单向发送。同步和异步方式均需要Broker返回确认信息，单向发送不需要。
 
-消息消费者(Consumer)：负责消费消息，一般是后台系统负责异步消费。
+**消息消费者**(Consumer)：负责消费消息，一般是后台系统负责异步消费。
   - 提供了两种消费形式：拉取式消费、推动式消费。
     - 拉取式消费：应用通常主动调用Consumer的拉消息方法从Broker服务器拉消息、主动权由应用控制。
     - 推动式消费：Broker收到数据后会主动推送给消费端，该消费模式一般实时性较高。
   - 提供两种消费模式：集群消费和广播消费
     - 集群消费模式下,相同Consumer Group的每个Consumer实例平均分摊消息。
     - 广播消费模式下，相同Consumer Group的每个Consumer实例都接收全量的消息。
 
-主题(Topic)：表示一类消息的集合，每个主题包含若干条消息，每条消息只能属于一个主题，是RocketMQ进行消息订阅的基本单位。
+**主题**(Topic)：表示一类消息的集合，每个主题包含若干条消息，每条消息只能属于一个主题，是RocketMQ进行消息订阅的基本单位。
 
-代理服务器(Broker Server)：消息中转角色，负责存储消息、转发消息。代理服务器在RocketMQ系统中负责接收从生产者发送来的消息并存储、同时为消费者的拉取请求作准备。代理服务器也**存储消息相关的元数据，包括消费者组、消费进度偏移和主题和队列消息**等
+**代理服务器**(Broker Server)：消息中转角色，负责存储消息、转发消息。代理服务器在RocketMQ系统中负责接收从生产者发送来的消息并存储、同时为消费者的拉取请求作准备。代理服务器也**存储消息相关的元数据，包括消费者组、消费进度偏移和主题和队列消息**等
 
-名字服务(Name Server)：名称服务充当路由消息的提供者。生产者或消费者能够通过名字服务查找各主题相应的Broker IP列表。多个Namesrv实例组成集群，但相互独立，没有信息交换。
+**名字服务**(Name Server)：名称服务充当路由消息的提供者。生产者或消费者能够通过名字服务查找各主题相应的Broker IP列表。多个Namesrv实例组成集群，但相互独立，没有信息交换。
 
-生产者组(Producer Group)：同一类Producer的集合，这类Producer发送同一类消息且发送逻辑一致。如果发送的是事务消息且原始生产者在发送之后崩溃，则Broker服务器会联系同一生产者组的其他生产者实例以提交或回溯消费。
+**生产者组**(Producer Group)：同一类Producer的集合，这类Producer发送同一类消息且发送逻辑一致。如果发送的是事务消息且原始生产者在发送之后崩溃，则Broker服务器会联系同一生产者组的其他生产者实例以提交或回溯消费。
 
 消费者组(Consumer Group)：同一类Consumer的集合，这类Consumer通常消费同一类消息且消费逻辑一致。消费者组使得在消息消费方面，实现负载均衡和容错的目标变得非常容易。要注意的是，消费者组的消费者实例必须订阅完全相同的Topic。RocketMQ 支持两种消息模式：集群消费和广播消费。
 - 标签(Tag)：为消息设置的标志，用于同一主题下区分不同类型的消息。来自同一业务单元的消息，可以根据不同业务目的在同一主题下设置不同标签。标签能够有效地保持代码的清晰度和连贯性，并优化RocketMQ提供的查询系统。
@@ -637,3 +637,20 @@ RocketMQ采用了2PC的思想来实现了提交事务消息，同时增加一个
 其中，补偿阶段用于解决消息Commit或者Rollback发生超时或者失败的情况。
 
 # RabbitMQ
+
+RabbitMQ是一个开源的消息代理和队列服务器，用来通过普通协议在不同的应用之间共享数据(跨平台跨语言)。RabbitMQ是使用Erlang语言编写，并且基于AMQP协议实现。
+
+## 基本概念
+
+![avatar](https://raw.githubusercontent.com/rbmonster/file-storage/main/learning-note/other/rabbitmq.png)
+
+1. Channel（信道）：多路复用连接中的一条独立的双向数据流通道。信道是建立在真实的TCP连接内的虚拟连接，复用TCP连接的通道。
+2. Producer（消息的生产者）：向消息队列发布消息的客户端应用程序。
+3. Consumer（消息的消费者）：从消息队列取得消息的客户端应用程序。
+4. Message（消息）：消息由消息头和消息体组成。消息体是不透明的，而消息头则由一系列的可选属性组成，这些属性包括routing-key（路由键）、priority（消息优先权）、delivery-mode（是否持久性存储）等。
+5. Routing Key（路由键）：消息头的一个属性，用于标记消息的路由规则，决定了交换机的转发路径。最大长度255 字节。
+6. Queue（消息队列）：存储消息的一种数据结构，用来保存消息，直到消息发送给消费者。它是消息的容器，也是消息的终点。一个消息可投入一个或多个队列。消息一直在队列里面，等待消费者连接到这个队列将消息取走。需要注意，当多个消费者订阅同一个Queue，这时Queue中的消息会被平均分摊给多个消费者进行处理，而不是每个消费者都收到所有的消息并处理，每一条消息只能被一个订阅者接收。
+7. Exchange（交换器|路由器）：提供Producer到Queue之间的匹配，接收生产者发送的消息并将这些消息按照路由规则转发到消息队列。交换器用于转发消息，它不会存储消息 ，如果没有 Queue绑定到 Exchange 的话，它会直接丢弃掉 Producer 发送过来的消息。交换器有四种消息调度策略（下面会介绍），分别是fanout, direct, topic, headers。
+8. Binding（绑定）：用于建立Exchange和Queue之间的关联。一个绑定就是基于Binding Key将Exchange和Queue连接起来的路由规则，所以可以将交换器理解成一个由Binding构成的路由表。
+9. Binding Key（绑定键）：Exchange与Queue的绑定关系，用于匹配Routing Key。最大长度255 字节。
+10. Broker：RabbitMQ Server，服务器实体。