RocketMQ筑基篇-部署集群（Centos7）

矫情吗；* 2022-12-31 02:25 232阅读 0赞

# 工欲善其事必先利其器 #

独孤九剑虽是宝典，光说不练也是假把式，先把环境搭建起来，扎个马步，夯实基础。

## 环境 ##

### 服务器 ###

<table> 
 <thead> 
  <tr> 
   <th>服务器IP</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>192.68.1.61</td> 
  </tr> 
  <tr> 
   <td>192.68.1.232</td> 
  </tr> 
  <tr> 
   <td>192.68.1.233</td> 
  </tr> 
 </tbody> 
</table>

### 其他环境 ###

<table> 
 <thead> 
  <tr> 
   <th>环境</th> 
   <th>版本</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>JDK</td> 
   <td>java8</td> 
  </tr> 
  <tr> 
   <td>RocketMq</td> 
   <td>4.8.0</td> 
  </tr> 
 </tbody> 
</table>

> RocketMq需要java8的java环境，如果是java11会报错，主要rocketMq是支持java11的，只是脚本不知道，网上也有解决方案，自行百度即可。

## 下载RocketMQ ##

[官网下载地址][Link 1] ttp://rocketmq.apache.org/dowloading/releases/

wget https://mirror.bit.edu.cn/apache/rocketmq/4.8.0/rocketmq-all-4.8.0-bin-release.zip

**直接下载二进制版本** ：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI2NDYyNTY3_size_16_color_FFFFFF_t_70]

## 安装RocketMq ##

### 解压安装包到安装目录 ###

unzip rocketmq-all-4.8.0-bin-release.zip -d /home/install/

## 配置集群 ##

#### 主节点配置（192.168.1.61） ####

## 集群名
    brokerClusterName = RaftCluster
    ### broker组名，同一个RaftClusterGroup内，brokerName名要一样
    brokerName=RaftNode00
    ### 监听的端口
    listenPort=30911
    ### 你设置的NameServer地址和端口
    namesrvAddr=192.168.1.61:9876;192.168.1.232:9876;192.168.1.233:9876
    storePathRootDir=/guodun/data/rocketmq/node
    storePathCommitLog=/guodun/data/rocketmq/node/commitlog
    enableDLegerCommitLog=true
    dLegerGroup=RaftNode00
    ### n0 n1 n2 分别是broker1,broker2,broker3 的 dLegerSelfId
    ### 例如：dLegerPeers=n0-服务器1的IP:40911;n1-服务器2的IP:40912;n2-服务器3的IP:40913
    dLegerPeers=n0-192.168.1.61:40911;n1-192.168.1.232:40912;n2-192.168.1.233:40913
    ## must be unique
    ## 这个值必须是在同一个RaftClusterGroup内唯一的
    dLegerSelfId=n0
    sendMessageThreadPoolNums=16
    brokerIP1=192.168.1.61

#### 从节点配置（192.168.1.232） ####

brokerClusterName = RaftCluster
    brokerName=RaftNode00
    listenPort=30921
    namesrvAddr=192.168.1.61:9876;192.168.1.232:9876;192.168.1.233:9876
    storePathRootDir=/home/guodun/data/rocketmq/node
    storePathCommitLog=/home/guodun/data/rocketmq/node/commitlog
    enableDLegerCommitLog=true
    dLegerGroup=RaftNode00
    dLegerPeers=n0-192.168.1.61:40911;n1-192.168.1.232:40912;n2-192.168.1.233:40913
    # must be unique
    dLegerSelfId=n1
    sendMessageThreadPoolNums=16
    
    brokerIP1=192.168.1.232

#### 从节点配置（192.168.1.233） ####

brokerClusterName = RaftCluster
    brokerName=RaftNode00
    listenPort=30931
    namesrvAddr=192.168.1.61:9876;192.168.1.232:9876;192.168.1.233:9876
    storePathRootDir=/home/guodun/data/rocketmq/node
    storePathCommitLog=/home/guodun/data/rocketmq/node/commitlog
    enableDLegerCommitLog=true
    dLegerGroup=RaftNode00
    dLegerPeers=n0-192.168.1.61:40911;n1-192.168.1.232:40912;n2-192.168.1.233:40913
    ## must be unique
    dLegerSelfId=n2
    sendMessageThreadPoolNums=16
    brokerIP1=192.168.1.233

> brokerIP1 实例IP ，如果不配置在多网卡模式下可能会有问题  
> dLegerSelfId 要和 dLegerPeers 的前缀要保持一致

#### 使用Dledger集群搭建 ####

##### 启动主节点名字服务 #####

nohup sh bin/mqnamesrv > nameServer-start.log &

##### 启动rocketMq主节点broker #####

nohup sh bin/mqbroker  > broker-start.log -c conf/dledger/broker-n-61.conf &

--------------------

##### 启动从节点（232）名字服务 #####

nohup sh bin/mqnamesrv > nameServer-start.log &

##### 启动从节点（232）broker #####

nohup sh bin/mqbroker  > broker-start.log -c conf/dledger/broker-n-232.conf &

--------------------

##### 启动从节点（233）名字服务 #####

nohup sh bin/mqnamesrv > nameServer-start.log &

##### 启动从节点（233）broker #####

nohup sh bin/mqbroker  > broker-start.log -c conf/dledger/broker-n-233.conf &

--------------------

#### 校验集群有效性 ####

sh bin/mqadmin clusterList -n 127.0.0.1:9876

![在这里插入图片描述][20201227211101286.png]

#### 关闭broker命令 ####

sh bin/mqshutdown broker

[Link 1]: http://rocketmq.apache.org/dowloading/releases/
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI2NDYyNTY3_size_16_color_FFFFFF_t_70]: /images/20221120/1fbff28c6d9a47ad9ebf72b1e43f58be.png
[20201227211101286.png]: /images/20221120/59e728ec37b14f75a98d48cf26ffb6c4.png