【RocketMq实战第三篇】-RocketMq双机集群

╰+哭是因爲堅強的太久メ 2022-04-23 07:34 399阅读 0赞

## 前言 ##

由于我的电脑内存不够大，所以集群方式没办法做了，rocketmq很吃内存。本文我会把书上资料的步骤给大家贴出来。如有疑问请直接联系我，联系方式在最下方。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zODAwMzM4OQ_size_16_color_FFFFFF_t_70][]

## 正文 ##

启动 RocketMQ 的顺序是先启动 NameServer，再启动 Broker，这时候消 息队列已 经可以提供服务了，想发送消息就使用 Producer来发送，想接收消息 就使用 Consumer来接收 。 很多应用程序既要发送，又要接收，可以启动多个Producer 和 Consumer 来发送多种消息，同时接收多种消息 。

为了消除单点故障，增加可靠性或增大吞吐 量 ，可以在多台机器上部署多 个 NameServer 和 Broker，为每个 Broker部署一个或多个 Slave。

下图是RocketMQ各角色之间的关系

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zODAwMzM4OQ_size_16_color_FFFFFF_t_70 1][]

### 多机集群配置和部署 ###

用两台物理机，搭建 出双主 、 双从 、 无单点故 障的高可用 RocketMQ集群。 假设这两台物理机的 IP分别是 192.168.100.131 和 192.168 . 100.132 。

**启动多个 NameServer 和 Broker**

首先我们两台机器上都应有同样的rocketMQ服务，具体做法，包括安装启动，查看日志等点击链接：[【RocketMq实战第一篇】-RocketMq下载与安装][RocketMq_-RocketMq]

首先在这 两台机器上分别启动 NameServer ( nohup sh bin/mqnamesrv &), 这样我们就得到了 一个无单点的 NameServer服务， 服务地址是“ 192.168.100. 131:9876；192.168.100.132:9876”。

然后启动 Broker，每台机器上都要分别启动一个 Master 角色的 Broker 和一 个 Slave 角色的 Broker，并互为 主备 。 可以 基于 RocketMQ 自带的 示例配置 文件写自己的配置文件(示例配置文件在 conf/2m-2s-sync 目录下)。

**1)192.168.100.131 机器上 Master Broker 的配置文件:**

namesrvAddr=192.168.100. 131:9876;192.168.100.132:9876                          
                      brokerClusterName=DefaultCluster  
                      brokerName=broker-a  
                      brokerId=0  
                      deleteWhen=04  
                      fileReservedTime=48  
                      brokerRole=ASYNC\_MASTER  
                      flushDiskType=ASYNC\_FLUSH  
                      listenPort=10911  
                      storePathRootDir=/home/rocketmq/store-a

**2)192.168.100.132 机器上 Master Broker 的配置文件:**

namesrvAddr=192.168.100. 131:9876;192.168.100.132:9876                          
                      brokerClusterName=DefaultCluster  
                      brokerName=broker-b  
                      brokerId=0  
                      deleteWhen=04  
                      fileReservedTime=48  
                      brokerRole=ASYNC\_MASTER  
                      flushDiskType=ASYNC\_FLUSH  
                      listenPort=10911  
                      storePathRootDir=/home/rocketmq/store-b

**3) 192.168.100.131 机器上 Slave Broker 的配置文件:**

namesrvAddr=192.168.100. 131:9876;192.168.100.132:9876                          
                      brokerClusterName=DefaultCluster  
                      brokerName=broker-b  
                      brokerId=1  
                      deleteWhen=04  
                      fileReservedTime=48  
                      brokerRole=SLAVE  
                      flushDiskType=ASYNC\_FLUSH  
                      listenPort=10111  
                      storePathRootDir=/home/rocketmq/store-b

**4) 192.168.100.132机器上 SlaveBroker的配置文件:**

namesrvAddr=192.168.100. 131:9876;192.168.100.132:9876                          
                      brokerClusterName=DefaultCluster  
                      brokerName=broker-a  
                      brokerId=1  
                      deleteWhen=04  
                      fileReservedTime=48  
                      brokerRole=SLAVE  
                      flushDiskType=ASYNC\_FLUSH  
                      listenPort=10111  
                      storePathRootDir=/home/rocketmq/store-a

