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