当前位置：首页 > article >正文

Linux环境部署RocketMQ单节点以及双主双从集群环境

article 2024/12/5 2:14:25

本文目录

- 1.1 单机部署
- - 下载地址
  - 解压
  - 目录介绍
  - 启动NameServer
  - 启动Broker
  - 问题描述
  - 测试RocketMQ
  - - 发送消息
    - 接收消息
  - 停止服务
- 1.2 集群部署
- - 角色介绍
  - 集群搭建模式
  - - 集群特点
    - 群模式
    - - 1）单Master模式
      - 2）多Master模式
      - 3）多Master多Slave模式（异步）
      - 4）多Master多Slave模式（同步）
  - 双主双从集群搭建
  - - 总体架构
    - 集群工作流程
    - 服务器环境
    - 配置Host信息
    - 火墙配置
    - 环境变量配置
    - 创建消息存储路径
    - broker配置文件
    - aster1
    - 2）slave2
    - 3）master2
    - 4）slave1
    - 修改启动脚本文件
    - - 1）runbroker.sh
      - 2）runserver.sh
    - 服务启动
    - - 启动NameServe集群
      - 启动Broker集群
    - 查看进程状态
    - 查看日志
  - MQ控制台管理工具

1.1 单机部署

下载地址

https://dist.apache.org/repos/dist/release/rocketmq/5.2.0/rocketmq-all-5.2.0-bin-release.zip

# Download release from the Apache mirror
$ wget https://dist.apache.org/repos/dist/release/rocketmq/5.2.0/rocketmq-all-5.2.0-bin-release.zip

解压

解压到安装目录

# Unpack the release
$ unzip rocketmq-all-5.2.0-bin-release.zip

目录介绍

bin：启动脚本，包括shell脚本和CMD脚本
conf：实例配置文件，包括broker配置文件、logback配置文件等
lib：依赖jar包，包括Netty、commons-lang、FastJSON等

启动NameServer

### start Name Server
$ nohup sh bin/mqnamesrv &

### check whether Name Server is successfully started
$ tail -f ~/logs/rocketmqlogs/namesrv.log
The Name Server boot success...

启动Broker

在 conf 目录下，RocketMQ 提供了多种 Broker 的配置文件：

broker.conf ：单主，异步刷盘。
2m/ ：双主，异步刷盘。
2m-2s-async/ ：两主两从，异步复制，异步刷盘。
2m-2s-sync/ ：两主两从，同步复制，异步刷盘。
dledger/ ：Dledger 集群，至少三节点。

这里，我们只启动一个 RocketMQ Broker 服务，所以使用 broker.conf 配置文件。命令行操作如下：

### start Broker
$ nohup sh bin/mqbroker -c conf/broker.conf -n localhost:9876 &

### check whether Broker is successfully started, eg: Broker's IP is 192.168.1.2, Broker's name is broker-a
$ tail -f ~/logs/rocketmqlogs/broker.log
The broker[broker-a, 192.169.1.2:10911] boot success...

问题描述

RocketMQ默认的虚拟机内存较大，启动Broker如果因为内存不足失败，需要编辑如下两个配置文件，修改JVM内存大小

# 编辑runbroker.sh和runserver.sh修改默认JVM大小
vi runbroker.sh
vi runserver.sh

# 参考设置：

```JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=128m  -XX:MaxMetaspaceSize=320m"```

测试RocketMQ

发送消息

通过使用 bin/tools.sh 工具类，实现测试发送消息。命令行操作如下：

# 1.设置环境变量
export NAMESRV_ADDR=localhost:9876
# 2.使用安装包的Demo发送消息
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

接收消息

通过使用 bin/tools.sh 工具类，实现测试消费消息。命令行操作如下：

# 设置 Namesrv 服务器的地址
export NAMESRV_ADDR=127.0.0.1:9876

# 执行消费者 Consumer 消费测试消息
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

停止服务

# 1.关闭NameServer
sh bin/mqshutdown namesrv
# 2.关闭Broker
sh bin/mqshutdown broker

1.2 集群部署

角色介绍

Producer：消息的发送者；举例：发信者
Consumer：消息接收者；举例：收信者
Broker：暂存和传输消息；举例：邮局
NameServer：管理Broker；举例：各个邮局的管理机构
Topic：区分消息的种类；一个发送者可以发送消息给一个或者多个Topic；一个消息的接收者可以订阅一个或者多个Topic消息
Message Queue：相当于是Topic的分区；用于并行发送和接收消息

