centos安裝rocketmq


1. RocketMQ快速入門

RocketMQ是阿里巴巴2016年MQ中間件,使用Java語言開發,在阿里內部,RocketMQ承接了例如“雙11”等高並發場景的消息流轉,能夠處理萬億級別的消息。

1.1 准備工作

1.1.1 下載RocketMQ

RocketMQ版本:4.4.0

下載地址

img

1.1.2 環境要求

  • Linux64位系統
  • JDK1.8(64位)
  • 源碼安裝需要安裝Maven 3.2.x

1.1.3 常用插件安裝命令

 解壓文件    yum install -y unzip zip
 windows 需要向centos服務器上傳文件   yum -y install lrzsz

1.2 安裝RocketMQ

1.2.1 安裝步驟

本教程以二進制包方式安裝

1.2.1.1 通過rz 把下載好的壓縮文件上傳到指定centos目錄下面

在這里插入圖片描述

1.2.1.2.解壓rocket4.4壓縮包

unzip -d /usr/software rocketmq-all-4.4.0-bin-release.zip

在這里插入圖片描述

1.2.2 目錄介紹

img

  • benchmark :rocketmq的一些代碼示例
  • bin:啟動腳本,包括shell腳本和CMD腳本
  • conf:實例配置文件 ,包括broker配置文件、logback配置文件等
  • lib:依賴jar包,包括Netty、commons-lang、FastJSON等

1.3 啟動RocketMQ

  1. 啟動NameServer
# 1.啟動NameServer
nohup sh bin/mqnamesrv &
# 2.查看啟動日志
tail -f ~/logs/rocketmqlogs/namesrv.log
  1. 啟動Broker
# 1.啟動Broker
nohup sh bin/mqbroker -n localhost:9876 &
# 2.查看啟動日志
tail -f ~/logs/rocketmqlogs/broker.log 
  • 問題描述:

    RocketMQ默認的虛擬機內存較大,啟動Broker如果因為內存不足失敗,需要編輯如下兩個配置文件,修改JVM內存大小

# 編輯runbroker.sh和runserver.sh修改默認JVM大小
vi runbroker.sh
vi runserver.sh
  • 參考設置:

JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"

1.4 測試RocketMQ

1.4.1 發送消息

# 1.設置環境變量
export NAMESRV_ADDR=localhost:9876
# 2.使用安裝包的Demo發送消息
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

1.4.2 接收消息

# 1.設置環境變量
export NAMESRV_ADDR=localhost:9876
# 2.接收消息
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

1.5 關閉RocketMQ

# 1.關閉NameServer
sh bin/mqshutdown namesrv
# 2.關閉Broker
sh bin/mqshutdown broker


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM