RocketMQ（05）——消息的群集消费和广播消费
Posted elim168
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了RocketMQ（05）——消息的群集消费和广播消费相关的知识，希望对你有一定的参考价值。
消息的群集消费和广播消费
RocketMQ的消费者进行消息消费时有两种消费方式，群集消费和广播消费。默认是群集消费。
群集消费
Consumer都有一个Group，当两个Consumer实例属于同一个Group时，它们会共享消息队列中的消息消费位移，即同一条消息只会由一个消费者实例消费。实际上一个队列只会分配给一个消费者实例，那么属于该队列中的消息就只能被一个消费者实例消费了。当一个消费者实例挂了后，会重新为消费者实例分配队列，这样原本分配给挂了的那个实例的队列中又会分配给其它消费者进行消费。RocketMQ限制了同一个JVM中不允许有相同Group名称的Consumer实例存在，所以同一Group的多个Consumer往往是部署在不同机器上的，通常是同一程序部署了多份。假设现在有名为group1的Consumer在Machine1上部署了一份，在Machine2上部署了一份，它们订阅的消息队列中有消息1-10共10条消息，那么可能1-5条消息由Machine1上的消费者消费，6-10条消息由Machine2上的消费者消费。如果在Machine1上还部署了一个名为group2的消费者，则该消费者可以从消息队列中消费1-10条消息，因为它跟group1是不同的Group，不同Group的消费者对同一队列的消费是完全独立的。比如下面的代码对应的就是群集消费。
@Test
public void testConsumer以上是关于RocketMQ（05）——消息的群集消费和广播消费的主要内容，如果未能解决你的问题，请参考以下文章