rocketmq 啟動_016【windows版Rocketmq】小白學習Rocketmq單機部署

以前都是聽說MQ，或者在別人搭建好的基礎上去使用，沒有自己動手搭建過，就沒有更深入去理解。現在機會來啦.啦啦.啦啦啦......

234d6e9913bdbe0aa254bf0be17e638e.png

引用自己的CSDN文章

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

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

一、安裝配置

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

02190d8d5b7c2ea6cba2d6cf30e02752.png

點擊上圖zip進行下載。1.2、安裝下載完成后解壓該zip文件，并移動到對應的目錄下，如：

cad1fcc0f9457980c42c38b8ca59a265.png

1.3、配置環境變量

右鍵“我的電腦”->“屬性”->“高級屬性”->“環境變量”，新增環境變量

ROCKETMQ_HOME

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

0b0e0feb7ea815b3bc435dbcd64606ab.png

二、啟動NAMESERVER

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

start mqnamesrv.cmd

80ff204e721eed5fa4987d3db2a1f09a.png

如上圖所述，說明環境變量是正確的，并且NAMESERVER啟動成功，此框請不要關閉。

三、啟動BROKER

另外打開一個cmd命令窗口，輸入命令：

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

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

c34273f98eb83c0ec7b745726a65fb91.png

或者

啟動帶有配置文件的，啟動broker時需要加載配置文件，執行命令：

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

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

7d0e6313aaf9bb9683fab9007a554522.png

配置文件broker.conf默認內容如：

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

cmd運行brocker后：

96be0c6772496e37307e31cd7c98de59.png

奇怪，只是彈出了個框，卻沒有成功提示，不過這樣已經是啟動broker成功了，此框勿關閉。

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

四、查看連接到nameserver上的broker

mqadmin clusterList -n localhost:9876

25b88b1e6eab4d3d58ab5060a76f0ea0.png

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

通過git命令下載以下鏈接對應的源碼

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

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

mvn clean package -Dmaven.test.skip=true

507ff76887fb9cf5fb79ea565c87c33d.png

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

執行啟動該jar：

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

應用訪問：http://127.0.0.1:9980

bd92471e9effa794e30d0eb269464c33.png

六、創建主題topic

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

a3558d5b1a54c712b4b09d477540f26d.png

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

a15c886b34024de73f1582c0bc1a34c4.png

顯示剛剛已經創建的兩個topic：

78e82654894d24385d0b6c65cdc93e0a.png

然后可以查看一些自定義主題、系統主題等等：

35b2ca1113485798ecfdc46008a67530.png

七、控制臺創建主題

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

d33358a79b5b2448551c897974021558.png

八、啟動消費者

打開cmd命令窗口，執行以下命令：

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

e8273504d3fe620f73af0c67d64f3778.png

以上，消費者啟動成功。

九、啟動生產者

打開cmd命令窗口，執行以下命令：

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

11df987b15bd4a1ee2d453f243baec2f.png

使用topic是TopicTest。

這時候消費者窗口正在消費消息：

十、查看控制臺

de03bdd50813c3e1e3f33f20d466d75a.png

查看消費者：

e008b8f6a6a9c76a68563e61d35b085f.png

查看集群：

39bc18cae1a4cb2e892cb4be9956db87.png

查看主題TopicTest的各項信息：

4a09f947c86a14e9257c3545f9585161.png

狀態：

01d4b02e17e0430e2044376ce6f3ecf9.png

路由：

dfd1591e6508ac945297aab25812aa38.png

CONSUMER管理：

5eb57e290eaf76b85b570675a66a39cb.png

TOPIC配置：

3605976edd217b967c2ef6d52a3b12b0.png

查看消息：

d3ec6cd23aaf60c76a143cdf7b08add1.png

2f0ac0a25d922a4e66ab6942a1050a5e.png

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

十一、其他命令

1)刪除主題

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

十二、數據文件配置

12.1 查看數據存儲
rocketmq的數據默認都是存放到該目錄下

eb1c07bbc789f5bb9242dc6e2e081438.png

查詢屬性，發現文件實在太大了，想遷移該文件到其他地方，為c盤騰空間

58254514e6e9d672d50975ae2b92d52a.png

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

