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,这个是可以的。