集群搭建模式

集群特点

NameServer是一个几乎无状态节点，可集群部署，节点之间无任何信息同步。
Broker部署相对复杂，Broker分为Master与Slave，一个Master可以对应多个Slave，但是一个Slave只能对应一个Master，Master与Slave的对应关系通过指定相同的BrokerName，不同的BrokerId来定义，BrokerId为0表示Master，非0表示Slave。Master也可以部署多个。每个Broker与NameServer集群中的所有节点建立长连接，定时注册Topic信息到所有NameServer。
Producer与NameServer集群中的其中一个节点（随机选择）建立长连接，定期从NameServer取Topic路由信息，并向提供Topic服务的Master建立长连接，且定时向Master发送心跳。Producer完全无状态，可集群部署。
Consumer与NameServer集群中的其中一个节点（随机选择）建立长连接，定期从NameServer取Topic路由信息，并向提供Topic服务的Master、Slave建立长连接，且定时向Master、Slave发送心跳。Consumer既可以从Master订阅消息，也可以从Slave订阅消息，订阅规则由Broker配置决定。

群模式

1）单Master模式

这种方式风险较大，一旦Broker重启或者宕机时，会导致整个服务不可用。不建议线上环境使用,可以用于本地测试。

2）多Master模式

一个集群无Slave，全是Master，例如2个Master或者3个Master，这种模式的优缺点如下：

优点：配置简单，单个Master宕机或重启维护对应用无影响，在磁盘配置为RAID10时，即使机器宕机不可恢复情况下，由于RAID10磁盘非常可靠，消息也不会丢（异步刷盘丢失少量消息，同步刷盘一条不丢），性能最高；
缺点：单台机器宕机期间，这台机器上未被消费的消息在机器恢复之前不可订阅，消息实时性会受到影响。

3）多Master多Slave模式（异步）

每个Master配置一个Slave，有多对Master-Slave，HA采用异步复制方式，主备有短暂消息延迟（毫秒级），这种模式的优缺点如下：

优点：即使磁盘损坏，消息丢失的非常少，且消息实时性不会受影响，同时Master宕机后，消费者仍然可以从Slave消费，而且此过程对应用透明，不需要人工干预，性能同多Master模式几乎一样；
缺点：Master宕机，磁盘损坏情况下会丢失少量消息。

4）多Master多Slave模式（同步）

每个Master配置一个Slave，有多对Master-Slave，HA采用同步双写方式，即只有主备都写成功，才向应用返回成功，这种模式的优缺点如下：

优点：数据与服务都无单点故障，Master宕机情况下，消息无延迟，服务可用性与数据可用性都非常高；
缺点：性能比异步复制模式略低（大约低10%左右），发送单个消息的RT会略高，且目前版本在主节点宕机后，备机不能自动切换为主机。

双主双从集群搭建

总体架构

消息高可用采用2m-2s（同步双写）方式

集群工作流程

启动NameServer，NameServer起来后监听端口，等待Broker、Producer、Consumer连上来，相当于一个路由控制中心。
Broker启动，跟所有的NameServer保持长连接，定时发送心跳包。心跳包中包含当前Broker信息(IP+端口等)以及存储所有Topic信息。注册成功后，NameServer集群中就有Topic跟Broker的映射关系。
收发消息前，先创建Topic，创建Topic时需要指定该Topic要存储在哪些Broker上，也可以在发送消息时自动创建Topic。
Producer发送消息，启动时先跟NameServer集群中的其中一台建立长连接，并从NameServer中获取当前发送的Topic存在哪些Broker上，轮询从队列列表中选择一个队列，然后与队列所在的Broker建立长连接从而向Broker发消息。
Consumer跟Producer类似，跟其中一台NameServer建立长连接，获取当前订阅Topic存在哪些Broker上，然后直接跟Broker建立连接通道，开始消费消息。

服务器环境

序号	IP	角色	架构模式
1	192.168.83.137	nameserver、brokerserver	Master1、Slave2
2	192.168.83.138	nameserver、brokerserver	Master2、Slave1

配置Host信息

vim /etc/hosts

配置如下:

# nameserver
192.168.83.137 rocketmq-nameserver1
192.168.83.138 rocketmq-nameserver2
# broker
192.168.83.137 rocketmq-master1
192.168.83.137 rocketmq-slave2
192.168.83.138 rocketmq-master2
192.168.83.138 rocketmq-slave1

配置完成后, 重启网卡

systemctl restart network

火墙配置

宿主机需要远程访问虚拟机的rocketmq服务和web服务，需要开放相关的端口号，简单粗暴的方式是直接关闭防火墙

# 关闭防火墙
systemctl stop firewalld.service 
# 查看防火墙的状态
firewall-cmd --state 
# 禁止firewall开机启动
systemctl disable firewalld.service

或者为了安全，只开放特定的端口号，RocketMQ默认使用3个端口：9876 、10911 、11011 。如果防火墙没有关闭的话，那么防火墙就必须开放这些端口：

nameserver 默认使用 9876 端口
master 默认使用 10911 端口
slave 默认使用11011 端口

执行以下命令：

# 开放name server默认端口
firewall-cmd --remove-port=9876/tcp --permanent
# 开放master默认端口
firewall-cmd --remove-port=10911/tcp --permanent
# 开放slave默认端口 (当前集群模式可不开启)
firewall-cmd --remove-port=11011/tcp --permanent 
# 重启防火墙
firewall-cmd --reload

环境变量配置

vim /etc/profile

在profile文件的末尾加入如下命令

#set rocketmq
ROCKETMQ_HOME=/soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release
PATH=$PATH:$ROCKETMQ_HOME/bin
export ROCKETMQ_HOME PATH

输入:wq! 保存并退出，并使得配置立刻生效：

source /etc/profile

创建消息存储路径

#主节点存储路径
mkdir /soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/store
mkdir /soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/store/commitlog
mkdir /soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/store/consumequeue
mkdir /soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/store/index

#从节点存储路径
mkdir /soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/store-s
mkdir /soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/store-s/commitlog
mkdir /soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/store-s/consumequeue
mkdir /soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/store-s/index

broker配置文件

aster1

服务器：192.168.83.137

vi /soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/conf/2m-2s-sync/broker-a.properties

修改配置如下：

#所属集群名字
brokerClusterName=rocketmq-cluster
#broker名字，注意此处不同的配置文件填写的不一样
brokerName=broker-a
#0 表示 Master，>0 表示 Slave
brokerId=0
#nameServer地址，分号分割
namesrvAddr=rocketmq-nameserver1:9876;rocketmq-nameserver2:9876
#在发送消息时，自动创建服务器不存在的topic，默认创建的队列数
defaultTopicQueueNums=4
#是否允许 Broker 自动创建Topic，建议线下开启，线上关闭
autoCreateTopicEnable=true
#是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭
autoCreateSubscriptionGroup=true
#Broker 对外服务的监听端口
listenPort=10911
#删除文件时间点，默认凌晨 4点
deleteWhen=04
#文件保留时间，默认 48 小时
fileReservedTime=120
#commitLog每个文件的大小默认1G
mapedFileSizeCommitLog=1073741824
#ConsumeQueue每个文件默认存30W条，根据业务情况调整
mapedFileSizeConsumeQueue=300000
#destroyMapedFileIntervalForcibly=120000
#redeleteHangedFileInterval=120000
#检测物理文件磁盘空间
diskMaxUsedSpaceRatio=88
#存储路径
storePathRootDir=/soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/store
#commitLog 存储路径
storePathCommitLog=/soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/store/commitlog
#消费队列存储路径存储路径
storePathConsumeQueue=/soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/store/consumequeue
#消息索引存储路径
storePathIndex=/soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/store/index
#checkpoint 文件存储路径
storeCheckpoint=/soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/store/checkpoint
#abort 文件存储路径
abortFile=/soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/store/abort
#限制的消息大小
maxMessageSize=65536
#flushCommitLogLeastPages=4
#flushConsumeQueueLeastPages=2
#flushCommitLogThoroughInterval=10000
#flushConsumeQueueThoroughInterval=60000
#Broker 的角色
#- ASYNC_MASTER 异步复制Master
#- SYNC_MASTER 同步双写Master
#- SLAVE
brokerRole=SYNC_MASTER
#刷盘方式
#- ASYNC_FLUSH 异步刷盘
#- SYNC_FLUSH 同步刷盘
flushDiskType=SYNC_FLUSH
#checkTransactionMessageEnable=false
#发消息线程池数量
#sendMessageThreadPoolNums=128
#拉消息线程池数量
#pullMessageThreadPoolNums=128