#存儲路徑storePathRootDir=D:\\04_work_installed\\01_java_tools\\34_Rocketmq_4_2_0\\rocketmq-all-4.2.0-bin-release\\store#commitLog 存儲路徑storePathCommitLog=D:\\04_work_installed\\01_java_tools\\34_Rocketmq_4_2_0\\rocketmq-all-4.2.0-bin-release\\store\\commitlog#消費隊列存儲路徑存儲路徑storePathConsumeQueue=D:\\04_work_installed\\01_java_tools\\34_Rocketmq_4_2_0\\rocketmq-all-4.2.0-bin-release\\store\\consumequeue#消息索引存儲路徑storePathIndex=D:\\04_work_installed\\01_java_tools\\34_Rocketmq_4_2_0\\rocketmq-all-4.2.0-bin-release\\store\\index#checkpoint 文件存儲路徑storeCheckpoint=D:\\04_work_installed\\01_java_tools\\34_Rocketmq_4_2_0\\rocketmq-all-4.2.0-bin-release\\store\\checkpoint#abort 文件存儲路徑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運行失敗)，然后重新運行：

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

運行成功后，你會發現rocketmq安裝目錄下生成store文件夾，里面還有生成一些文件，如：

6d31457c92b585602f2214c59d70c07f.png

關閉broker后，再將之前的備份拷貝回來：

701bed4d12f520899e735e790cb1c2ce.png

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

在上述配置的內容來看，rocketmq的各端配置、以及消息都是存儲在store里面的，需要保護好該目錄數據。

12.2 查看日志存儲

2f330e28ba43596b03a7beadf120fdf7.png

默認存儲在C:\Users\tiannan\logs\rocketmqlogs文件夾里面，這個日志文件夾以及里面的日志文件，是以下日志配置進行配置的：

85a8b535716caeffa69dd5c74be6e677.png

xml文件里面都是設置父目錄是 ${user.home}/logs/rocketmqlogs ，所以可以在對應的xml文件里面修改日志存儲位置。

十三、修改mqnamesrv和mqbroker的jvm內存

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

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文件，找到以下內容修改：

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

或者修改成你需要的內存大小即可。

挺簡單的，對你來說，已經學會了拉32d64461378da417cdded8cc8cb79e72.png32d64461378da417cdded8cc8cb79e72.png32d64461378da417cdded8cc8cb79e72.png32d64461378da417cdded8cc8cb79e72.png32d64461378da417cdded8cc8cb79e72.png32d64461378da417cdded8cc8cb79e72.png23f38c9582342608c202dcc66e9d09b6.png。?

關注我，下期繼續！！！

本文來自互聯網用戶投稿，該文觀點僅代表作者本人，不代表本站立場。本站僅提供信息存儲空間服務，不擁有所有權，不承擔相關法律責任。
如若轉載，請注明出處：http://www.pswp.cn/news/260246.shtml
繁體地址，請注明出處：http://hk.pswp.cn/news/260246.shtml
英文地址，請注明出處：http://en.pswp.cn/news/260246.shtml

如若內容造成侵權/違法違規/事實不符，請聯系多彩編程網進行投訴反饋email:809451989@qq.com，一經查實，立即刪除！

相關文章

WPF WebBrowser 加載 html ，出現安全警告， 運行 腳本和 activeX 控件，

WPF WebBrowser 加載 html ，出現安全警告， 運行 腳本和 activeX 控件，

對于你的問題&#xff0c;只需要在你的HTML首行添加如下代碼即可隱藏安全提示條&#xff1a; <!-- saved from url(0014)about:internet --> 還有一個可選方案是使用Winform的WebBrowser控件&#xff0c;不需要更改HTML代碼&#xff0c;也不會出現安全提示&#xff0c;需…
閱讀更多...
資料下載資源網站

資料下載資源網站

腳本之家&#xff1a;www.jb51.net 轉載于:https://www.cnblogs.com/dreammyle/p/3850250.html
閱讀更多...
php異步處理下載文件,異步處理Excel文件導入【流程圖+PHP示例】

php異步處理下載文件,異步處理Excel文件導入【流程圖+PHP示例】

