RocketMq學習筆記之一【常用操作命令與簡單配置】
阿新 • • 發佈：2018-12-23
【為什麼使用RocketMq】
1、應用解耦
2、流量削峰
3、訊息分發
4、保證最終一致性
5、方便動態擴容
【RocketMq的角色】
producer
consumer
Broker
NameServer
broker配置檔案：
#nameServer 地址，分號分割 namesrvAddr=192.168.100.131:9876;192.168.100.132:9876 #所屬叢集的名字 brokerClusterName=RocketMq-Cluster #broker名字，Master和Slave通過使用相同的Broker名稱來表明相互關以說明某個Slave是哪個Master的Slave brokerName=broker-a #0表示master,>0表示slave brokerid=0 #刪除檔案時間點，預設是凌晨4點 deleteWhen=04 #檔案保留時間，預設48小時，自動刪除超時的訊息；commitLog每個檔案的大小預設1G fileReservedTime=48 #Broker 的角色 ASYNC_MASTER 非同步複製Master；SYNC_MASTER 同步雙寫Master brokerRole=SYNC_MASTER #刷盤方式ASYNC_FLUSH 非同步刷盤訊息寫入page_cache就返回成功狀態；SYNC_FLUSH 同步刷盤，訊息真正寫入磁碟再返回成功狀態 flushDiskType=ASYNC_FLUSH listenPort=10911 #日誌存放位置 storePathRootDir=/home/rocketmq/store-a #限制的訊息大小 maxMessageSize=65536 flushCommitLogLeastPages=4 flushConsumeQueueLeastPages=2 flushCommitLogThoroughInterval=10000 flushConsumeQueueThoroughInterval=60000
【建立topic】
# -b broker地址;-c Cluster名稱;-n nameserver地址列表；-t topic名稱
updateTopic -b 192.168.0.1:10911 -c RocketMq-Cluster -n 192.168.0.1:9876;192.168.0.2:9876 -t order-topic【刪除topic】
deleteTopic -c RocketMq-Cluster -n 192.168.0.1:9876;192.168.0.2:9876 -t order-topic【建立/修改訂閱組】
#訂閱組名稱
updateSubGroup -b 192.168.0.1:10911 -c RocketMq-Cluster -g subGroupName -n 192.168.0.1:9876;192.168.0.2:9876【刪除訂閱組】
deleteSubGroup -b 192.168.0.1:10911 -c RocketMq-Cluster -g subGroupName -n 192.168.0.1:9876;192.168.0.2:9876【更新broker配置】
#某些配置檔案broker執行的時候可以動態修改,-k broker配置檔案的key -v value updateBrokerConfig -b 192.168.0.1:10911 -c RocketMq-Cluster -n 192.168.0.1:9876;192.168.0.2:9876 -k deleteWhen -v 05
【更新topic的讀寫許可權】
updateTopicPerm -b 192.168.0.1:10911 -c RocketMq-Cluster -n 192.168.0.1:9876;192.168.0.2:9876 -t order-topic【查詢topic路由資訊】
TopicRoute -b 192.168.0.1:10911 -c RocketMq-Cluster -n 192.168.0.1:9876;192.168.0.2:9876 -t order-topic【檢視topic路由資訊】
TopicList -n 192.168.0.1:9876;192.168.0.2:9876【檢視topic狀態統計資訊】
TopicStats -t order_topic -n 192.168.0.1:9876;192.168.0.2:9876【根據時間查詢訊息】
printMsg -t order_topic -n 192.168.0.1:9876;192.168.0.2:9876【根據Id查詢訊息】
queryMsgById -i msgId -n -n 192.168.0.1:9876;192.168.0.2:9876【檢視叢集資訊】
clusterList -n 192.168.0.1:9876;192.168.0.2:9876【rocketmq圖形介面專案地址】
https://github.com/apache/rocketmq-externals/tree/master/rocketmq-console
#進入原始碼目錄
mvn spring-boot:run
http://localhost:8080/即可檢視