當前位置：首頁 > 运维知识 > windows >内容正文

windows

rocketmq安装，内存配置，各种命令说明，windows下安装，控制台工具

發布時間：2024/9/27 windows 33 豆豆

生活随笔收集整理的這篇文章主要介紹了 rocketmq安装，内存配置，各种命令说明，windows下安装，控制台工具小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

1修改內存大小

以下只是設置實例：

cd /home/bigdata/installed/rocketmq-all-4.2.0 （140機器） vim bin/runserver.sh　（調整nameserver啟動的內存，不調整此文件，可能導致無法啟動。） JAVA_OPT="${JAVA_OPT} -server -Xms4g -Xmx4g -Xmn2g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"vim bin/runbroker.sh JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx1024m -Xmn128m"

2關閉防火墻

systemctl stop iptables systemctl stop firewalld.service

3啟動nameserver

nohup sh bin/mqnamesrv & tail -f ~/logs/rocketmqlogs/namesrv.log

4啟動broker

nohup sh bin/mqbroker -n xxx.xxx.18.140:9876 autoCreateTopicEnable=true & tail -f ~/logs/rocketmqlogs/broker.log

5生產和消費者案例

export NAMESRV_ADDR=bigdata1:9876 sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

6停止nameserver和broker

#關閉namesrv,broker sh bin/mqshutdown broker sh bin/mqshutdown namesrv

6.1 停止rocketmq

可以使用kill -9 命令強制停止rocketmq進程

6.2. 刪除rocketmq日志