面向管理后臺的系統中&#xff0c;經常會有文件導入的需求。常規的做法就是同步等待&#xff0c;但在業務關系復雜(多表數據校驗)、數據量較大的情況下&#xff0c;管理人員只能等結果&#xff0c;也可能會等到超時。使用異步的話&#xff0c;將導入數據的功能與后端接口解耦&a…
閱讀更多...
tcp client.cs

tcp client.cs

public class stateobject { public socket worksocket null; public const int Buffer_Size2048; public byte[] buffer new byte[Buffer_size]; public stringbuilder sb new stringbuilder(); } 轉載于:https://www.cnblogs.com/neumik/archive/2012/11/15/2771024.ht…
閱讀更多...
[python] 之 常用內建函數

[python] 之 常用內建函數

本博客僅列舉了一些常用的內建函數&#xff0c;歡迎大家補充&#xff01; 1. dir([obj]) 顯示對象的屬性&#xff0c;若果沒有提供參數&#xff0c;則顯示全局變量的名字 2. help([obj]) 以一種整齊美觀的方式&#xff0c;顯示對象的文檔字符串&#xff1b;如果沒有提供任何參數…
閱讀更多...
python查詢模塊所有類_python 小技巧(import模塊、查詢類繼承關系、安裝包)

python查詢模塊所有類_python 小技巧(import模塊、查詢類繼承關系、安裝包)

作者&#xff1a;Vamei 出處&#xff1a;http://www.cnblogs.com/vamei 歡迎轉載&#xff0c;也請保留這段聲明。謝謝&#xff01;在這里列舉一些我使用Python時積累的小技巧。這些技巧是我在使用Python過程中經常使用的。之前很零碎的記在筆記本中&#xff0c;現在整理出來&am…
閱讀更多...
4.2 access函數實例

4.2 access函數實例

int access(const char *filenpath, int mode); 功 能: 確定文件或文件夾的訪問權限。 mode&#xff0c;要判斷的模式在頭文件unistd.h中的預定義如下&#xff1a;#define R_OK 4 /* Test for read permission. */#define W_OK 2 /* Test for write permission. */#define X_OK…
閱讀更多...
php 簡易 blog,PHP實現簡易blog的制作

php 簡易 blog,PHP實現簡易blog的制作

最近&#xff0c;有時間看了點PHP的代碼。參考PHP100教程做了簡單的blog&#xff0c;這里面簡單的記錄一下。首先是集成環境&#xff0c;這里選用的WAMP&#xff1a;http://www.wampserver.com/en/首先通過&#xff0c;phpMyAdmin創建一張blog表。純界面操作&#xff0c;過程比…
閱讀更多...
jquery 事件對象屬性小結

jquery 事件對象屬性小結

