rocketmq在我們專案中一般用於系統間的解耦，有時候會使用不同的consumer消費不同的tag，但是博主昨天踩了個坑。
情景如下：
兩個consumer接收相同的topic，不同tag的訊息，但是當處方系統傳送taga的訊息的時候，consumer2消費了，本來consumer2應該是要丟棄掉的，但是卻消費了，主要問題就是配置了相同的group。
rocketmq消費者如果針對同乙個topic不同的tag配置了相同的group，會導致訊息消費混亂。
解決方法：
針對不同的tag配置不同的group即可。
解決效果可以從監控平台看到如下：
乙個group過濾了訊息，乙個group消費了。
希望也能夠解決大家的問題。
rocketmq 自動建立topic原始碼分析
預設情況下，topic不用手動建立，當producer進行訊息傳送時，會從nameserver拉取topic的路由資訊，如果topic的路由資訊不存在，那麼會預設拉取broker啟動時預設建立好名為 tbw102 的topic。topic首次傳送訊息，此時並不能從namserver獲取topic的路...
RocketMQ通過命令列建立Topic
updatetopic命令很多人都知道，也在部落格上覆制貼上了官網的。但很多人沒有給出具體的簡單例子，對於初學者而言要的就是直觀的例子，可以拷貝下來改個數字直接使用的例子。文件大家都知道看，但很多人看了還是不知道具體怎麼去做。因為官網只是給乙個介紹。具體命令怎麼使用需要靠自己摸索。updatetop...
RocketMQ生產者組topic和消費組的關係
各個之間的關係其實很鬆散,並不是說不能操作 訂閱關係一致 多個 group id 訂閱了多個 topic，並且每個 group id 裡的多個消費者例項的訂閱關係保持了一致。消費冪等 最終一致性保證資料一致性,如果不冪等,將導致資料錯亂 topic和tag的關係 topic可以是一級過濾關係 tag...