2）slave2

服务器：192.168.83.137

vi /soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/conf/2m-2s-sync/broker-b-s.properties

修改配置如下：

#所属集群名字
brokerClusterName=rocketmq-cluster
#broker名字，注意此处不同的配置文件填写的不一样
brokerName=broker-b
#0 表示 Master，>0 表示 Slave
brokerId=1
#nameServer地址，分号分割
namesrvAddr=rocketmq-nameserver1:9876;rocketmq-nameserver2:9876
#在发送消息时，自动创建服务器不存在的topic，默认创建的队列数
defaultTopicQueueNums=4
#是否允许 Broker 自动创建Topic，建议线下开启，线上关闭
autoCreateTopicEnable=true
#是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭
autoCreateSubscriptionGroup=true
#Broker 对外服务的监听端口
listenPort=11011
#删除文件时间点，默认凌晨 4点
deleteWhen=04
#文件保留时间，默认 48 小时
fileReservedTime=120
#commitLog每个文件的大小默认1G
mapedFileSizeCommitLog=1073741824
#ConsumeQueue每个文件默认存30W条，根据业务情况调整
mapedFileSizeConsumeQueue=300000
#destroyMapedFileIntervalForcibly=120000
#redeleteHangedFileInterval=120000
#检测物理文件磁盘空间
diskMaxUsedSpaceRatio=88
#存储路径
storePathRootDir=/soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/store
#commitLog 存储路径
storePathCommitLog=/soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/store/commitlog
#消费队列存储路径存储路径
storePathConsumeQueue=/soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/store/consumequeue
#消息索引存储路径
storePathIndex=/soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/store/index
#checkpoint 文件存储路径
storeCheckpoint=/soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/store/checkpoint
#abort 文件存储路径
abortFile=/soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/store/abort
#限制的消息大小
maxMessageSize=65536
#flushCommitLogLeastPages=4
#flushConsumeQueueLeastPages=2
#flushCommitLogThoroughInterval=10000
#flushConsumeQueueThoroughInterval=60000
#Broker 的角色
#- ASYNC_MASTER 异步复制Master
#- SYNC_MASTER 同步双写Master
#- SLAVE
brokerRole=SLAVE
#刷盘方式
#- ASYNC_FLUSH 异步刷盘
#- SYNC_FLUSH 同步刷盘
flushDiskType=ASYNC_FLUSH
#checkTransactionMessageEnable=false
#发消息线程池数量
#sendMessageThreadPoolNums=128
#拉消息线程池数量
#pullMessageThreadPoolNums=128

3）master2

服务器：192.168.83.138

vi /soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/conf/2m-2s-sync/broker-b.properties

修改配置如下：

#所属集群名字
brokerClusterName=rocketmq-cluster
#broker名字，注意此处不同的配置文件填写的不一样
brokerName=broker-b
#0 表示 Master，>0 表示 Slave
brokerId=0
#nameServer地址，分号分割
namesrvAddr=rocketmq-nameserver1:9876;rocketmq-nameserver2:9876
#在发送消息时，自动创建服务器不存在的topic，默认创建的队列数
defaultTopicQueueNums=4
#是否允许 Broker 自动创建Topic，建议线下开启，线上关闭
autoCreateTopicEnable=true
#是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭
autoCreateSubscriptionGroup=true
#Broker 对外服务的监听端口
listenPort=10911
#删除文件时间点，默认凌晨 4点
deleteWhen=04
#文件保留时间，默认 48 小时
fileReservedTime=120
#commitLog每个文件的大小默认1G
mapedFileSizeCommitLog=1073741824
#ConsumeQueue每个文件默认存30W条，根据业务情况调整
mapedFileSizeConsumeQueue=300000
#destroyMapedFileIntervalForcibly=120000
#redeleteHangedFileInterval=120000
#检测物理文件磁盘空间
diskMaxUsedSpaceRatio=88
#存储路径
storePathRootDir=/soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/store
#commitLog 存储路径
storePathCommitLog=/soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/store/commitlog
#消费队列存储路径存储路径
storePathConsumeQueue=/soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/store/consumequeue
#消息索引存储路径
storePathIndex=/soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/store/index
#checkpoint 文件存储路径
storeCheckpoint=/soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/store/checkpoint
#abort 文件存储路径
abortFile=/soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/store/abort
#限制的消息大小
maxMessageSize=65536
#flushCommitLogLeastPages=4
#flushConsumeQueueLeastPages=2
#flushCommitLogThoroughInterval=10000
#flushConsumeQueueThoroughInterval=60000
#Broker 的角色
#- ASYNC_MASTER 异步复制Master
#- SYNC_MASTER 同步双写Master
#- SLAVE
brokerRole=SYNC_MASTER
#刷盘方式
#- ASYNC_FLUSH 异步刷盘
#- SYNC_FLUSH 同步刷盘
flushDiskType=SYNC_FLUSH
#checkTransactionMessageEnable=false
#发消息线程池数量
#sendMessageThreadPoolNums=128
#拉消息线程池数量
#pullMessageThreadPoolNums=128

