RocketMQ 作為我們常用的消息隊(duì)列, 知識(shí)點(diǎn)還是相對(duì)于RabbitMQ比較多的, 所以我把整理好的md發(fā)到專欄方便在公網(wǎng)上快速查閱與使用...

消息發(fā)送

dependency

One to One

生產(chǎn)者

消費(fèi)者

One to Many

單生產(chǎn)者

?

多消費(fèi)者 ( 默認(rèn)模式: 負(fù)載均衡 )

開啟多實(shí)例運(yùn)行

多個(gè)消費(fèi)者爭搶topic數(shù)據(jù)

消費(fèi)者（廣播模式）

特殊消息類別

單向消息

延時(shí)消息

批量消息

??

消息過濾

tag過濾

生產(chǎn)者配置

消費(fèi)者配置

SQL過濾

生產(chǎn)者配置

消費(fèi)者配置

注意：SQL過濾需要依賴服務(wù)器的功能支持，在broker.conf配置文件中添加對(duì)應(yīng)的功能項(xiàng)，并開啟對(duì)應(yīng)功能

重啟broker

或者直接cmd中輸入

SpringBoot 整合

依賴

yml

Entity

Producer

DemoConsumer

BatchConsumer

DelayConsumer

SyncConsumer