RocketMQ簡介
- 官網地址: https://rocketmq.apache.org/zh/
- 文檔地址: 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