jquery 事件對象屬性小結 使用事件自然少不了事件對象. 因為不同瀏覽器之間事件對象的獲取, 以及事件對象的屬性都有差異, 導致我們很難跨瀏覽器使用事件對象. jQuery中統一了事件對象, 當綁定事件處理函數時, 會將jQuery格式化后的事件對象作為唯一參數傳入: $("#testDiv…
閱讀更多...
ABP文檔 - Mvc 視圖

ABP文檔 - Mvc 視圖

文檔目錄 本節內容&#xff1a; 簡介AbpWebViewPage 基類簡介 ABP通過nuget包Abp.Web.Mvc集成到Mvc視圖里&#xff0c;你可以像往常那樣創建常規的視圖。 AbpWebViewPage 基類 ABP也提供了AbpWebViewPage&#xff0c;它定義了一些有用的屬性和方法&#xff0c;如果你使用啟動模…
閱讀更多...
ThinkPad L440 FN鍵設置

ThinkPad L440 FN鍵設置

剛入手了ThinkPad L440&#xff0c;用起來相當不錯&#xff0c;嘿嘿&#xff01; L440系統默認&#xff08;F1-F12&#xff09;鍵盤為系統默認功能鍵&#xff0c;主要控制音量、亮度、連接投影儀等。 因為編寫程序需要調試&#xff0c;經常用到F10&#xff0c;F11等鍵&#xff…
閱讀更多...
離散數學反對稱關系_《離散數學》學習記錄 - 集合論

離散數學反對稱關系_《離散數學》學習記錄 - 集合論

來源&#xff1a;北京大學《離散數學》公開課地址&#xff1a;https://www.bilibili.com/video/av18896337/?p122.1 有序對和卡氏積有序對<a,b>&#xff1a;有順序&#xff0c;類似于數組&#xff0c;可以用集合定義。性質&#xff1a;有序對內元素對應相等卡氏積AB&…
閱讀更多...
收集的博客列表

收集的博客列表

前端&#xff1a; ———————————————————— 宅居 - 裸: http://otakustay.com/ 轉載于:https://www.cnblogs.com/ccdc/archive/2012/11/21/2780879.html
閱讀更多...
php創建表并插入數據,php數據庫操作-創建庫和表以及插入數據

php創建表并插入數據,php數據庫操作-創建庫和表以及插入數據

以上我們正確連接到了mysql數據庫&#xff0c;本文將進一步創建數據庫&#xff0c;表&#xff0c;在表中填充數據。大家知道連接上數據庫才能進行操作&#xff0c;同樣的代碼搬過來/** 數據庫操作*(創建數據庫&#xff0c;表&#xff0c;插入數據&#xff0c;插入多條數據)** T…
閱讀更多...
C#配置及使用log4net

C#配置及使用log4net

首先從官方網站http://logging.apache.org/log4net/下載最近版本的log4net組件。在程序中添加對log4net.dll的引用&#xff0c;就可以在程序中使用了。 下一步&#xff0c;編寫配置文件&#xff0c;內容如下 <?xml version"1.0" encoding"utf-8" ?>…
閱讀更多...
ORACLE EBS常用表及查詢語句（最終整理版）

ORACLE EBS常用表及查詢語句（最終整理版）

建議去看參考二 參考一&#xff1a; call fnd_global.APPS_INITIALIZE(1318,50583,401) select fnd_profile.VALUE(ORG_ID) FROM DUAL select * from hr_operating_units hou where hou.organization_id204 --fn…
閱讀更多...
mysql觸發器 當記錄的指定字段發生變化時，更新表中的另外一個字段，或者更新另外一張關聯表中關聯記錄的字段...

mysql觸發器 當記錄的指定字段發生變化時，更新表中的另外一個字段，或者更新另外一張關聯表中關聯記錄的字段...

2019獨角獸企業重金招聘Python工程師標準>>> 注意&#xff1a;語句中出現的old&#xff0c;new&#xff0c;now&#xff08;&#xff09;&#xff0c;都為數據庫自帶的關鍵字&#xff0c;此處不做解釋。 兩種情況&#xff1a; 第一種&#xff1a;一張表中&#xff0…
閱讀更多...
通用無線設備對碼軟件_珞光全新發布國產通用軟件無線電平臺 ：USRP-LW N310！珞光品牌已實現國產替代...

通用無線設備對碼軟件_珞光全新發布國產通用軟件無線電平臺 ：USRP-LW N310！珞光品牌已實現國產替代...

USRP-LW N310是一種網絡的軟件定義無線電&#xff08;SDR&#xff09;&#xff0c;它提供了部署大規模的可靠的和容錯性的分布式無線系統。USRP-LW N310通過引入遠程執行任務的能力簡化了對SDR系統的控制和管理&#xff0c;如更新軟件&#xff0c;重新啟動&#xff0c;工廠復位…
閱讀更多...
手把手玩轉win8開發系列課程（2）

手把手玩轉win8開發系列課程（2）

對win8開發&#xff0c;上一節我們對win8進行了簡單的介紹&#xff0c;這一節我們來瞧一瞧他的開發環境搭建。 前奏。 這里所講的win8開發&#xff0c;主要是指Windows8 app store 上開發&#xff0c;及metro ui或叫morden ui 程序的開發。傳統桌面應用程序&#xff0c;網站應…
閱讀更多...
python通過什么來區分不同語句塊_Python語言通過

python通過什么來區分不同語句塊_Python語言通過

【填空題】小塊【填空題】離開;出發(n.)【填空題】好人啊中的 “ 啊 ” 讀( )【填空題】“ 潔癖 ” 的正確讀音是( )【單選題】The article suggests that when a person ________ under unusual stress he should be especially careful to have a well-balanced diet. (CET20…
閱讀更多...
最新文章

Copyright @ 2022~2023