Rocketmq-DLeger-集群安装

Rocketmq-DLeger-集群安装

官方文档

More Info: 官方文档

More Info: rocketmq-dashbord

部署主机

1
2
3
172.31.34.25   aws-sit-app-01  
172.31.43.98 aws-sit-app-03
172.31.43.45 aws-sit-app-04

配置文件

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
/data/rocketmq/conf/dledger/broker-n*.conf

brokerClusterName = RaftCluster
brokerName=RaftNode00
listenPort=30911
namesrvAddr=172.31.34.25:9876;172.31.43.98:9876;172.31.43.45:9876
storePathRootDir=/tmp/rmqstore/node00
storePathCommitLog=/tmp/rmqstore/node00/commitlog
enableDLegerCommitLog=true
dLegerGroup=RaftNode00
dLegerPeers=n0-172.31.34.25:40911;n1-172.31.43.98:40911;n2-172.31.43.45:40911
##每个节点更改n0、n1、n2
dLegerSelfId=n0
sendMessageThreadPoolNums=4
##自动创建topic
autoCreateTopicEnable = true
## 执行broker ip(多网卡适用)
#brokerIP1=10.19.73.64

启动脚本

1
2
3
4
5
6
7
8
9
10
11
#!/bin/sh
export JAVA_HOME=/data/soft/jdk1.8.0_301
export PATH=$JAVA_HOME/bin:$PATH

ROOT_PATH=/data/rocketmq

nohup sh $ROOT_PATH/bin/mqnamesrv > $ROOT_PATH/startup.log 2>&1 &
nohup sh $ROOT_PATH/bin/mqbroker -c $ROOT_PATH/conf/dledger/broker-n0.conf >> $ROOT_PATH/startup.log 2>&1 &
## mq console
nohup java -jar $ROOT_PATH/rocketmq-dashboard-1.0.1-SNAPSHOT.jar --server.port=9801 \
--rocketmq.config.namesrvAddr=tcp.farmbgy.net:29876 > $ROOT_PATH/startDashboard.log 2>&1 &

systemd-service

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
cat << EOF > /usr/lib/systemd/system/rocketmq.service
[Unit]
Description=rocketmq
After=network.target

[Service]
Type=forking
User=root

ExecStart=/data/rocketmq/startup.sh
ExecStop=/data/rocketmq/stop.sh

[Install]
WantedBy=multi-user.target

EOF

systemctl daemon-reload
systemctl enable rocketmq
systemctl start rocketmq
systemctl stop rocketmq