Skip to content

Commit 86558e4

Browse files
authored
Update RocketMQ.md
1 parent 5854bb9 commit 86558e4

File tree

1 file changed

+2
-2
lines changed
  • docs/system-design/distributed-system/message-queue

1 file changed

+2
-2
lines changed

docs/system-design/distributed-system/message-queue/RocketMQ.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -190,7 +190,7 @@
190190

191191
你可以看到图中生产者组中的生产者会向主题发送消息,而 **主题中存在多个队列**,生产者每次生产消息之后是指定主题中的某个队列发送消息的。
192192

193-
每个主题中都有多个队列(这里还不涉及到 `Broker`),集群消费模式下,一个消费者集群多台机器共同消费一个 `topic` 的多个队列,**一个队列只会被一个消费者消费**。如果某个消费者挂掉,分组内其它消费者会接替挂掉的消费者继续消费。就像上图中 `Consumer1``Consumer2` 分别对应着两个队列,而 `Consuer3` 是没有队列对应的,所以一般来讲要控制 **消费者组中的消费者个数和主题中队列个数相同**
193+
每个主题中都有多个队列(分布在不同的 `Broker`中,如果是集群的话,`Broker`又分布在不同的服务器中),集群消费模式下,一个消费者集群多台机器共同消费一个 `topic` 的多个队列,**一个队列只会被一个消费者消费**。如果某个消费者挂掉,分组内其它消费者会接替挂掉的消费者继续消费。就像上图中 `Consumer1``Consumer2` 分别对应着两个队列,而 `Consuer3` 是没有队列对应的,所以一般来讲要控制 **消费者组中的消费者个数和主题中队列个数相同**
194194

195195
当然也可以消费者个数小于队列个数,只不过不太建议。如下图。
196196

@@ -451,4 +451,4 @@ emmm,是不是有一点复杂🤣,看英文图片和英文文档的时候就
451451

452452
等等。。。
453453

454-
> 如果喜欢可以点赞哟👍👍👍。
454+
> 如果喜欢可以点赞哟👍👍👍。

0 commit comments

Comments
 (0)