RocketMQ部署文档

一、引言

适用读者：一切使用RocketMQ的人员。

文章目的：主要介绍RocketMQ的集中部署方式和方法、使开发人员快速搭建RocketQM服务器。

二、简介

RocketMQ是一款分布式、队列模型的消息中间件，具有以下特点：

• 能够保证严格的消息顺序
  
• 提供丰富的消息拉取模式
  
• 提供丰富的消息拉取模式
  
• 高效的订阅者水平扩展能力
  
• 实时的消息订阅机制
  
• 亿级消息堆积能力
  

三、Linux环境搭建&安装包下载

1. Java环境：RocketMQ依赖于宿主机Java环境，所以首先确保Java环境安装到位，如有不懂Java安装，问度娘。
2. Rocket下载：https://github.com/alibaba/RocketMQ/releases/download/v3.2.6/alibaba-rocketmq-3.2.6.tar.gz 具体版本根据需求下载，此处以3.2.6作为案例版本。
3. 复制、解压安装包：将安装包上传至服务器目标目录，例：opt/tpapp/。解压安装包即可： tar -zxvf alibaba-rocketmq-3.2.6.tar.gz  opt/tpapp/rocketmq 。

四、RocketMQ部署服务的简述

   我们需要部署NameSever和Broker服务器，这两个服务有什么作用和用途请看下图：

   

   NameServer:

       RocketMQ-nameSrv用于管理所有broker的信息，以便于Producer和Consumer能够获取到正确的Broker信息，进行业务处理；

       可以看到NameSrv的主要管理内容如下：

       1. 接收Broker的注册，注销请求。

       2. Producer获取topic下的所有BrokerQueue，put消息。

       3. Consumer获取topic下所有的BrokerQueue，get消息。

   Broker:

       负责存储消息，提供读写功能。

   RocketMQ依赖于NameServer服务器和Broker服务器，所以我们需要分别部署NameServer和Broker(实际上只是用同一个软件文件，以不同的命令和配置区分别启动NameServer服务和Broker服务的)。

五、RocketMQ部署集中集群方式和配置

   NameServer一般作多台集群部署(2台：namesrv1、namesrv2)：

   启动：namesrv1 : nohup opt/tpapp/rocketmq/bin/mqnamesrv &

            namesrv2 : nohup opt/tpapp/rocketmq/bin/mqnamesrv &

   停止：sh mqshutdown namesrv

   Broker部署集群方式有以下几种（Master和Slave都是指Broker服务器）：

   1.单Master（一台服务器）

       优点：除了配置简单没什么优点

       缺点：不可靠，该机器重启或宕机，将导致整个服务不可用

       启动：

       nohup opt/tpapp/rocketmq/bin/mqbroker -n namesrv1IP；namesrv２IP -c 配置文件（../conf/2m-noslave/broker-a.properties）

   2.多Master（两台或多台服务器）

       优点：配置简单，性能最高

       缺点：可能会有少量消息丢失（配置相关），单台机器重启或宕机期间，该机器下未被消费的消息在机器恢复前不可订阅，影响消息实时性

       启动：

       nohup opt/tpapp/rocketmq/bin/mqbroker -n namesrv1IP；namesrv２IP -c 配置文件（../conf/2m-noslave/broker-a.properties）

       nohup opt/tpapp/rocketmq/bin/mqbroker -n namesrv1IP；namesrv２IP -c 配置文件（../conf/2m-noslave/broker-b.properties）

   3.多Master多Slave，每个Master配一个Slave，有多对Master-Slave，HA采用异步复制方式，主备有短暂消息延迟，毫秒级()

       优点：性能同多Master几乎一样，实时性高，主备间切换对应用透明，不需人工干预

       缺点：Master宕机或磁盘损坏时会有少量消息丢失

       启动：

       Master:

       nohup opt/tpapp/rocketmq/bin/mqbroker -n namesrv1IP；namesrv２IP -c 配置文件（../conf/2m-2s-async/broker-a.properties）                

       nohup opt/tpapp/rocketmq/bin/mqbroker -n namesrv1IP；namesrv２IP -c 配置文件（../conf/2m-2s-async/broker-a-s.properties）

      Slave:  

      nohup opt/tpapp/rocketmq/bin/mqbroker -n namesrv1IP；namesrv２IP -c 配置文件（../conf/2m-2s-async/broker-b.properties）

      nohup opt/tpapp/rocketmq/bin/mqbroker -n namesrv1IP；namesrv２IP -c 配置文件（../conf/2m-2s-async/broker-b-s.properties）

   4.多Master多Slave，每个Master配一个Slave，有多对Master-Slave，HA采用同步双写方式，主备都写成功，向应用返回成功

       优点：服务可用性与数据可用性非常高

       缺点：性能比一部HA略低，当前版本主宕备不能自动切换为主

       Master和Slave的配置文件参考conf目录下的配置文件

       Master与Slave通过指定相同的brokerName参数来配对，Master的BrokerId必须是0，Slave的BrokerId必须是大于0的数

       一个Master下面可以挂载多个Slave，同一Master下的多个Slave通过指定不同的BrokerId来区分

      Master:

      nohup opt/tpapp/rocketmq/bin/mqbroker -n namesrv1IP；namesrv２IP -c 配置文件（../conf/2m-2s-sync/broker-a.properties）                

      nohup opt/tpapp/rocketmq/bin/mqbroker -n namesrv1IP；namesrv２IP -c 配置文件（../conf/2m-2s-sync/broker-a-s.properties）

      Slave:  

      nohup opt/tpapp/rocketmq/bin/mqbroker -n namesrv1IP；namesrv２IP -c 配置文件（../conf/2m-2s-sync/broker-b.properties）

      nohup opt/tpapp/rocketmq/bin/mqbroker -n namesrv1IP；namesrv２IP -c 配置文件（../conf/2m-2s-sync/broker-b-s.properties）

   5. 停止broker

       sh mqshutdown broker

六、配置（注意对应版本）

   1.Broker配置

显示详细信息

   2.客户端公共配置类：clientconfig

显示详细信息

  3.producer配置

显示详细信息

   4.pushConsumer配置

显示详细信息

   5.pullConsumer

显示详细信息