rm -rf /root/logs/rocketmqlogs/*

6.3. 刪除rocketmq中topic等信息

rm -rf /root/store/*

6.4. [可選] 手工清空MQ里剩余的topic，示例命令如下：

cd alibaba-rocketmq/binsh mqadmin topicList -n xxx.xxx.1.167:9876sh mqadmin deleteTopic -c HOSTNAME -n xxx.xxx.1.167:9876 -t orderTopic

6.5. 重新啟動rocketmq，示例命令如下：

cd alibaba-rocketmq/binnohup sh mqnamesrv -n xxx.xxx.1.167:9876 > /dev/null 2>&1 &nohup sh mqbroker -n xxx.xxx.1.167:9876 > /dev/null 2>&1 &

PS:

順序必須是先停止rocketmq,再清空數據；如果順序錯誤，可能會導致消息無法正常清除、rocketmq無法啟動等問題

刪除Topic不是必須的，但是刪除的時候需要指定 -c，可以用服務器的hostname試試

7命令方式創建Topic

#查看添加topic的幫助文檔 bin/mqadmin updateTopic -h bin/mqadmin updateTopic -b bigdata1:10911 -n bigdata1:9876 -t TopicTestA -p 6 -w 16 -r 16

8控制臺使用

RocketMQ提供有控制臺及一系列控制臺命令，用于管理員對主題，集群，broker等信息的管理；
l 登錄控制臺：
首先進入RocketMQ工程，進入/RocketMQ/bin
在該目錄下有個mqadmin腳本
l 查看幫助：
在mqadmin下可以查看有哪些命令

sh mqadmin updateTopic Update or create topic deleteTopic Delete topic from broker and NameServer. updateSubGroup Update or create subscription group deleteSubGroup Delete subscription group from broker. updateBrokerConfig Update broker's config updateTopicPerm Update topic perm topicRoute Examine topic route info topicStatus Examine topic Status info topicClusterList get cluster info for topic brokerStatus Fetch broker runtime status data queryMsgById Query Message by Id queryMsgByKey Query Message by Key queryMsgByUniqueKey Query Message by Unique key queryMsgByOffset Query Message by offset printMsg Print Message Detail printMsgByQueue Print Message Detail sendMsgStatus send msg to broker. brokerConsumeStats Fetch broker consume stats data producerConnection Query producer's socket connection and client version consumerConnection Query consumer's socket connection, client version and subscription consumerProgress Query consumers's progress, speed consumerStatus Query consumer's internal data structure cloneGroupOffset clone offset from other group. clusterList List all of clusters topicList Fetch all topic list from name server updateKvConfig Create or update KV config. deleteKvConfig Delete KV config. wipeWritePerm Wipe write perm of broker in all name server resetOffsetByTime Reset consumer offset by timestamp(without client restart). updateOrderConf Create or update or delete order conf cleanExpiredCQ Clean expired ConsumeQueue on broker. cleanUnusedTopic Clean unused topic on broker. startMonitoring Start Monitoring statsAll Topic and Consumer tps stats allocateMQ Allocate MQ checkMsgSendRT check message send response time clusterRT List All clusters Message Send RT getNamesrvConfig Get configs of name server. updateNamesrvConfig Update configs of name server. getBrokerConfig Get broker config by cluster or special broker! queryCq Query cq command. sendMessage Send a message consumeMessage Consume message

l 查看具體命令的使用

sh mqadmin help 命令名稱

例如，查看updateTopic的使用

sh mqadmin help updateTopic

9 詳細命令

9.1. 創建Topic (updateTopic)

指令: updateTopic 類路徑 com.alibaba.rocketmq.tools.command.topic.UpdateTopicSubCommand

參數是否必填說明

-b	如果 -c為空，則必填	broker地址，表示topic建在該broker
-c	如果 -b為空，則必填	cluster名稱，表示topic建在該集群（集群可通過clusterList查詢）
-h	否	打印幫助
-n	是	nameserve服務地址列表，格式ip:port;ip:port;…
-p	否	指定新topic的權限限制( W
-r	否	可讀隊列數（默認為8）
-w	否	可寫隊列數（默認為8）
-t	是	topic名稱（名稱只能使用字符）

舉例在集群DefaultCluster上創建主題ZTEExample，nameserve地址為10.45.47.168:9876

sh mqadmin updateTopic –n 10.45.47.168 –c DefaultCluster –t ZTEExample

9.2. 刪除Topic(deleteTopic)

指令 deleteTopic 類路徑 com.alibaba.rocketmq.tools.command.topic.DeleteTopicSubCommand

參數是否必填說明

-c	是	cluster名稱，表示刪除某集群下的某個topic （集群可通過clusterList查詢）
-h	否	打印幫助
-n	是	nameserve服務地址列表，格式ip:port;ip:port;…
-t	是	topic名稱（名稱只能使用字符）

舉例在集群DefaultCluster上刪除主題ZTEExample，nameserve地址為10.45.47.168:9876

sh mqadmin deleteTopic –n 10.45.47.168:9876 –c DefaultCluster –t ZTEExample

9.3. 創建（修訂）訂閱組(updateSubGroup)

指令 updateSubGroup 類路徑 com.alibaba.rocketmq.tools.command.consumer.UpdateSubGroupSubCommand

參數是否必填說明

-b	如果 –c為空，則必填	broker地址，表示訂閱組建在該broker
-c	如果 –b為空，則必填	cluster名稱，表示topic建在該集群（集群可通過clusterList查詢）
-d	否	是否容許廣播方式消費
-g	是	訂閱組名
-i	否	從哪個broker開始消費
-m	否	是否容許從隊列的最小位置開始消費，默認會設置為false
-q	否	消費失敗的消息放到一個重試隊列，每個訂閱組配置幾個重試隊列
-r	否	重試消費最大次數，超過則投遞到死信隊列，不再投遞，并報警
-s	否	消費功能是否開啟
-w	否	發現消息堆積后，將Consumer的消費請求重定向到另外一臺Slave機器
-h	否	打印幫助
-n	是	nameserve服務地址列表，格式ip:port;ip:port;…

舉例

9.4. 刪除訂閱組配置(deleteSubGroup)

指令 deleteSubGroup 類路徑 com.alibaba.rocketmq.tools.command.consumer.DeleteSubscriptionGroupCommand

參數是否必填說明

-b	如果 –c為空，則必填	broker地址，表示訂閱組建在該broker
-c	如果 –b為空，則必填	cluster名稱，表示topic建在該集群（集群可通過clusterList查詢）
-g	是	訂閱組名
-h	否	打印幫助
-n	是	nameserve服務地址列表，格式ip:port;ip:port;…

舉例

9.5. 更新Broker配置文件(updateBrokerConfig)

指令 updateBrokerConfig 類路徑 com.alibaba.rocketmq.tools.command.broker.UpdateBrokerConfigSubCommand

參數是否必填說明

-b	如果 –c為空，則必填	broker地址，表示訂閱組建在該broker
-c	如果 –b為空，則必填	cluster名稱，表示topic建在該集群（集群可通過clusterList查詢）
-k	是	key值
-v	否	value值
-h	否	打印幫助
-n	是	nameserve服務地址列表，格式ip:port;ip:port;…

舉例

9.6. 查看Topic列表信息(topicList)

指令 topicList 類路徑 com.alibaba.rocketmq.tools.command.broker.UpdateBrokerConfigSubCommand

參數是否必填說明

-h	否	打印幫助
-n	是	nameserve服務地址列表，格式ip:port;ip:port;…

舉例 nameserve地址為10.45.47.168:9876

sh mqadmin topicList –n 10.45.47.168:9876

打印內容：
BenchmarkTest
%RETRY%simple-consumer-test
SELF_TEST_TOPIC
ZTEExample
注釋：上述頭三個主題是RocketMQ默認預先創建

9.7. 查看Topic路由信息(topicRoute)

指令 topicRoute 類路徑 com.alibaba.rocketmq.tools.command.topic.TopicRouteSubCommand

參數是否必填說明

-t	是	topic名稱
-h	否	打印幫助
-n	是	nameserve服務地址列表，格式ip:port;ip:port;…

舉例查看主題ZTEExample的路由，nameserve地址為10.45.47.168:9876

sh mqadmin topicRoute –n 10.45.47.168:9876 –t ZTEExample_Crm

打印內容：

{"brokerDatas":[{"brokerAddrs":{0:"10.45.47.168:10911"},"brokerName":"crmdb"}],"queueDatas":[{"brokerName":"crmdb","perm":6,"readQueueNums":8,"writeQueueNums":8}] }

9.8. 查看Topic統計信息(topicStats)

指令 topicStats 類路徑 com.alibaba.rocketmq.tools.command.topic.TopicStatsSubCommand

參數是否必填說明

-t	是	topic名稱
-h	否	打印幫助
-n	是	nameserve服務地址列表，格式ip:port;ip:port;…

舉例查看主題ZTEExample的統計信息，nameserve地址為10.45.47.168:9876

sh mqadmin topicStats –n 10.45.47.168:9876 –t ZTEExample

打印內容：（統計信息里包括有offset、最后更新時間）

#Broker Name #QID #Min Offset #Max Offset #Last Updated crmdb 0 0 1 2014-02-10 11:37:44,977 crmdb 1 0 0 crmdb 2 0 0 crmdb 3 0 0 crmdb 4 0 0 crmdb 5 0 0 crmdb 6 0 0 crmdb 7 0 0

9.9. 查看Broker統計信息(brokerStats)

指令 brokerStats 類路徑 com.alibaba.rocketmq.tools.command.broker.BrokerStatsSubCommand

參數是否必填說明

-b	是	broker地址
-h	否	打印幫助
-n	是	nameserve服務地址列表，格式ip:port;ip:port;…

舉例查看broker(crmdb)的統計信息，broker地址為10.45.47.168:10911,nameserve地址為10.45.47.168:9876

sh mqadmin brokerStats –n 10.45.47.168:9876 –b 10.45.47.168:10911

打印內容：

bootTimestamp : 1392003367470 brokerVersion : 29 brokerVersionDesc : V3_0_7 commitLogDiskRatio : 0.32690830974763857 commitLogMaxOffset : 217 commitLogMinOffset : 0 consumeQueueDiskRatio : 0.32690830974763857 dispatchMaxBuffer : 1 getFoundTps : 0.0 0.0 0.0 getMessageEntireTimeMax : 4 getMissTps : 0.0 0.0 0.0 getTotalTps : 0.0 0.0 0.0 getTransferedTps : 0.0 0.0 0.0 msgGetTotalTodayMorning : 0 msgGetTotalTodayNow : 1 msgGetTotalYesterdayMorning : 0 msgPutTotalTodayMorning : 0 msgPutTotalTodayNow : 1 msgPutTotalYesterdayMorning : 0 putMessageAverageSize : 217.0 putMessageDistributeTime :0(0.0%)1(100.0%)0(0.0%)0(0.0%)0(0.0%)0(0.0%)0(0.0%) putMessageEntireTimeMax : 6 putMessageSizeTotal : 217 putMessageTimesTotal : 1 putTps : 0.0 0.0 0.0 runtime : [ 0 days, 3 hours, 21 minutes, 1 seconds ] sendThreadPoolQueueCapacity : 100000 sendThreadPoolQueueSize : 0

9.10. 根據消息ID查詢消息(queryMsgById)

指令 queryMsgById 類路徑 com.alibaba.rocketmq.tools.command.message.QueryMsgByIdSubCommand

參數是否必填說明

-i	是	msgId
-h	否	打印幫助
-n	是	nameserve服務地址列表，格式ip:port;ip:port;…

舉例查詢msgId= 0A2D2FA800002A9F0000000000000000的消息，nameserve地址為10.45.47.168:9876

sh mqadmin queryMsgById –n 10.45.47.168:9876 –i 0A2D2FA800002A9F0000000000000000

打印內容:

Topic: ZTEExample Tags: [SimpleTest] Keys: [SimpleTest-1] Queue ID: 0 Queue Offset: 0 CommitLog Offset: 0 Born Timestamp: 2014-02-26 14:49:10,875 Store Timestamp: 2014-02-26 14:48:44,840 Born Host: 10.45.46.229:4231 Store Host: 10.45.47.168:10911 System Flag: 0 Properties: {TAGS=SimpleTest, KEYS=SimpleTest-1, WAIT=true} Message Body Path: /tmp/rocketmq/msgbodys/0A2D2FA800002A9F0000000000000000

9.11. 根據消息Key查詢消息(queryMsgByKey)

指令 queryMsgByKey 類路徑 com.alibaba.rocketmq.tools.command.message.QueryMsgByKeySubCommand

參數是否必填說明

-f	否	被查詢消息的截止時間
-k	是	msgKey
-t	是	Topic名稱
-h	否	打印幫助
-n	是	nameserve服務地址列表，格式ip:port;ip:port;…

舉例查詢Topic= ZTEExample下key= SimpleTest-1的消息，nameserve地址為10.45.47.168:9876

sh mqadmin queryMsgByKey -n 10.45.47.168:9876 -t ZTEExample -k SimpleTest-1

打印內容:

#Message ID #QID #Offset 0A2D2FA800002A9F0000000000000000 0 0

9.12. 根據Offset查詢消息(queryMsgByKey)

指令 queryMsgByOffset 類路徑 com.alibaba.rocketmq.tools.command.message.QueryMsgByOffsetSubCommand

參數是否必填說明

-b	是	Broker名稱，表示訂閱組建在該broker（這里需要注意填寫的是broker的名稱，不是broker的地址，broker名稱可以在clusterList查到）
-i	是	query隊列id
-o	是	offset值
-t	是	topic名稱
-h	否	打印幫助
-n	是	nameserve服務地址列表，格式ip:port;ip:port;…

舉例查詢brokerName=crm-168，Topic= ZTEExample的第1個隊列下offset=0的消息，nameserve地址為10.45.47.168:9876

sh mqadmin queryMsgByOffset -n 10.45.47.168:9876 -b crm-168 -i 0 -t ZTEExample -o 0

打印內容:

9.13. 查詢Producer的網絡連接(producerConnection)

l 該命令只打印當前與cluster連接的producer網絡連接信息
指令 producerConnection 類路徑 com.alibaba.rocketmq.tools.command.connection.ProducerConnectionSubCommand

參數是否必填說明

-g	是	生產者所屬組名
-t	是	topic名稱
-h	否	打印幫助
-n	是	nameserve服務地址列表，格式ip:port;ip:port;…

舉例查詢當前屬于group（生產者組）=simple-producer-test的生產者到topic=ZTEExample的網絡連接，nameserve地址為10.45.47.168:9876

sh mqadmin producerConnection -n 10.45.47.168:9876 -g simple-producer-test -t ZTEExample

打印內容:
0001 10.45.46.229@simple-producer-test-99f09de2a20a4b6284bb949b452bee0c 10.45.46.229:4332 JAVA V3_0_7

9.14. 查詢Consumer的網絡連接(consumerConnection)

l 該命令只打印當前與cluster連接的consumer網絡連接信息
指令 consumerConnection 類路徑 com.alibaba.rocketmq.tools.command.connection.ConsumerConnectionSubCommand

參數是否必填說明

-g	是	消費者所屬組名
-h	否	打印幫助
-n	是	nameserve服務地址列表，格式ip:port;ip:port;…

舉例查詢當前屬于group（消費者組）=simple-consumer-test的消費者的網絡連接，nameserve地址為10.45.47.168:9876

sh mqadmin consumerConnection -n 10.45.47.168:9876 -g simple-consumer-test

打印內容:

001 10.45.46.229@simple-consumer-test-7babbb6021b040d29978494b16d559ae 10.45.46.229:4355 JAVA V3_0_7Below is subscription: 001 Topic: ZTEExample SubExpression: *ConsumeType: CONSUME_ACTIVELY MessageModel: CLUSTERING ConsumeFromWhere: CONSUME_FROM_LAST_OFFSET

9.15. 查看訂閱組消費狀態(consumerProgress)

指令 consumerProgress 類路徑 com.alibaba.rocketmq.tools.command.consumer.ConsumerProgressSubCommand

參數是否必填說明

-g	是	消費者所屬組名
-h	否	打印幫助
-n	是	nameserve服務地址列表，格式ip:port;ip:port;…

舉例查詢當前屬于group（消費者組）=simple-consumer-test的訂閱狀態，nameserve地址為10.45.47.168:9876

sh mqadmin consumerProgress -n 10.45.47.168:9876 -g simple-consumer-test

打印內容:

#Topic #Broker Name #QID #Broker Offset #Consumer Offset #Diff ZTEExample crm-168 0 2 2 0 ZTEExample crm-168 1 0 0 0 ZTEExample crm-168 2 0 0 0 ZTEExample crm-168 3 0 0 0 ZTEExample crm-168 4 0 0 0 ZTEExample crm-168 5 0 0 0 ZTEExample crm-168 6 0 0 0 ZTEExample crm-168 7 0 0 0Consume TPS: 0 Diff Total: 0

9.16.查看集群消息(clusterList)

指令 clusterList 類路徑 com.alibaba.rocketmq.tools.command.cluster.ClusterListSubCommand

參數是否必填說明

-m	否	打印更多信息 (增加打印出如下信息 #InTotalYest, #OutTotalYest, #InTotalToday ,#OutTotalToday)
-h	否	打印幫助
-n	是	nameserve服務地址列表，格式ip:port;ip:port;…

舉例查詢當前集群狀態，nameserve地址為10.45.47.168:9876

sh mqadmin clusterList -n 10.45.47.168:9876

打印內容:

#Cluster Name #Broker Name #BID #Addr #Version #InTPS #OutTPS CRM crm-168 0 10.45.47.168:10911 V3_0_7 0.00 0.00 CRM crm-181 0 10.45.47.181:10911 V3_0_7 0.00 0.00sh mqadmin clusterList -n 10.45.47.168:9876 –m #Cluster Name #Broker Name #InTotalYest #OutTotalYest #InTotalToday #OutTotalToday CRM crm-168 0 0 2 3 CRM crm-181 0 0 0 0

9.17.添加（更新）KV配置信息(updateKvConfig)

指令 updateKvConfig 類路徑 com.alibaba.rocketmq.tools.command.namesrv.UpdateKvConfigCommand

參數是否必填說明

-k	是	key值
-v	是	value值
-s	是	Namespace值
-h	否	打印幫助
-n	是	nameserve服務地址列表，格式ip:port;ip:port;…

舉例

9.18. 刪除KV配置信息(deleteKvConfig)

指令 deleteKvConfig 類路徑 com.alibaba.rocketmq.tools.command.namesrv.DeleteKvConfigCommand

參數是否必填說明

-k	是	key值
-s	是	Namespace值
-h	否	打印幫助
-n	是	nameserve服務地址列表，格式ip:port;ip:port;…

舉例

9.19. 添加（更新）Project group配置信息(updateProjectGroup)

指令 updateProjectGroup 類路徑 com.alibaba.rocketmq.tools.command.namesrv.UpdateProjectGroupCommand

參數是否必填說明

-i	是	服務器ip
-p	是	project group名
-h	否	打印幫助
-n	是	nameserve服務地址列表，格式ip:port;ip:port;…

舉例

9.20. 刪除Projectgroup配置信息(deleteProjectGroup)

指令 deleteProjectGroup 類路徑 com.alibaba.rocketmq.tools.command.namesrv.DeleteProjectGroupCommand

參數是否必填說明

-i	是	服務器ip
-p	是	project group名
-h	否	打印幫助
-n	是	nameserve服務地址列表，格式ip:port;ip:port;…

舉例

9.21. 取得Projectgroup配置信息(getProjectGroup)

指令 getProjectGroup 類路徑 com.alibaba.rocketmq.tools.command.namesrv.GetProjectGroupCommand

參數是否必填說明

-i	是	服務器ip
-p	是	project group名
-h	否	打印幫助
-n	是	nameserve服務地址列表，格式ip:port;ip:port;…

舉例

9.22. 設置消費進度(resetOffsetByTime)

l 根據時間來設置消費進度，設置之前要關閉這個訂閱組的所有consumer，設置完再啟動，方可生效
指令 resetOffsetByTime 類路徑 com.alibaba.rocketmq.tools.command.offset.ResetOffsetByTimeSubCommand

參數是否必填說明

-f	否	通過時間戳強制回滾（true
-s	是	時間戳（currentTimeMillis
-g	是	消費者所屬組名
-t	是	topic名稱
-h	否	打印幫助
-n	是	nameserve服務地址列表，格式ip:port;ip:port;…

舉例

9.23. 清除特定Broker權限(wipeWritePerm)

指令 wipeWritePerm 類路徑 com.alibaba.rocketmq.tools.command.namesrv.WipeWritePermSubCommand

參數是否必填說明

-b	是	broker地址
-h	否	打印幫助
-n	是	nameserve服務地址列表，格式ip:port;ip:port;…

舉例

9.24. 獲取Consumer消費進度(getConsumerStatus)

l 該命令只打印當前與cluster連接的consumer的消費進度
指令 getConsumerStatus 類路徑 com.alibaba.rocketmq.tools.command.offset.GetConsumerStatusCommand

參數是否必填說明

-g	是	消費者所屬組名
-t	是	查詢主題
-i	否	Consumer客戶端ip
-h	否	打印幫助
-n	是	nameserve服務地址列表，格式ip:port;ip:port;…

舉例查詢屬于group（消費者組）=simple-consumer-test的消費者在Topic=ZTEExample上的消費狀態，nameserve地址為10.45.47.168:9876

sh mqadmin getConsumerStatus -n 10.45.47.168:9876 -g simple-consumer-test -t ZTEExample get consumer status from client. group=simple-consumer-test, topic=ZTEExample, originClientId= #clientId #brokerName #queueId #offset 10.45.46.229@simple-consumer-test-3f89fb692e874640 crm-168 4 0 10.45.46.229@simple-consumer-test-3f89fb692e874640 crm-168 0 2 10.45.46.229@simple-consumer-test-3f89fb692e874640 crm-168 3 0 10.45.46.229@simple-consumer-test-3f89fb692e874640 crm-168 1 0 10.45.46.229@simple-consumer-test-3f89fb692e874640 crm-168 5 0 10.45.46.229@simple-consumer-test-3f89fb692e874640 crm-168 6 0 10.45.46.229@simple-consumer-test-3f89fb692e874640 crm-168 7 0 10.45.46.229@simple-consumer-test-3f89fb692e874640 crm-168 2 0

10Rocketmq原理&最佳實踐

https://www.jianshu.com/p/2838890f3284

11 Rocketmq windows下安裝過程

一.預備環境
1.系統
Windows
2. 環境
JDK1.8、Maven、Git
二. RocketMQ部署
1.下載
1.1地址：http://rocketmq.apache.org/release_notes/release-notes-4.2.0/
1.2選擇‘Binary’進行下載
1.3解壓已下載工程

2. 配置
2.1 系統環境變量配置
變量名：ROCKETMQ_HOME
變量值：MQ解壓路徑\MQ文件夾名

2.2重啟服務器
3. 啟動
3.1 啟動NAMESERVER
Cmd命令框執行進入至‘MQ文件夾\bin’下，然后執行‘start mqnamesrv.cmd’，啟動NAMESERVER。成功后會彈出提示框，此框勿關閉。

3.2 啟動BROKER
Cmd命令框執行進入至‘MQ文件夾\bin’下，然后執行‘start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true’，啟動BROKER。成功后會彈出提示框，此框勿關閉。

假如彈出提示框提示‘錯誤: 找不到或無法加載主類 xxxxxx’。打開runbroker.cmd，然后將‘%CLASSPATH%’加上英文雙引號。保存并重新執行start語句。

三. RocketMQ插件部署

下載
地址：https://github.com/apache/rocketmq-externals.git

下載完成之后，進入‘rocketmq-externals\rocketmq-console\src\main\resources’文件夾，打開‘application.properties’進行配置。

2. 編譯啟動
進入‘\rocketmq-externals\rocketmq-console’文件夾，執行‘mvn clean package -Dmaven.test.skip=true’，編譯生成。
編譯成功之后，Cmd進入‘target’文件夾，執行‘java -jar rocketmq-console-ng-1.0.0.jar’，啟動‘rocketmq-console-ng-1.0.0.jar’。

3.測試
瀏覽器中輸入‘127.0.0.1：配置端口’，成功后即可查看。

總結

以上是生活随笔為你收集整理的rocketmq安装，内存配置，各种命令说明，windows下安装，控制台工具的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。

上一篇：我国制造的92式枪？
下一篇： 45.JVM调优策略、常见问题：内存泄漏