RocketMQ 消費者默認是集群的方式消費的,消費者還可以用廣播的模式進行消費。
集群模式
當(dāng) Consumer 使用集群模式時,每條消息只會被 Consumer 集群內(nèi)的任意一個 Consumer 實例消費一次。
比如當(dāng)一個 Consumer 集群內(nèi)有 3 個 Consumer 實例時,一條消息到達時,只會被Consumer 1、Consumer 2、Consumer 3中的一個消費。
廣播模式
當(dāng) Consumer 使用廣播模式時,每條消息都會被 Consumer 集群內(nèi)所有的 Consumer 實例消費一次。
仍然用前面的例子,當(dāng)一個 Consumer 集群內(nèi)有 3 個 Consumer 實例時,一條消息到達時,會被Consumer 1、Consumer 2、Consumer 3 三個都消費一次。