4）slave1

服务器：192.168.83.138

vi /soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/conf/2m-2s-sync/broker-a-s.properties

修改配置如下：

#所属集群名字
brokerClusterName=rocketmq-cluster
#broker名字，注意此处不同的配置文件填写的不一样
brokerName=broker-a
#0 表示 Master，>0 表示 Slave
brokerId=1
#nameServer地址，分号分割
namesrvAddr=rocketmq-nameserver1:9876;rocketmq-nameserver2:9876
#在发送消息时，自动创建服务器不存在的topic，默认创建的队列数
defaultTopicQueueNums=4
#是否允许 Broker 自动创建Topic，建议线下开启，线上关闭
autoCreateTopicEnable=true
#是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭
autoCreateSubscriptionGroup=true
#Broker 对外服务的监听端口
listenPort=11011
#删除文件时间点，默认凌晨 4点
deleteWhen=04
#文件保留时间，默认 48 小时
fileReservedTime=120
#commitLog每个文件的大小默认1G
mapedFileSizeCommitLog=1073741824
#ConsumeQueue每个文件默认存30W条，根据业务情况调整
mapedFileSizeConsumeQueue=300000
#destroyMapedFileIntervalForcibly=120000
#redeleteHangedFileInterval=120000
#检测物理文件磁盘空间
diskMaxUsedSpaceRatio=88
#存储路径
storePathRootDir=/soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/store
#commitLog 存储路径
storePathCommitLog=/soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/store/commitlog
#消费队列存储路径存储路径
storePathConsumeQueue=/soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/store/consumequeue
#消息索引存储路径
storePathIndex=/soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/store/index
#checkpoint 文件存储路径
storeCheckpoint=/soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/store/checkpoint
#abort 文件存储路径
abortFile=/soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/store/abort
#限制的消息大小
maxMessageSize=65536
#flushCommitLogLeastPages=4
#flushConsumeQueueLeastPages=2
#flushCommitLogThoroughInterval=10000
#flushConsumeQueueThoroughInterval=60000
#Broker 的角色
#- ASYNC_MASTER 异步复制Master
#- SYNC_MASTER 同步双写Master
#- SLAVE
brokerRole=SLAVE
#刷盘方式
#- ASYNC_FLUSH 异步刷盘
#- SYNC_FLUSH 同步刷盘
flushDiskType=ASYNC_FLUSH
#checkTransactionMessageEnable=false
#发消息线程池数量
#sendMessageThreadPoolNums=128
#拉消息线程池数量
#pullMessageThreadPoolNums=128

修改启动脚本文件

1）runbroker.sh

vi /usr/local/rocketmq/bin/runbroker.sh

需要根据内存大小进行适当的对JVM参数进行调整：

#===================================================
# 开发环境配置 JVM Configuration
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m"

2）runserver.sh

vim /usr/local/rocketmq/bin/runserver.sh

JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"

服务启动

启动NameServe集群

分别在192.168.83.137和192.168.83.138启动NameServer

cd /soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/bin
nohup sh mqnamesrv &

启动Broker集群

在192.168.83.137上启动master1和slave2

master1：

cd /soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/bin
nohup sh mqbroker -c /soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/conf/2m-2s-sync/broker-a.properties &

slave2：

