RocketMQ——Consumer消費模式

RocketMQ的Consumer有兩種消費模式,通過 consumer.setMessageModel(MessageModel.BROADCASTING) 和consumer.setMessageModel(MessageModel.CLUSTERING)設置 廣播模式 當使用廣播消費模式時,MQ 會將每條消息推送給集羣內所有訂閱該topic和tag的客戶端,保證消息至少被每臺機器消費一次。
相關文章
相關標籤/搜索