消息消費要注意的細節

@RocketMQMessageListener(consumerGroup = "shop",//消費者分組topic = "order-topic",//要消費的主題consumeMode = ConsumeMode.CONCURRENTLY, //消費模式:無序和有序messageModel = MessageModel.CLUSTERING, //消息模式:廣播和集群,默認是集群 ) public class SmsService implements RocketMQListener<Order> {}

RocketMQ支持兩種消息模式:

廣播消費: 每個消費者實例都會收到消息,也就是一條消息可以被每個消費者實例處理；

集群消費: 一條消息只能被一個消費者實例消費

?

總結

以上是生活随笔為你收集整理的消息消费要注意的细节的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。