RocketMQ核心构件对应关系

topic2

msg3

queue1

queue0

producer-topic-queue

producer2

producer1

con-group-a

msg1

consumer3

对应关系producer:topic=1:ntopic:producer=1:nproducer:consumer=n:ntopic:consumer=1:nconsumer:topic=1:1message:topic=1:1topic:message=1:n说明：其中n>=1

msg2

topic3

topic

queue3

con-a0

msg6

对应关系1、一个消费者组只能消费一个tipic，但一个topic可以被多个消费者组消费；2、一个消费者组的同一个消费者，可以消费多个队列；3、一个topic的同一个queue可以被多个消费者组消费，但同一个queue只能被同一个组的一个消费者消费。4、消费者数量应该小于等于topic中队列的数量，如果大于，多余的消费者不会有消息进行消费topic : queue : group = 1 : n ：m，其中 n >= m >=1

producer-topic-consumer

topic6

producer

consumer2

topic1

con-a1

topic-queue-consume(group)

msg0

queue2

con-group-b

consumer1

consumer6

con-b0