安裝準(zhǔn)備
新上線系統(tǒng)要求安裝recketmq或者以上版本。
2. RocketMQ部署配置規(guī)范
針對linux、unix操作系統(tǒng),除一些操作系統(tǒng)配置、用戶創(chuàng)建等操作外,所有RocketMQ軟件安裝以及配置、啟動操作建議使用RocketMQ用戶進(jìn)行。
systemctl stop firewalld |
配置hosts 文件,每臺服務(wù)器添加hosts文件信息。
按照口令要求進(jìn)行口令創(chuàng)建。
cd /root/.ssh scp id_dsa.pub root@node2:~ scp id_dsa.pub root@node3:~ 拷貝的時(shí)候你會發(fā)現(xiàn),是需要密碼的。 cat ~/id_dsa.pub >>~/.ssh/authorized_keys |
7. 在官網(wǎng)下載rocketmq包并上傳
官網(wǎng)地址:http://rocketmq.apache.org/
下載完成后按照要求上傳到/opt/application/
安裝部署規(guī)范
本規(guī)范暫時(shí)以rocketmq4.9版本為例。
cd /opt/application/ unzip rocketmq-all-4.9.0-bin-release.zip |
2. 安裝java-jdk
修改配置:vi /etc/profile
生效:source /etc/profile
要注意如何是單機(jī)部署 rocketmq 要添加nameserver地址
添加完此配置后 啟動nameserver:
cd /opt/application/rocketmq-all-4.9.0-bin-release/bin
單機(jī)服務(wù):
Step1:
修改nameserver jvm參數(shù)
(內(nèi)存默認(rèn) 是4g要根據(jù)自己的實(shí)際 情況修改 一個(gè) 512M)
修改runserver.sh 修改內(nèi)存為512M
Step2:
修改runbroker.sh jvm參數(shù)
(內(nèi)存默認(rèn) 是8g要根據(jù)自己的實(shí)際 情況修改 一個(gè) 512M)
修改runbroker.sh 修改內(nèi)存為1g(界面內(nèi)存)
啟動nameserver 在bin錄入下
nohup sh bin/mqnamesrv &
jps檢驗(yàn) 啟動進(jìn)程
啟動 broker
nohup ./mqbroker -c ../conf/broker.conf &
Step4:
開始搭建2主2從異步刷盤的集群,這個(gè)集群的搭建reckmq有對應(yīng)的模板文件在conf/2m-2s-async 下的配置文件:
啟動 :NameServer
Node1:
cd /opt/application/rocketmq-all-4.9.0-bin-release/bin
nohup sh bin/mqnamesrv &
node2: NameServer 和 broker
cd /opt/application/rocketmq-all-4.9.0-bin-release/bin
nohup sh bin/mqnamesrv &
啟動:broker
cd /opt/application/rocketmq-all-4.9.0-bin-release/bin
nohup ./mqbroker -c ../conf/2m-2s-async/broker-a.properties &
nohup ./mqbroker -c ../conf/2m-2s-async/broker-b-s.properties &
.-
node3: NameServer 和 broker
cd /opt/application/rocketmq-all-4.9.0-bin-release/bin
nohup sh bin/mqnamesrv &
啟動:broker
cd /opt/application/rocketmq-all-4.9.0-bin-release/bin
nohup ./mqbroker -c ../conf/2m-2s-async/broker-b.properties &
nohup ./mqbroker -c ../conf/2m-2s-async/broker-a-s.properties &
消費(fèi)消息和接受消息:
發(fā)送消息和接收消息
export NAMESRV_ADDR=192.168.1.5:9876
export NAMESRV_ADDR=192.168.1.4:9876
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
rocketmq 源碼中并沒有提供控制臺,但是在rocketmq社區(qū)擴(kuò)展項(xiàng)目中提供一個(gè)控制臺:
地址:
https:github.com.apache/recketmq-externals
/原始地址
https://github.com/apache/rocketmq-externals
//加速地址
https://codechina.csdn.net/mirrors/apache/rocketmq-externals/
下載rocketmq-console 項(xiàng)目:
1) 安裝maven
yum install maven
2) 安裝maven
yum install git
3) 下載rocketmq-externals代碼
git clone https://codechina.csdn.net/mirrors/apache/rocketmq-externals/
4) 編譯
(編譯前可以先修改配置文件 vim src/main/resources/application.properties )cd rocketmq-externals/rocketmq-console/
mvn clean package -Dmaven.test.skip=true
在rocketmq-externals/rocketmq-console/target/目錄下即為目標(biāo)文件 :rocketmq-console-ng-2.0.0.jar
5) 運(yùn)行
nohup java -jar rocketmq-console-ng-2.0.0.jar --rocketmq.config.namesrvAddr=localhost:9876 --server.port=8080 &
啟動:
http://192.168.1.3:8080/#/
更多精彩干貨分享
點(diǎn)擊下方名片關(guān)注
IT那活兒
文章版權(quán)歸作者所有,未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為,您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請注明本文地址:http://systransis.cn/yun/129815.html
摘要:本地的安裝與調(diào)試標(biāo)簽啟動進(jìn)入的源碼項(xiàng)目。消息發(fā)送的高性能與低延遲。強(qiáng)大的消息堆積能力與消息處理能力。嚴(yán)格的順序消息存儲。保證消息至少被消費(fèi)一次,但不承諾消息不會被消費(fèi)者多次消費(fèi)。其消息的冪等由消費(fèi)者自己實(shí)現(xiàn)。 本地RocketMQ的安裝與調(diào)試 標(biāo)簽:【RocketMQ】 1. 啟動 進(jìn)入RocketMQ-ALL的源碼項(xiàng)目。 執(zhí)行maven打包: mvn -Prelease-all ...
摘要:前提通過前面兩篇文章可以簡單的了解和安裝,今天就將和整合起來使用。然后我運(yùn)行之前的整合項(xiàng)目,查看監(jiān)控信息如下總結(jié)整篇文章講述了與整合和監(jiān)控平臺的搭建。 showImg(https://segmentfault.com/img/remote/1460000013232432?w=1920&h=1277); 前提 通過前面兩篇文章可以簡單的了解 RocketMQ 和 安裝 RocketMQ...
摘要:具體可以參考消息隊(duì)列之具體可以參考實(shí)戰(zhàn)之快速入門十分鐘入門阿里中間件團(tuán)隊(duì)博客是一個(gè)分布式的可分區(qū)的可復(fù)制的基于發(fā)布訂閱的消息系統(tǒng)主要用于大數(shù)據(jù)領(lǐng)域當(dāng)然在分布式系統(tǒng)中也有應(yīng)用。目前市面上流行的消息隊(duì)列就是阿里借鑒的原理用開發(fā)而得。 我自己總結(jié)的Java學(xué)習(xí)的系統(tǒng)知識點(diǎn)以及面試問題,目前已經(jīng)開源,會一直完善下去,歡迎建議和指導(dǎo)歡迎Star: https://github.com/Snail...
摘要:依次執(zhí)行下面命令本地安裝從官方安裝包下載。管理界面提供多種管理方式命令行和界面等提供一個(gè)開源的擴(kuò)展項(xiàng)目里面包含一個(gè)子項(xiàng)目配置下打個(gè)包就可以用了。 前言 github 開源項(xiàng)目--paascloud-master:https://github.com/paascloud/... paascloud-master 官方環(huán)境搭建:http://blog.paascloud.net/20...
摘要:我在前面的文章中也提到了應(yīng)該怎么做自我介紹與項(xiàng)目介紹,詳情可以查看這篇文章備戰(zhàn)春招秋招系列初出茅廬的程序員該如何準(zhǔn)備面試。因此基于事件消息對象驅(qū)動的業(yè)務(wù)架構(gòu)可以是一系列流程。 showImg(https://user-gold-cdn.xitu.io/2018/11/14/16711ac29c2ae52c?w=928&h=531&f=png&s=798562); 一 消息隊(duì)列MQ的...
閱讀 1356·2023-01-11 13:20
閱讀 1707·2023-01-11 13:20
閱讀 1215·2023-01-11 13:20
閱讀 1906·2023-01-11 13:20
閱讀 4165·2023-01-11 13:20
閱讀 2757·2023-01-11 13:20
閱讀 1402·2023-01-11 13:20
閱讀 3671·2023-01-11 13:20