以上配置文件内容分别是红色框里的，大家要仔细看好，然后把对应的配置进行替换，记得namesrvAddr要换成自己服务器ip，storePathRootDir目录要有。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zODAwMzM4OQ_size_16_color_FFFFFF_t_70 2][]

然后分别使用如下命令启动四个 Broker: “config\_file”是变量分别是这四个配置文件的绝对路径。

nohup sh . /bin/mqbroker - c config\_file &

这样就是两台物理机，每台都有一主一从。

### 下面讲解参数的含义： ###

1)namesrvAddr=192.168.100.131:9876; 192.168.100.132:9876

NamerServer 的地址，可以是多个 。

2) brokerClusterName=DefaultCluster

Cluster 的地址，如果集群机器数比较多，可以分成多个 Cluster，每个 Cluster 供一个业务群使用 。

3) brokerName=broker-a

Broker 的名称， Master 和 Slave 通过使用相同的 Broker 名称来表明相互关系，以说明某个 Slave 是哪个 Master 的 Slave。

4) brokerId=0

一个 Master Barker可以有多个 Slave, 0表示 Master，大于 0表示不同 Slave 的 ID。

5) fileReservedTime=48

在磁盘上保存消息的时长，单位是小时，自动删除超时的消息 。

6) deleteWhen=04

与 fileReservedTim巳参数呼应，表明在几点做消息删除动作，默认值 04表 示凌晨 4点。

7) brokerRole=SYNC\_MASTER

brokerRole 有 3 种: SYNC\_MASTER、 ASYNC\_MASTER、 SLAVE。 关键 词 SYNC 和 ASYNC 表示 Master 和 Slave 之间同步消息的机制， SYNC 的意思 是当 Slave 和 Master 消息同步完成后，再返回发送成功的状态 。

8) flushDiskType=ASYNC\_FLUSH

flushDiskType表示刷盘策略，分为SYNC\_FLUSH和ASYNC\_FLUSH两 种，分别代表同步刷盘和异步刷盘。 同步刷盘情况下，消息真正写人磁盘后再 返回成功状态;异步刷盘情况下，消息写人 page\_cache 后就返回成功状态 。

9) listenPort=10911  
Broker监听的端口 号，如果一台机器上启动了多个 Broker， 则要设置不同的端口号，避免冲 突 。  
10 ) storePathRootDir=/home/rocketmq/store-a 存储消息以及一些配置信息的根目录 。

**这些配置参数，在 Broker启动的时候生效，如果启动后有更改，要重启 Broker。**

### 通过图形界面管理集群 ###

运维服务程序是个 SpringBoot项目，需要从 GitHub 上的 apache/rocketmq externals 里下载 源 码 (https://github.com/apache/rocketmq-externals/tree/master/rocketmq-console)。

下载然后进入下载源码的 目录，运行如下命令 即可启 动:mvn spring-boot:run

也可以编译成 jar 包，通过 java -jar 来执行 。

服务启动后 ，在浏览器里访问 server ip\_address:8080 (server\_ip\_address 是 启动rocketmq心onsole的机器IP) 地址就可看到集群的状态。

大家应该会碰到问题，请关注公众号查找我的联系方式。

![20190125101117236.jpeg][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zODAwMzM4OQ_size_16_color_FFFFFF_t_70]: /images/20220323/e9ac86e209994864addbe6a55abd7b69.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zODAwMzM4OQ_size_16_color_FFFFFF_t_70 1]: /images/20220323/d2279adf53544af7acb95ae116e2a49e.png
[RocketMq_-RocketMq]: https://blog.csdn.net/weixin_38003389/article/details/86505677
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zODAwMzM4OQ_size_16_color_FFFFFF_t_70 2]: /images/20220323/a71d347ef73448d3ab22bee665afdd94.png
[20190125101117236.jpeg]: /images/20220323/a7994c33b2d54c1994ef0608e39edb02.png