签到成功

知道了

CNDBA社区CNDBA社区

rocketmq集群安装

2023-03-04 15:44 888 0 原创 RabbitMQ
作者: hbhe0316

1.设置hostname,两天服务器分别执行命令

hostnamectl set-hostname node01
hostnamectl set-hostname node02

2.设置/etc/hosts文件

http://www.cndba.cn/hbhe0316/article/116473
http://www.cndba.cn/hbhe0316/article/116473
http://www.cndba.cn/hbhe0316/article/116473
http://www.cndba.cn/hbhe0316/article/116473

[root@node01 ~]# cat /etc/hosts
127.0.0.1   localhost localhost.localdomain localhost4 localhost4.localdomain4
::1         localhost localhost.localdomain localhost6 localhost6.localdomain6
192.168.56.100 node01
192.168.56.101 node02

3.关闭selinux

[root@node01 ~]# sed -i 's/SELINUX=enforcing/SELINUX=disabled/g' /etc/sysconfig/selinux
[root@node01 ~]# setenforce 0

4.关闭防火墙

[root@node01 ~]# systemctl stop firewalld
[root@node01 ~]# systemctl disable firewalld

5.安装JDK

[root@node01 home]# rpm -ivh jdk-18.0.2.1_linux-x64_bin.rpm 
[root@node01 home]# java -version
java version "18.0.2.1" 2022-08-18
Java(TM) SE Runtime Environment (build 18.0.2.1+1-1)
Java HotSpot(TM) 64-Bit Server VM (build 18.0.2.1+1-1, mixed mode, sharing)

6.解压rocketmqhttp://www.cndba.cn/hbhe0316/article/116473http://www.cndba.cn/hbhe0316/article/116473

[root@node01 home]# unzip rocketmq-all-5.1.0-bin-release.zip -d /opt/
[root@node01 opt]# mv rocketmq-all-5.1.0-bin-release/ rocketmq

7.修改node01节点文件http://www.cndba.cn/hbhe0316/article/116473

[root@node01 opt]# cd /opt/rocketmq/conf/2m-2s-async
[root@node01 2m-2s-async]# cat broker-a.properties 
brokerClusterName=DefaultCluster
brokerName=broker-a
brokerId=0
deleteWhen=04
fileReservedTime=48
brokerRole=ASYNC_MASTER
flushDiskType=ASYNC_FLUSH
namesrvAddr=192.168.56.100:9876;192.168.56.101:9876

[root@node01 2m-2s-async]# cat broker-b-s.properties
brokerClusterName=DefaultCluster
brokerName=broker-b
brokerId=1
deleteWhen=04
fileReservedTime=48
brokerRole=SLAVE
flushDiskType=ASYNC_FLUSH
namesrvAddr=192.168.56.100:9876;192.168.56.101:9876
listenPort=11911
storePathRootDir=~/store-s
storePathCommitLog=~/store-s/commitlog
storePathConsumeQueue=~/store-s/consumequeue
storePathIndex=~/store-s/index
storeCheckpoint=~/store-s/checkpoint
abortFile=~/store-s/abort

8.修改node02节点的broker-a.properties 文件

http://www.cndba.cn/hbhe0316/article/116473

[root@node02 2m-2s-async]# cd /opt/rocketmq/conf/2m-2s-async
[root@node02 2m-2s-async]# cat broker-b.properties 
brokerClusterName=DefaultCluster
brokerName=broker-b
brokerId=0
deleteWhen=04
fileReservedTime=48
brokerRole=ASYNC_MASTER
flushDiskType=ASYNC_FLUSH
namesrvAddr=192.168.56.100:9876;192.168.56.101:9876

[root@node02 2m-2s-async]# cat broker-a-s.properties 
brokerClusterName=DefaultCluster
brokerName=broker-a
brokerId=1
deleteWhen=04
fileReservedTime=48
brokerRole=SLAVE
flushDiskType=ASYNC_FLUSH
namesrvAddr=192.168.56.100:9876;192.168.56.101:9876
listenPort=11911
storePathRootDir=~/store-s
storePathCommitLog=~/store-s/commitlog
storePathConsumeQueue=~/store-s/consumequeue
storePathIndex=~/store-s/index
storeCheckpoint=~/store-s/checkpoint
abortFile=~/store-s/abort

启动集群http://www.cndba.cn/hbhe0316/article/116473

http://www.cndba.cn/hbhe0316/article/116473

[root@node01 rocketmq]# cd /opt/rocketmq
[root@node01 rocketmq]# nohup sh bin/mqnamesrv &
[root@node01 rocketmq]# tail -f ~/logs/rocketmqlogs/namesrv.log

[root@node02 rocketmq]# cd /opt/rocketmq
[root@node02 rocketmq]# nohup sh bin/mqnamesrv &
[root@node02 rocketmq]# tail -f ~/logs/rocketmqlogs/namesrv.log

启动两个Master

[root@node01 rocketmq]# nohup sh bin/mqbroker -c conf/2m-2s-async/broker-a.properties &
[root@node01 rocketmq]# tail -f ~/logs/rocketmqlogs/broker.log
[root@node02 rocketmq]# nohup sh bin/mqbroker -c conf/2m-2s-async/broker-b.properties &
[root@node02 rocketmq]# tail -f ~/logs/rocketmqlogs/broker.log

启动两个slave节点

[root@node01 rocketmq]# nohup sh bin/mqbroker -c conf/2m-2s-async/broker-b-s.properties &
[root@node01 rocketmq]# tail -f ~/logs/rocketmqlogs/broker.log
[root@node02 rocketmq]# nohup sh bin/mqbroker -c conf/2m-2s-async/broker-a-s.properties &
[root@node02 rocketmq]# tail -f ~/logs/rocketmqlogs/broker.log

版权声明:本文为博主原创文章,未经博主允许不得转载。

rocketmq

用户评论
* 以下用户言论只代表其个人观点,不代表CNDBA社区的观点或立场
hbhe0316

hbhe0316

关注

1.只有承认无知,才能装下新的东西; 2.进步来自一点点滴滴的积累; 3.广博让你更优秀,而专业让你无法替代; 4.挫折和失败能够转换为一种财富。

  • 889
    原创
  • 1
    翻译
  • 13
    转载
  • 24
    评论
  • 访问:1140337次
  • 积分:1523
  • 等级:核心会员
  • 排名:第6名
精华文章
    最新问题
    查看更多+
    热门文章
      热门用户
      推荐用户
        Copyright © 2016 All Rights Reserved. Powered by CNDBA · 皖ICP备2022006297号-1·

        QQ交流群

        注册联系QQ