cd /soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/bin
nohup sh mqbroker -c /soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/conf/2m-2s-sync/broker-b-s.properties &

在192.168.83.138上启动master2和slave2

master2

cd /soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/bin
nohup sh mqbroker -c /soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/conf/2m-2s-sync/broker-b.properties &

slave1

cd /soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/bin
nohup sh mqbroker -c /soft/rocketmq-5.2.0/rocketmq-all-5.2.0-bin-release/conf/2m-2s-sync/broker-a-s.properties &

查看进程状态

启动后通过JPS查看启动进程

查看日志

# 查看nameServer日志
tail -500f ~/logs/rocketmqlogs/namesrv.log
# 查看broker日志
tail -500f ~/logs/rocketmqlogs/broker.log

# 查询是否注册有topic
cat ~/logs/rocketmqlogs/broker.log  | grep topicName=DEMO-TOPIC-01

MQ控制台管理工具

RocketMQ有一个对其扩展的开源项目incubator-rocketmq-externals，这个项目中有一个子模块叫rocketmq-console，这个便是管理控制台项目了，先将incubator-rocketmq-externals拉到本地，因为我们需要自己对rocketmq-console进行编译打包运行。

git clone https://github.com/apache/rocketmq-externals
cd rocketmq-console
mvn clean package -Dmaven.test.skip=true

注意：打包前，修改 src/main/resources/application.properties 配置文件，通过设置 rocketmq.config.namesrvAddr 配置项，设置 RocketMQ Namesrv 的地址。

rocketmq.config.namesrvAddr=192.168.83.137:9876;192.168.83.138:9876

启动rocketmq-console：

java -jar rocketmq-console-ng-1.0.0.jar
nohup java -jar target/rocketmq-console-ng-1.0.1.jar &

查看日志：

tail -f nohup.out

启动成功后，我们就可以通过浏览器访问http://localhost:8080进入控制台界面了，如下图：

查看全文

http://www.kler.cn/a/422068.html

[go-redis]客户端的创建与配置说明

node.js @ffmpeg-installer/ffmpeg 桌面推流

使用CertD全自动申请和部署SSL证书至服务器

【Elasticsearch】04-RestAPI

基于python的汽车数据爬取数据分析与可视化

C++之异常智能指针其他

算法笔记：力扣146.LRU缓存

ubuntu无线网络共享到有线

在 Windows Server 2022 Datacenter 上配置 MySQL 8.0 的主从复制

vscode切换anaconda虚拟环境解释器不成功

无人机的计算机仿真模拟控制

【测试工具JMeter篇】JMeter性能测试入门级教程（六）：JMeter中实现参数化的几种方式

利用Python爬虫获取淘宝关键词接口的深入解析

LeetCode78：子集

unity与android拓展

量化交易系统开发-实时行情自动化交易-8.8.同花顺 SuperMind 平台

【Oracle11g SQL详解】子查询的分类与嵌套查询实例

Typora设置自动上传图片到图床

Linux查看系统基本信息

推荐文章：FLUI Framework——打造流畅的微软界面体验

Mysql外键约束与关联表操作

讯方智汇云校HarmonyOS培训，培养鸿蒙原生应用开发人才

TypeScript (一)运行环境配置，数据类型，可选类型，联合类型，type与interface，交叉类型，断言as，字面量类型，类型缩小

【青牛科技】超低功耗混合信号处理器由多种设备组成的流量计电路芯片——D8331

Linux之信号集基础

怎么自己创建一个网站? 开发语言首选 java，使用CMS网站内容管理系统是不错的选择

本文目录

1.1 单机部署

下载地址

解压

目录介绍

启动NameServer

启动Broker

问题描述

测试RocketMQ

发送消息

接收消息

停止服务

1.2 集群部署

角色介绍

集群搭建模式

集群特点

群模式

1）单Master模式

2）多Master模式

3）多Master多Slave模式（异步）

4）多Master多Slave模式（同步）

双主双从集群搭建

总体架构

集群工作流程

服务器环境

配置Host信息

火墙配置

环境变量配置

创建消息存储路径

broker配置文件

aster1

2）slave2

3）master2

4）slave1

修改启动脚本文件

1）runbroker.sh

2）runserver.sh

服务启动

启动NameServe集群

启动Broker集群

查看进程状态

查看日志

MQ控制台管理工具

相关文章：