馬老師mybaTisplus實(shí)戰(zhàn)教程 馬老師sprIngboot
在 RocketMQ 中,可以通過使用 console 控制臺對死信隊(duì)列的消息進(jìn)行重發(fā)來使得消費(fèi)者實(shí)例再次進(jìn)行消費(fèi)
RocketMQ 消費(fèi)模式
RocketMQ 消息訂閱有兩種模式,一種是Push模式(MQPushConsumer),即MQServer主動(dòng)向消費(fèi)端推送;另外一種是Pull模式(MQPullConsumer),即消費(fèi)端在需要時(shí),主動(dòng)到MQ Server拉取。但在具體實(shí)現(xiàn)時(shí),Push和Pull模式本質(zhì)都是采用消費(fèi)端主動(dòng)拉取的方式,即 Consumer 輪詢從 Broker 拉取消息。
Push 模式
優(yōu)點(diǎn):就是實(shí)時(shí)性高。
標(biāo)簽: