一：順序發送 通過一定算法，將一組順序消息發送到同一個broker下面的同一個隊列，消費者進行順序監聽即可。 例如：一條信息的唯一標識 通過一定算法 路由到 同一個 broker 下到 某一個隊列下 ...

tag 的使用場景：不同的消費組，訂閱同一 topic 不同的 tag，拉取不同的消息並消費。在 topic 內部對消息進行隔離。 producer 發送消息，指定 tag cons ...

rocketMQ 為了保證 consumer 順序消費，做了很多工作。 MQClientManager 在 jvm 進程中是單例，其內部維護一個 map，鍵是 clientId，值是 MQClien ...

附加：如果有多個master，那么每個master配置的名字應該一樣，要不然識別不了對方，不知道是一個集群內部的 所屬集群名字：brokerClusterName=rocketmq-c ...

1:基礎知識梳理 Message對象 topic: 主題名稱 tag: 標簽，用於過濾 key: 消息唯一標示，可以是業務字段組合 body: 消息體,字節數組 注意 發送消息到 ...

命令行主類：org.apache.rocketmq.tools.command.MQAdminStartup 客戶端創建 topic 程序參數：updateTopic -n localhost:9 ...

1、導入依賴 2、配置生產者 3、發送消息Controller 4、客戶端 5、測試 注意：一定要創建to ...

rocketMQ 重置消息 offset，有兩種情形：一種是有消費者在線，另一種則是無消費者在線。 命令行 首先描述存在在線消費者的情況： 1. 命令行程序和 nameserver ...

問題 Rocketmq 重試是否有超時問題，假如超時了如何解決，是重新發送消息呢？還是一直等待 假如某個 msg 進入了重試隊列（%RETRY_XXX%），然后成功消費了 概述 ...

一、rocketMQ安裝 　　（一）安裝NameSrv 　　1、創建nameSrv數據掛載文件夾 　　2、拉取鏡像 　　3、運行NameSrv新容器 ...