RocketMQ簡介

  1. 官網地址: https://rocketmq.apache.org/zh/
  2. 文檔地址: https://rocketmq.apache.org/zh/docs/

RocketMQ安裝

1. 安裝Javajdk

#Debian
apt install -y openjdk-17-jdk

#CentOS
yum install -y java-11-openjdk-devel

2. 安裝 Maven

#Debian
apt install -y maven

#CentOS
yum install -y maven

3. 下載RocketMQ

官方下載地址: https://rocketmq.apache.org/zh/download

# 下載ROCKETMQ
wget https://dist.apache.org/repos/dist/release/rocketmq/5.3.3/rocketmq-all-5.3.3-bin-release.zip

# 解壓
unzip rocketmq-all-5.3.3-bin-release.zip

4. 啓動RocketMQ


cd rocketmq-all-5.3.3-bin-release

# 啓動RocketMQ server - 默認本機9876端口
./bin/mqnamesrv

# 修改broker配置 修改 JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx2g 最小 512m最大2g 或其他
vim bin/runbroker.sh

# 啓動RocketMQ broker - 使用 --enable-proxy 可使用gRPC協議
./bin/mqbroker -n 127.0.0.1:9876 --enable-proxy 

使用RocketMQ Dashboard (圖形管理界面)

源碼地址: https://github.com/apache/rocketmq-dashboard 官方文檔: https://rocketmq.apache.org/zh/docs/deploymentOperations/04Dashboard

1. 下載RocketMQ Dashboard

git clone https://github.com/apache/rocketmq-dashboard.git

2. 編譯jar包

cd rocketmq-dashboard

# 內存要大於4G
mvn clean package -Dmaven.test.skip=true

3. 啓動RocketMQ Dashboard

# 本地連接遠程RocketMQ server
# 指定啓動端口 server.port: 8082 (默認)
# 修改鏈接的RockerMQ server - rocketmq.namesrvAddrs: - ip:port
# 注 本機鏈接遠程server需要注意 需要修改 rocketmq broker 啓動配置
vim src/main/resources/application.yml

# 修改rocketmq broker啓動配置 - 增加 brokerIP1=IP (需要RocketMQ Dashboard服務可連接到)
vim conf/broker.conf

# 啓動RocketMQ Dashboard
java -jar target/rocketmq-dashboard.jar