以前都是聽說MQ，或者在別人搭建好的基礎(chǔ)上去使用，沒有自己動(dòng)手搭建過，就沒有更深入去理解。現(xiàn)在機(jī)會(huì)來啦.啦啦.啦啦啦......

引用自己的CSDN文章

href="https://blog.csdn.net/chenzhong2010/article/details/106699590

或點(diǎn)擊左下角“閱讀原文”來支持我...φ(0￣*)啦啦啦_φ(*￣0￣)>

一、安裝配置

1.1、下載
下載地址是http://rocketmq.apache.org/release_notes/release-notes-4.2.0/
打開后顯示如圖：

點(diǎn)擊上圖zip進(jìn)行下載。1.2、安裝下載完成后解壓該zip文件，并移動(dòng)到對(duì)應(yīng)的目錄下，如：

1.3、配置環(huán)境變量

右鍵“我的電腦”->“屬性”->“高級(jí)屬性”->“環(huán)境變量”，新增環(huán)境變量

ROCKETMQ_HOME

D:\04_work_installed\01_java_tools\34_Rocketmq_4_2_0\rocketmq-all-4.2.0-bin-release

二、啟動(dòng)NAMESERVER

打開cmd命令窗口，輸入命令：

start mqnamesrv.cmd

如上圖所述，說明環(huán)境變量是正確的，并且NAMESERVER啟動(dòng)成功，此框請(qǐng)不要關(guān)閉。

三、啟動(dòng)BROKER

另外打開一個(gè)cmd命令窗口，輸入命令：

start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true

后續(xù)查詢broker名稱是tiannanIT，名稱就是本地電腦名稱：

或者

啟動(dòng)帶有配置文件的，啟動(dòng)broker時(shí)需要加載配置文件，執(zhí)行命令：

start?mqbroker.cmd?-n?127.0.0.1:9876?autoCreateTopicEnable=true?-c?D:\04_work_installed\01_java_tools\34_Rocketmq_4_2_0\rocketmq-all-4.2.0-bin-release\conf\broker.conf

后續(xù)查詢broker名稱是broker-a，名稱就是broker.conf里面配置的：

配置文件broker.conf默認(rèn)內(nèi)容如：

brokerClusterName = DefaultClusterbrokerName = broker-abrokerId = 0deleteWhen = 04fileReservedTime = 48brokerRole = ASYNC_MASTERflushDiskType?=?ASYNC_FLUSH

cmd運(yùn)行brocker后：

奇怪，只是彈出了個(gè)框，卻沒有成功提示，不過這樣已經(jīng)是啟動(dòng)broker成功了，此框勿關(guān)閉。

【備注】如果光標(biāo)沒有閃爍，而是回到命令行，那意思就是brocker啟動(dòng)失敗，需要把c:/user/你的用戶名/store文件夾里面的所有文件全部刪除，再啟動(dòng)，成功。

四、查看連接到nameserver上的broker

mqadmin clusterList -n localhost:9876

五、下載RocketMQ插件(管理控制臺(tái))

通過git命令下載以下鏈接對(duì)應(yīng)的源碼

git clone https://gitee.com/mirrors/RocketMQ-Externals.git

進(jìn)入D:\04_work_installed\01_java_tools\34_Rocketmq_4_2_0\rocketmq-externals_git_resource\rocketmq-externals**rocketmq-console**目錄，清除并打包(如果有自己的maven私服，最好啟動(dòng))：

mvn clean package -Dmaven.test.skip=true

進(jìn)入到編譯包下cd D:\04_work_installed\01_java_tools\34_Rocketmq_4_2_0\rocketmq-externals_git_resource\rocketmq-externals\rocketmq-console\target\

執(zhí)行啟動(dòng)該jar：

java -jar rocketmq-console-ng-1.0.1.jar

應(yīng)用訪問：http://127.0.0.1:9980

六、創(chuàng)建主題topic

mqadmin updateTopic -n localhost:9876 -b localhost:10911 -t tx-mq-TOPIC

mqadmin updateTopic -c DefaultCluster -n localhost:9876 -t threezto-test -r 12 -w 12

顯示剛剛已經(jīng)創(chuàng)建的兩個(gè)topic：

然后可以查看一些自定義主題、系統(tǒng)主題等等：

七、控制臺(tái)創(chuàng)建主題

通過菜單：主題->新增/更新，就彈出框來填寫對(duì)應(yīng)的信息，并提交。

八、啟動(dòng)消費(fèi)者

打開cmd命令窗口，執(zhí)行以下命令：

set NAMESRV_ADDR=127.0.0.1:9876 tools.cmd org.apache.rocketmq.example.quickstart.Consumer

以上，消費(fèi)者啟動(dòng)成功。

九、啟動(dòng)生產(chǎn)者

打開cmd命令窗口，執(zhí)行以下命令：

set NAMESRV_ADDR=127.0.0.1:9876tools.cmd?org.apache.rocketmq.example.quickstart.Producer

使用topic是TopicTest。

這時(shí)候消費(fèi)者窗口正在消費(fèi)消息：

十、查看控制臺(tái)

查看消費(fèi)者：

查看集群：

查看主題TopicTest的各項(xiàng)信息：

狀態(tài)：

路由：

CONSUMER管理：

TOPIC配置：

查看消息：

可以查到，
Topic：TopicTest
Tag：TagA
consumerGroup：please_rename_unique_group_name_4

十一、其他命令

1)刪除主題

mqadmin?deleteTopic?-n?localhost:9876?-c?DefaultCluster?-t?zto-example

十二、數(shù)據(jù)文件配置

12.1 查看數(shù)據(jù)存儲(chǔ)
rocketmq的數(shù)據(jù)默認(rèn)都是存放到該目錄下

查詢屬性，發(fā)現(xiàn)文件實(shí)在太大了，想遷移該文件到其他地方，為c盤騰空間

打開broker.conf配置文件，增加以下配置(注意：需要使用 \\，\是無效的)：

#存儲(chǔ)路徑storePathRootDir=D:\\04_work_installed\\01_java_tools\\34_Rocketmq_4_2_0\\rocketmq-all-4.2.0-bin-release\\store#commitLog 存儲(chǔ)路徑storePathCommitLog=D:\\04_work_installed\\01_java_tools\\34_Rocketmq_4_2_0\\rocketmq-all-4.2.0-bin-release\\store\\commitlog#消費(fèi)隊(duì)列存儲(chǔ)路徑存儲(chǔ)路徑storePathConsumeQueue=D:\\04_work_installed\\01_java_tools\\34_Rocketmq_4_2_0\\rocketmq-all-4.2.0-bin-release\\store\\consumequeue#消息索引存儲(chǔ)路徑storePathIndex=D:\\04_work_installed\\01_java_tools\\34_Rocketmq_4_2_0\\rocketmq-all-4.2.0-bin-release\\store\\index#checkpoint 文件存儲(chǔ)路徑storeCheckpoint=D:\\04_work_installed\\01_java_tools\\34_Rocketmq_4_2_0\\rocketmq-all-4.2.0-bin-release\\store\\checkpoint#abort 文件存儲(chǔ)路徑abortFile=D:\\04_work_installed\\01_java_tools\\34_Rocketmq_4_2_0\\rocketmq-all-4.2.0-bin-release\\store\\abort

首先將C:\Users\tiannan\store里所有文件遷移出來(否則brocker運(yùn)行失敗)，然后重新運(yùn)行：

start?mqbroker.cmd?-n?127.0.0.1:9876?autoCreateTopicEnable=true?-c?D:\04_work_installed\01_java_tools\34_Rocketmq_4_2_0\rocketmq-all-4.2.0-bin-release\conf\broker.conf

運(yùn)行成功后，你會(huì)發(fā)現(xiàn)rocketmq安裝目錄下生成store文件夾，里面還有生成一些文件，如：

關(guān)閉broker后，再將之前的備份拷貝回來：

最好重新重啟broker，打開rocketmq控制臺(tái)，又可以看見之前生成的topic等信息了。

在上述配置的內(nèi)容來看，rocketmq的各端配置、以及消息都是存儲(chǔ)在store里面的，需要保護(hù)好該目錄數(shù)據(jù)。

12.2 查看日志存儲(chǔ)

默認(rèn)存儲(chǔ)在C:\Users\tiannan\logs\rocketmqlogs文件夾里面，這個(gè)日志文件夾以及里面的日志文件，是以下日志配置進(jìn)行配置的：

xml文件里面都是設(shè)置父目錄是 ${user.home}/logs/rocketmqlogs ，所以可以在對(duì)應(yīng)的xml文件里面修改日志存儲(chǔ)位置。

十三、修改mqnamesrv和mqbroker的jvm內(nèi)存

mqnamesrv.cmd -> runserver.cmd
打開runserver.cmd文件，找到以下內(nèi)容修改：

set "JAVA_OPT=%JAVA_OPT% -server -Xms2g -Xmx2g -Xmn1g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"##修改為set?"JAVA_OPT=%JAVA_OPT%?-server?-Xms512m?-Xmx512m?-Xmn256m?-XX:MetaspaceSize=128m?-XX:MaxMetaspaceSize=320m"

mqbroker.cmd -> runbroker.cmd打開runbroker.cmd文件，找到以下內(nèi)容修改：

set "JAVA_OPT=%JAVA_OPT% -server -Xms2g -Xmx2g -Xmn1g"##修改為set?"JAVA_OPT=%JAVA_OPT%?-server?-Xms512m?-Xmx512m?-Xmn256m"

或者修改成你需要的內(nèi)存大小即可。

挺簡(jiǎn)單的，對(duì)你來說，已經(jīng)學(xué)會(huì)了拉。?

關(guān)注我，下期繼續(xù)！！！

總結(jié)

以上是生活随笔為你收集整理的rocketmq 启动_016【windows版Rocketmq】小白学习Rocketmq单机部署的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。