0
点赞
收藏
分享

微信扫一扫

RocketMQ的部署

Java架构领域 2021-09-27 阅读 70
RocketMQ

1.机器上先安装java环境(安装JDK,maven等)

2.下载RocketMQ的源码来编译构建

执行如下命令来构建Dledger:

git clone https://github.com/openmessaging/openmessaging-storage-dledger.git
cd openmessaging-storage-dledger
mvn clean install -DskipTests

执行下面命令构建RocketMQ

git clone https://github.com/apache/rocketmq.git
cd rocketmq
git checkout -b store_with_dledger origin/store_with_dledger
mvn -Prelease-all -DskipTests clean install -U
cd distribution/target/apache-rocketmq

在上述目录中修改三个文件,一个是bin/runserver.sh,一个是bin/runbroker.sh,另一个是bin/tools.sh在里面找到如下三行,然后将第二行和第三行都删除掉,同时将第一行的值修改为自己的JDK的主目录。

[ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME=$HOME/jdk/java
[ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME=/usr/java
[ ! -e "$JAVA_HOME/bin/java" ] && error_exit "Please set the JAVA_HOME variable in your environment, We need java(x64)!"

注:查看JDK的目录命令:/usr/libexec/java_home -V,
执行下面的命令进行快速RocketMQ集群的启动

sh bin/dledger/fast-try.sh start

这个命令会在当前这台机器上启动一个NameServer和三个Broker,三个Broker其中一个是Master,另外两个是Slave,瞬间就可以组成一个最小的Rocker集群
使用以下命令检查一下RocketMQ的集群状态

sh bin/mqadmin clusterList -n 127.0.0.1:9876


看到如上图就说明启动成功了,BID为0的就是Master,BID大于0的就是Slave。
尝试slave自动切换为master

##找到master的进程号
lsof -i:30931

kill -9 58798 ##干掉它

通过上面查看集群状态的命令再次查看集群状态详情


3.完成正式的三台NameServer的部署

还是先在三台机器上安装java环境,以及根据上述步骤把RockerMQ和Dledger全都构建好。
启动NameServer

nohup sh mqnamesrv & ##NameServer监听的接口默认就是9876,

4.完成一组Broker集群的部署

同样的还是在机器上先安装好java环境以及构建好Dledger和RockerMQ,然后编辑好对应的文件。
执行如下命令:

nohup sh bin/mqbroker -c conf/dledger/broker-n0.conf &

注:第一个Broker的配置文件是broker-n0.conf,第二个broker的配置文件可以是broker-n1.conf,第三broker
的配置文件可以是broker-n2.conf。
对broker-n0.conf配置文件的说明:

其实最关键的是,你的Broker是分为多组的,每一组是三个Broker,一个Master和两个Slave。对每一组Broker,他们的Broker名称、Group名称都是一样的,然后你得给他们配置好一样的dLegerPeers(里面是组内三台Broker的地址)然后他们得配置好对应的NameServer的地址,最后还有就是每个Broker有自己的ID,在组内是唯一的就可以了,比如说不同的组里都有一个ID为n0的broker,这个是可以的。

举报

相关推荐

0 条评论