安裝準(zhǔn)備
新上線系統(tǒng)要求安裝recketmq或者以上版本。
2. RocketMQ部署配置規(guī)范
針對(duì)linux、unix操作系統(tǒng),除一些操作系統(tǒng)配置、用戶創(chuàng)建等操作外,所有RocketMQ軟件安裝以及配置、啟動(dòng)操作建議使用RocketMQ用戶進(jìn)行。
systemctl stop firewalld |
配置hosts 文件,每臺(tái)服務(wù)器添加hosts文件信息。
按照口令要求進(jìn)行口令創(chuàng)建。
cd /root/.ssh scp id_dsa.pub root@node2:~ scp id_dsa.pub root@node3:~ 拷貝的時(shí)候你會(huì)發(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地址
添加完此配置后 啟動(dòng)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)存)
啟動(dòng)nameserver 在bin錄入下
nohup sh bin/mqnamesrv &
jps檢驗(yàn) 啟動(dòng)進(jìn)程
啟動(dòng) broker
nohup ./mqbroker -c ../conf/broker.conf &
Step4:
開(kāi)始搭建2主2從異步刷盤的集群,這個(gè)集群的搭建reckmq有對(duì)應(yīng)的模板文件在conf/2m-2s-async 下的配置文件:
啟動(dòng) :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 &
啟動(dòng):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 &
啟動(dòng):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 源碼中并沒(méi)有提供控制臺(tái),但是在rocketmq社區(qū)擴(kuò)展項(xiàng)目中提供一個(gè)控制臺(tái):
地址:
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 &
啟動(dòng):
http://192.168.1.3:8080/#/
更多精彩干貨分享
點(diǎn)擊下方名片關(guān)注
IT那活兒
文章版權(quán)歸作者所有,未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為,您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請(qǐng)注明本文地址:http://specialneedsforspecialkids.com/yun/129815.html
摘要:本地的安裝與調(diào)試標(biāo)簽啟動(dòng)進(jìn)入的源碼項(xiàng)目。消息發(fā)送的高性能與低延遲。強(qiáng)大的消息堆積能力與消息處理能力。嚴(yán)格的順序消息存儲(chǔ)。保證消息至少被消費(fèi)一次,但不承諾消息不會(huì)被消費(fèi)者多次消費(fèi)。其消息的冪等由消費(fèi)者自己實(shí)現(xiàn)。 本地RocketMQ的安裝與調(diào)試 標(biāo)簽:【RocketMQ】 1. 啟動(dòng) 進(jìn)入RocketMQ-ALL的源碼項(xiàng)目。 執(zhí)行maven打包: mvn -Prelease-all ...
摘要:前提通過(guò)前面兩篇文章可以簡(jiǎn)單的了解和安裝,今天就將和整合起來(lái)使用。然后我運(yùn)行之前的整合項(xiàng)目,查看監(jiān)控信息如下總結(jié)整篇文章講述了與整合和監(jiān)控平臺(tái)的搭建。 showImg(https://segmentfault.com/img/remote/1460000013232432?w=1920&h=1277); 前提 通過(guò)前面兩篇文章可以簡(jiǎn)單的了解 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ì)列就是阿里借鑒的原理用開(kāi)發(fā)而得。 我自己總結(jié)的Java學(xué)習(xí)的系統(tǒng)知識(shí)點(diǎn)以及面試問(wèn)題,目前已經(jīng)開(kāi)源,會(huì)一直完善下去,歡迎建議和指導(dǎo)歡迎Star: https://github.com/Snail...
摘要:依次執(zhí)行下面命令本地安裝從官方安裝包下載。管理界面提供多種管理方式命令行和界面等提供一個(gè)開(kāi)源的擴(kuò)展項(xiàng)目里面包含一個(gè)子項(xiàng)目配置下打個(gè)包就可以用了。 前言 github 開(kāi)源項(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)備面試。因此基于事件消息對(duì)象驅(qū)動(dòng)的業(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的...
閱讀 1346·2023-01-11 13:20
閱讀 1684·2023-01-11 13:20
閱讀 1132·2023-01-11 13:20
閱讀 1858·2023-01-11 13:20
閱讀 4100·2023-01-11 13:20
閱讀 2704·2023-01-11 13:20
閱讀 1385·2023-01-11 13:20
閱讀 3597·2023-01-11 13:20