寫在前面
簡單說明一下,RocketMQ是阿裡團隊開發,并推到Apache社群,它的入門稍微有點難(主要是環境、網絡、社群的資源有限),下面我簡單介紹一下
一、安裝、部署
這裡包括三個
- Windows單機
- Linux單機
- linux多主多從
上文中說到的難點就是,Linux 的版本學習,本地可以部署成功,但用戶端Client連接配接,總是連接配接不上
這裡我先介紹下 本地Windows的版本學習
1.1、Windows單機版
1.1.1、基本環境
- 64bit
- 64bit JDK 1.8+;
- Maven
- Git
三種安裝方式,
- 源碼
- 二進制檔案
- docker
這裡我介紹下,二進制的安裝方式
下載下傳
然後 解壓 -> 配置環境變量 -> 修改配置 -> 啟動 nameserver -> 啟動 broker
1.1.2、需要注意的地方
- 配置環境變量 ,一定要 用 ROCKETMQ_HOME 來辨別
- 修改配置,單機版,隻要修改 啟動配置即可
修改 這兩個配置檔案的啟動 記憶體配置設定,調小 如下
-server -Xms256m -Xmx256m -Xmn125m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m
1.1.3、啟動服務
- 先啟動 mqnamesrv.cmd
-
再啟動 mqbroker.cmd
注意啟動Broker 時,指定 自動生成Topic
start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true
1.1.、配置控制台
這裡,我有 打好的包,在這裡(僅适合本地單機版)
https://kdocs.cn/l/ce6BAkTZo [金山文檔] rocketmq-console-ng-1.0.1.jar
也可從官網,下載下傳源碼,修改nameserver 配置,編譯,打包,執行