rocketmq部署
一、安装jdk
1. 上传jdkjdk-8u361-linux-x64.tar.gz
2.解压
tar xf jdk-8u361-linux-x64.tar.gz -C /data
3.配置环境变量
vim /etc/profile
export JAVA_HOME=/data/jdk1.8.0_361
export PATH=$JAVA_HOME/bin:$PATH
export CLASSPATH=.:$JAVA_HOEM/lib/dt.jar:$JAVA_HOME/lib/tools.jar
4.执行并验证
source /etc/profile
java -version
二、安装rocketmq
1.两节点:
192.168.233.128(rocketmq-1)
192.168.233.129(rocketmq-2)
1. 安装NameServer
1.1 上传安装包并解压
1. 上传rocketmq-all-4.7.0-bin-release.zip
2.解压
unzip rocketmq-all-4.7.0-bin-release.zip -d /data
mv /data/rocketmq-all-4.7.0-bin-release /data/rocketmq
1.2 配置rocketmq环境变量
vim /etc/profile
# rocketmq
ROCKETMQ_HOME=/data/rocketmq
PATH=$PATH:$ROCKETMQ_HOME/bin
export PATH ROCKETMQ_HOME
# 执行
source /etc/profile
1.3 启动与停止
1.启动NameServer
nohup sh /data/rocketmq/bin/mqnamesrv &
2.验证
jps
3. 查看启动日志
tail -f /data/rocketmq/logs/rocketmqlogs/namesrv.log
3.停止NameServer
nohup sh /data/rocketmq/bin/mqshutdown namesrv
2. 安装broker
2.1 单节点
1. 启动
nohup sh /data/rocketmq/bin/mqbroker -n localhost:9876 &
2. 查看启动日志
tail -f /data/rocketmq/logs/rocketmqlogs/broker.log
2.2 异步模式
rocketmq-1配置master
[root@rocketmq-1 ~]# vim /data/rocketmq/conf/2m-2s-async/broker-a.properties
#所属集群名字
brokerClusterName=rocketmq-cluster
#broker名字，注意此处不同的配置文件填写的不一样 例如：在a.properties 文件中写 broker-a 在b.properties 文件中写 broker-b
brokerName=broker-a
#0 表示 Master，>0 表示 Slave
brokerId=0
#删除文件时间点，默认凌晨 4点
deleteWhen=04
#文件保留时间，默认 48 小时
fileReservedTime=120
#Broker 的角色，ASYNC_MASTER=异步复制Master，SYNC_MASTER=同步双写Master，SLAVE=slave节点
brokerRole=ASYNC_MASTER
#刷盘方式，ASYNC_FLUSH=异步刷盘，SYNC_FLUSH=同步刷盘
flushDiskType=SYNC_FLUSH
#Broker 对外服务的监听端口
listenPort=10911
#nameServer地址，这里nameserver是单台，如果nameserver是多台集群的话，就用分号分割（即namesrvAddr=ip1:port1;ip2:port2;ip3:port3）
namesrvAddr=192.168.233.128:9876;192.168.233.129:9876
#每个topic对应队列的数量，默认为4，实际应参考consumer实例的数量，值过小不利于consumer负载均衡
defaultTopicQueueNums=8
#是否允许 Broker 自动创建Topic，生产建议关闭
autoCreateTopicEnable=true
#是否允许 Broker 自动创建订阅组，生产建议关闭
autoCreateSubscriptionGroup=true
#设置BrokerIP
brokerIP1=192.168.233.128
#存储路径
storePathRootDir=/data/rocketmq/data/store-a
#commitLog 存储路径
storePathCommitLog=/data/rocketmq/data/store-a/commitlog
#消费队列存储路径存储路径
storePathConsumerQueue=/data/rocketmq/data/store-a/consumequeue
#消息索引存储路径
storePathIndex=/data/rocketmq/data/store-a/index
#checkpoint 文件存储路径
storeCheckpoint=/data/rocketmq/data/store-a/checkpoint
#abort 文件存储路径
abortFile=/data/rocketmq/data/store-a/abort
#commitLog每个文件的大小默认1G
mapedFileSizeCommitLog=1073741824
#ConsumeQueue每个文件默认存30W条，根据业务情况调整
mapedFileSizeConsumeQueue=300000
rocketmq-1配置slave
[root@rocketmq-1 ~]# vim /data/rocketmq/conf/2m-2s-async/broker-b-s.properties
#所属集群名字
brokerClusterName=rocketmq-cluster
#broker名字，注意此处不同的配置文件填写的不一样 例如：在a.properties 文件中写 broker-a 在b.properties 文件中写 broker-b
brokerName=broker-b
#0 表示 Master，>0 表示 Slave
brokerId=1
#删除文件时间点，默认凌晨 4点
deleteWhen=04
#文件保留时间，默认 48 小时
fileReservedTime=120
#Broker 的角色，ASYNC_MASTER=异步复制Master，SYNC_MASTER=同步双写Master，SLAVE=slave节点
brokerRole=SLAVE
#刷盘方式，ASYNC_FLUSH=异步刷盘，SYNC_FLUSH=同步刷盘
flushDiskType=SYNC_FLUSH
#Broker 对外服务的监听端口
listenPort=11011
#nameServer地址，这里nameserver是单台，如果nameserver是多台集群的话，就用分号分割（即namesrvAddr=ip1:port1;ip2:port2;ip3:port3）
namesrvAddr=192.168.233.128:9876;192.168.233.129:9876
#每个topic对应队列的数量，默认为4，实际应参考consumer实例的数量，值过小不利于consumer负载均衡
defaultTopicQueueNums=8
#是否允许 Broker 自动创建Topic，生产建议关闭
autoCreateTopicEnable=true
#是否允许 Broker 自动创建订阅组，生产建议关闭
autoCreateSubscriptionGroup=true
#设置BrokerIP
brokerIP1=192.168.233.128
#存储路径
storePathRootDir=/data/rocketmq/data/store-b
#commitLog 存储路径
storePathCommitLog=/data/rocketmq/data/store-b/commitlog
#消费队列存储路径存储路径
storePathConsumerQueue=/data/rocketmq/data/store-b/consumequeue
#消息索引存储路径
storePathIndex=/data/rocketmq/data/store-b/index
#checkpoint 文件存储路径
storeCheckpoint=/data/rocketmq/data/store-b/checkpoint
#abort 文件存储路径
abortFile=/data/rocketmq/data/store-b/abort
#commitLog每个文件的大小默认1G
mapedFileSizeCommitLog=1073741824
#ConsumeQueue每个文件默认存30W条，根据业务情况调整
mapedFileSizeConsumeQueue=300000
rocketmq-2配置master
[root@rocketmq-2 soft]# vim /data/rocketmq/conf/2m-2s-async/broker-b.properties
#所属集群名字
brokerClusterName=rocketmq-cluster
#broker名字，注意此处不同的配置文件填写的不一样 例如：在a.properties 文件中写 broker-a 在b.properties 文件中写 broker-b
brokerName=broker-b
#0 表示 Master，>0 表示 Slave
brokerId=0
#删除文件时间点，默认凌晨 4点
deleteWhen=04
#文件保留时间，默认 48 小时
fileReservedTime=120
#Broker 的角色，ASYNC_MASTER=异步复制Master，SYNC_MASTER=同步双写Master，SLAVE=slave节点
brokerRole=ASYNC_MASTER
#刷盘方式，ASYNC_FLUSH=异步刷盘，SYNC_FLUSH=同步刷盘
flushDiskType=SYNC_FLUSH
#Broker 对外服务的监听端口
listenPort=10911
#nameServer地址，这里nameserver是单台，如果nameserver是多台集群的话，就用分号分割（即namesrvAddr=ip1:port1;ip2:port2;ip3:port3）
namesrvAddr=192.168.233.128:9876;192.168.233.129:9876
#每个topic对应队列的数量，默认为4，实际应参考consumer实例的数量，值过小不利于consumer负载均衡
defaultTopicQueueNums=8
#是否允许 Broker 自动创建Topic，生产建议关闭
autoCreateTopicEnable=true
#是否允许 Broker 自动创建订阅组，生产建议关闭
autoCreateSubscriptionGroup=true
#设置BrokerIP
brokerIP1=192.168.233.129
#存储路径
storePathRootDir=/data/rocketmq/data/store-b
#commitLog 存储路径
storePathCommitLog=/data/rocketmq/data/store-b/commitlog
#消费队列存储路径存储路径
storePathConsumerQueue=/data/rocketmq/data/store-b/consumequeue
#消息索引存储路径
storePathIndex=/data/rocketmq/data/store-b/index
#checkpoint 文件存储路径
storeCheckpoint=/data/rocketmq/data/store-b/checkpoint
#abort 文件存储路径
abortFile=/data/rocketmq/data/store-b/abort
#commitLog每个文件的大小默认1G
mapedFileSizeCommitLog=1073741824
#ConsumeQueue每个文件默认存30W条，根据业务情况调整
mapedFileSizeConsumeQueue=300000
rocketmq-2配置slave
[root@rocketmq-2 soft]# vim /data/rocketmq/conf/2m-2s-async/broker-a-s.properties
#所属集群名字
brokerClusterName=rocketmq-cluster
#broker名字，注意此处不同的配置文件填写的不一样 例如：在a.properties 文件中写 broker-a 在b.properties 文件中写 broker-b
brokerName=broker-a
#0 表示 Master，>0 表示 Slave
brokerId=1
#删除文件时间点，默认凌晨 4点
deleteWhen=04
#文件保留时间，默认 48 小时
fileReservedTime=120
#Broker 的角色，ASYNC_MASTER=异步复制Master，SYNC_MASTER=同步双写Master，SLAVE=slave节点
brokerRole=SLAVE
#刷盘方式，ASYNC_FLUSH=异步刷盘，SYNC_FLUSH=同步刷盘
flushDiskType=SYNC_FLUSH
#Broker 对外服务的监听端口
listenPort=11011
#nameServer地址，这里nameserver是单台，如果nameserver是多台集群的话，就用分号分割（即namesrvAddr=ip1:port1;ip2:port2;ip3:port3）
namesrvAddr=192.168.233.128:9876;192.168.233.129:9876
#每个topic对应队列的数量，默认为4，实际应参考consumer实例的数量，值过小不利于consumer负载均衡
defaultTopicQueueNums=8
#是否允许 Broker 自动创建Topic，生产建议关闭
autoCreateTopicEnable=true
#是否允许 Broker 自动创建订阅组，生产建议关闭
autoCreateSubscriptionGroup=true
#设置BrokerIP
brokerIP1=192.168.233.129
#存储路径
storePathRootDir=/data/rocketmq/data/store-a
#commitLog 存储路径
storePathCommitLog=/data/rocketmq/data/store-a/commitlog
#消费队列存储路径存储路径
storePathConsumerQueue=/data/rocketmq/data/store-a/consumequeue
#消息索引存储路径
storePathIndex=/data/rocketmq/data/store-a/index
#checkpoint 文件存储路径
storeCheckpoint=/data/rocketmq/data/store-a/checkpoint
#abort 文件存储路径
abortFile=/data/rocketmq/data/store-a/abort
#commitLog每个文件的大小默认1G
mapedFileSizeCommitLog=1073741824
#ConsumeQueue每个文件默认存30W条，根据业务情况调整
mapedFileSizeConsumeQueue=300000
启动broker
[root@rocketmq-1 rocketmq]# nohup sh bin/mqbroker -c conf/2m-2s-async/broker-a.properties &
[root@rocketmq-2 rocketmq]# nohup sh bin/mqbroker -c conf/2m-2s-async/broker-b.properties &
[root@rocketmq-2 rocketmq]# nohup sh bin/mqbroker -c conf/2m-2s-async/broker-a-s.properties &
[root@rocketmq-1 rocketmq]# nohup sh bin/mqbroker -c conf/2m-2s-async/broker-b-s.properties &
注意：内存不足
原因：broker的java启动内存参数配置的是8g，请根据服务器实际资源做调整。
解决方案：修改内存参数，在bin/runbroker.sh文件中
JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m -Xmn512m"
验证
export NAMESRV_ADDR=localhost:9876
启动生产者
sh /data/rocketmq/bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
启动消费者
sh /data/rocketmq/bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
查看集群状态
[root@rocketmq-1 ~]# sh /data/rocketmq/bin/mqadmin clusterList -n "192.168.233.128:9876;192.168.233.129:9876"
RocketMQLog:WARN No appenders could be found for logger (io.netty.util.internal.PlatformDependent0).
RocketMQLog:WARN Please initialize the logger system properly.
#Cluster Name #Broker Name #BID #Addr #Version #InTPS(LOAD) #OutTPS(LOAD) #PCWait(ms) #Hour #SPACE
rocketmq-cluster broker-a 0 192.168.233.128:10911 V4_7_0 0.00(0,0ms) 0.00(0,0ms) 0 472132.10 0.0243
rocketmq-cluster broker-a 1 192.168.233.129:11011 V4_7_0 0.00(0,0ms) 0.00(0,0ms) 0 472132.10 0.0229
rocketmq-cluster broker-b 0 192.168.233.129:10911 V4_7_0 0.00(0,0ms) 0.00(0,0ms) 0 472132.10 0.0229
rocketmq-cluster broker-b 1 192.168.233.128:11011 V4_7_0 0.00(0,0ms) 0.00(0,0ms) 0 472132.10 0.0243
关闭服务
先关闭Broker、再关闭NameServer，服务启动的时候正好相反。
[root@rocketmq-1 ~]# sh /data/rocketmq/bin/mqshutdown broker
[root@rocketmq-1 ~]# sh /data/rocketmq/bin/mqshutdown namesrv
2.3 同步模式
rocketmq-1配置master
[root@rocketmq-1 ~]# vim /data/rocketmq/conf/2m-2s-sync/broker-a.properties
#所属集群名字
brokerClusterName=rocketmq-cluster
#broker名字，注意此处不同的配置文件填写的不一样 例如：在a.properties 文件中写 broker-a 在b.properties 文件中写 broker-b
brokerName=broker-a
#0 表示 Master，>0 表示 Slave
brokerId=0
#删除文件时间点，默认凌晨 4点
deleteWhen=04
#文件保留时间，默认 48 小时
fileReservedTime=120
#Broker 的角色，ASYNC_MASTER=异步复制Master，SYNC_MASTER=同步双写Master，SLAVE=slave节点
brokerRole=SYNC_MASTER
#刷盘方式，ASYNC_FLUSH=异步刷盘，SYNC_FLUSH=同步刷盘
flushDiskType=SYNC_FLUSH
#Broker 对外服务的监听端口
listenPort=10911
#nameServer地址，这里nameserver是单台，如果nameserver是多台集群的话，就用分号分割（即namesrvAddr=ip1:port1;ip2:port2;ip3:port3）
namesrvAddr=192.168.233.128:9876;192.168.233.129:9876
#每个topic对应队列的数量，默认为4，实际应参考consumer实例的数量，值过小不利于consumer负载均衡
defaultTopicQueueNums=8
#是否允许 Broker 自动创建Topic，生产建议关闭
autoCreateTopicEnable=true
#是否允许 Broker 自动创建订阅组，生产建议关闭
autoCreateSubscriptionGroup=true
#设置BrokerIP
brokerIP1=192.168.233.128
#存储路径
storePathRootDir=/data/rocketmq/data/store-a
#commitLog 存储路径
storePathCommitLog=/data/rocketmq/data/store-a/commitlog
#消费队列存储路径存储路径
storePathConsumerQueue=/data/rocketmq/data/store-a/consumequeue
#消息索引存储路径
storePathIndex=/data/rocketmq/data/store-a/index
#checkpoint 文件存储路径
storeCheckpoint=/data/rocketmq/data/store-a/checkpoint
#abort 文件存储路径
abortFile=/data/rocketmq/data/store-a/abort
#commitLog每个文件的大小默认1G
mapedFileSizeCommitLog=1073741824
#ConsumeQueue每个文件默认存30W条，根据业务情况调整
mapedFileSizeConsumeQueue=300000
rocketmq-1配置slave
[root@rocketmq-1 ~]# vim /data/rocketmq/conf/2m-2s-sync/broker-b-s.properties
#所属集群名字
brokerClusterName=rocketmq-cluster
#broker名字，注意此处不同的配置文件填写的不一样 例如：在a.properties 文件中写 broker-a 在b.properties 文件中写 broker-b
brokerName=broker-b
#0 表示 Master，>0 表示 Slave
brokerId=1
#删除文件时间点，默认凌晨 4点
deleteWhen=04
#文件保留时间，默认 48 小时
fileReservedTime=120
#Broker 的角色，ASYNC_MASTER=异步复制Master，SYNC_MASTER=同步双写Master，SLAVE=slave节点
brokerRole=SLAVE
#刷盘方式，ASYNC_FLUSH=异步刷盘，SYNC_FLUSH=同步刷盘
flushDiskType=SYNC_FLUSH
#Broker 对外服务的监听端口
listenPort=11011
#nameServer地址，这里nameserver是单台，如果nameserver是多台集群的话，就用分号分割（即namesrvAddr=ip1:port1;ip2:port2;ip3:port3）
namesrvAddr=192.168.233.128:9876;192.168.233.129:9876
#每个topic对应队列的数量，默认为4，实际应参考consumer实例的数量，值过小不利于consumer负载均衡
defaultTopicQueueNums=8
#是否允许 Broker 自动创建Topic，生产建议关闭
autoCreateTopicEnable=true
#是否允许 Broker 自动创建订阅组，生产建议关闭
autoCreateSubscriptionGroup=true
#设置BrokerIP
brokerIP1=192.168.233.128
#存储路径
storePathRootDir=/data/rocketmq/data/store-b
#commitLog 存储路径
storePathCommitLog=/data/rocketmq/data/store-b/commitlog
#消费队列存储路径存储路径
storePathConsumerQueue=/data/rocketmq/data/store-b/consumequeue
#消息索引存储路径
storePathIndex=/data/rocketmq/data/store-b/index
#checkpoint 文件存储路径
storeCheckpoint=/data/rocketmq/data/store-b/checkpoint
#abort 文件存储路径
abortFile=/data/rocketmq/data/store-b/abort
#commitLog每个文件的大小默认1G
mapedFileSizeCommitLog=1073741824
#ConsumeQueue每个文件默认存30W条，根据业务情况调整
mapedFileSizeConsumeQueue=300000
rocketmq-2配置master
[root@rocketmq-2 soft]# vim /data/rocketmq/conf/2m-2s-sync/broker-b.properties
#所属集群名字
brokerClusterName=rocketmq-cluster
#broker名字，注意此处不同的配置文件填写的不一样 例如：在a.properties 文件中写 broker-a 在b.properties 文件中写 broker-b
brokerName=broker-b
#0 表示 Master，>0 表示 Slave
brokerId=0
#删除文件时间点，默认凌晨 4点
deleteWhen=04
#文件保留时间，默认 48 小时
fileReservedTime=120
#Broker 的角色，ASYNC_MASTER=异步复制Master，SYNC_MASTER=同步双写Master，SLAVE=slave节点
brokerRole=SYNC_MASTER
#刷盘方式，ASYNC_FLUSH=异步刷盘，SYNC_FLUSH=同步刷盘
flushDiskType=SYNC_FLUSH
#Broker 对外服务的监听端口
listenPort=10911
#nameServer地址，这里nameserver是单台，如果nameserver是多台集群的话，就用分号分割（即namesrvAddr=ip1:port1;ip2:port2;ip3:port3）
namesrvAddr=192.168.233.128:9876;192.168.233.129:9876
#每个topic对应队列的数量，默认为4，实际应参考consumer实例的数量，值过小不利于consumer负载均衡
defaultTopicQueueNums=8
#是否允许 Broker 自动创建Topic，生产建议关闭
autoCreateTopicEnable=true
#是否允许 Broker 自动创建订阅组，生产建议关闭
autoCreateSubscriptionGroup=true
#设置BrokerIP
brokerIP1=192.168.233.129
#存储路径
storePathRootDir=/data/rocketmq/data/store-b
#commitLog 存储路径
storePathCommitLog=/data/rocketmq/data/store-b/commitlog
#消费队列存储路径存储路径
storePathConsumerQueue=/data/rocketmq/data/store-b/consumequeue
#消息索引存储路径
storePathIndex=/data/rocketmq/data/store-b/index
#checkpoint 文件存储路径
storeCheckpoint=/data/rocketmq/data/store-b/checkpoint
#abort 文件存储路径
abortFile=/data/rocketmq/data/store-b/abort
#commitLog每个文件的大小默认1G
mapedFileSizeCommitLog=1073741824
#ConsumeQueue每个文件默认存30W条，根据业务情况调整
mapedFileSizeConsumeQueue=300000
rocketmq-2配置slave
[root@rocketmq-2 soft]# vim /data/rocketmq/conf/2m-2s-async/broker-a-s.properties
#所属集群名字
brokerClusterName=rocketmq-cluster
#broker名字，注意此处不同的配置文件填写的不一样 例如：在a.properties 文件中写 broker-a 在b.properties 文件中写 broker-b
brokerName=broker-a
#0 表示 Master，>0 表示 Slave
brokerId=1
#删除文件时间点，默认凌晨 4点
deleteWhen=04
#文件保留时间，默认 48 小时
fileReservedTime=120
#Broker 的角色，ASYNC_MASTER=异步复制Master，SYNC_MASTER=同步双写Master，SLAVE=slave节点
brokerRole=SLAVE
#刷盘方式，ASYNC_FLUSH=异步刷盘，SYNC_FLUSH=同步刷盘
flushDiskType=SYNC_FLUSH
#Broker 对外服务的监听端口
listenPort=11011
#nameServer地址，这里nameserver是单台，如果nameserver是多台集群的话，就用分号分割（即namesrvAddr=ip1:port1;ip2:port2;ip3:port3）
namesrvAddr=192.168.233.128:9876;192.168.233.129:9876
#每个topic对应队列的数量，默认为4，实际应参考consumer实例的数量，值过小不利于consumer负载均衡
defaultTopicQueueNums=8
#是否允许 Broker 自动创建Topic，生产建议关闭
autoCreateTopicEnable=true
#是否允许 Broker 自动创建订阅组，生产建议关闭
autoCreateSubscriptionGroup=true
#设置BrokerIP
brokerIP1=192.168.233.129
#存储路径
storePathRootDir=/data/rocketmq/data/store-a
#commitLog 存储路径
storePathCommitLog=/data/rocketmq/data/store-a/commitlog
#消费队列存储路径存储路径
storePathConsumerQueue=/data/rocketmq/data/store-a/consumequeue
#消息索引存储路径
storePathIndex=/data/rocketmq/data/store-a/index
#checkpoint 文件存储路径
storeCheckpoint=/data/rocketmq/data/store-a/checkpoint
#abort 文件存储路径
abortFile=/data/rocketmq/data/store-a/abort
#commitLog每个文件的大小默认1G
mapedFileSizeCommitLog=1073741824
#ConsumeQueue每个文件默认存30W条，根据业务情况调整
mapedFileSizeConsumeQueue=300000
启动broker
[root@rocketmq-1 rocketmq]# nohup sh bin/mqbroker -c conf/2m-2s-sync/broker-a.properties &
[root@rocketmq-2 rocketmq]# nohup sh bin/mqbroker -c conf/2m-2s-sync/broker-b.properties &
[root@rocketmq-2 rocketmq]# nohup sh bin/mqbroker -c conf/2m-2s-sync/broker-a-s.properties &
[root@rocketmq-1 rocketmq]# nohup sh bin/mqbroker -c conf/2m-2s-sync/broker-b-s.properties &
注意：内存不足
原因：broker的java启动内存参数配置的是8g，请根据服务器实际资源做调整。
解决方案：修改内存参数，在bin/runbroker.sh文件中
JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m -Xmn512m"
验证
export NAMESRV_ADDR=localhost:9876
启动生产者
sh /data/rocketmq/bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
启动消费者
sh /data/rocketmq/bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
查看集群状态
[root@rocketmq-1 rocketmq]# sh /data/rocketmq/bin/mqadmin clusterList -n "192.168.233.128:9876;192.168.233.129:9876"
#Cluster Name #Broker Name #BID #Addr #Version #InTPS(LOAD) #OutTPS(LOAD) #PCWait(ms) #Hour #SPACE
rocketmq-cluster broker-a 0 192.168.233.128:10911 V4_9_6 0.00(0,0ms) 0.00(0,0ms) 0 472133.40 0.0300
rocketmq-cluster broker-a 1 192.168.233.129:11011 V4_9_6 0.00(0,0ms) 0.00(0,0ms) 0 472133.40 0.0300
rocketmq-cluster broker-b 0 192.168.233.129:10911 V4_9_6 0.00(0,0ms) 0.00(0,0ms) 0 472133.40 0.0300
rocketmq-cluster broker-b 1 192.168.233.128:11011 V4_9_6 0.00(0,0ms) 0.00(0,0ms) 0 472133.40 0.0300
关闭服务
先关闭Broker、再关闭NameServer，服务启动的时候正好相反。
[root@rocketmq-1 ~]# sh /data/rocketmq/bin/mqshutdown broker
[root@rocketmq-1 ~]# sh /data/rocketmq/bin/mqshutdown namesrv
四、部署Maven
1. 下载
wget https://dlcdn.apache.org/maven/maven-3/3.9.5/binaries/apache-maven-3.9.5-bin.tar.gz
2. 解压
tar xf apache-maven-3.9.5-bin.tar.gz -C /data
mv /data/apache-maven-3.9.5 /data/apache-maven
3. 配置环境变量
vim /etc/profile
# apache-maven
export MAVEN_HOME=/data/apache-maven
export PATH=$PATH:$MAVEN_HOME/bin
4. 执行并验证
source /etc/profile
mvn -v
五、部署console控制台
1. 上传安装包rocketmq-externals-master.zip
2. 解压
unzip rocketmq-externals-master.zip
3. rocketmq-console目录
cd rocketmq-externals-master/rocketmq-console/
4. 打包
mvn clean package -Dmaven.test.skip=true
5. 启动rocketmq-console
java -jar target/rocketmq-console-ng-1.0.0.jar --rocketmq.config.namesrvAddr='192.168.233.128:9876;192.168.233.129:9876' &
6. 验证
浏览器访问IP:8080