RocketMQ 部署

本节将介绍生产就绪的部署解决方案。一般来说，我们将部署一个弹性的RocketMQ集群，没有单点故障。

先决条件

在开始这一节之前, 请确保您已经阅读快速启动部分中，并且熟悉RocketMQ的核心概念和组件。

开始部署

Name Server

为了确保集群在一个实例崩溃时仍然可以运行，建议使用两个或多个名称服务器实例。只要有一个名称服务器实例还活着，整个集群就会继续服务。

名称服务器遵循share-nothing设计范例。Brokers将心跳数据发送到所有名称服务器。生产者和消费者可以在发送或者消费消息时查询来自任何名称服务器的元数据。

Broker

Brokers 可以根据他们的角色分为两类：master 和 slave。master brokers提供RW访问，而slave brokers只接受读访问。

要部署一个没有单点故障的高可用性RocketMQ集群，应该部署一系列broker set。一个broker set包含一个master，其brokerID 设置为0，和多个slaves，其brokerID非零。一个集合中的所有代理都具有相同的代理名称。在正式的场景中，我们应该在一个代理集中至少有两个代理。每个主题都位于两个或更多的代理中。

Configuration

在部署RocketMQ集群时，建议的配置如下:

Broker configuration

Property Name	Default value	Details
listenPort	10911	端口监听客户端
namesrvAddr	null	名称服务器地址
brokerIP1	InetAddress for network interface	是否应该配置多个地址
brokerName	null	broker 名称
brokerClusterName	DefaultCluster	这个代理属于哪个集群
brokerId	0	broker id, 0 代表 master, 负数代表 slave
storePathCommitLog	$HOME/store/commitlog/	提交日志的文件路径
storePathConsumerQueue	$HOME/store/consumequeue/	用于消费队列的文件路径
mapedFileSizeCommitLog	1024 * 1024 * 1024(1G)	用于提交日志的映射文件大小
deleteWhen	04	何时删除超出预留时间的提交日志
fileReserverdTime	72	在删除提交日志之前的小时数
brokerRole	ASYNC_MASTER	SYNC_MASTER/ASYNC_MASTER/SLVAE
flushDiskType	ASYNC_FLUSH	{SYNC_FLUSH/ASYNC_FLUSH}. SYNC_FLUSH 模式在Broker ack生产者之前将每个消息都放到磁盘上. Broker of ASYNC_FLUSH 模式与之相反，利用异步批量提交的优势，获取更好的性能.

CLI Admin 工具

RocketMQ提供了一个CLI(命令行界面)管理工具带来查询、管理和诊断各种问题。

如何获得

管理工具和RocketMQ一起打包。您可以下载预构建的二进制版本，也可以自己从源代码构建，您已经拥有它了。

如果您需要源代码，rocketmq-tools模块包含它的源代码。

如何使用

管理工具很容易使用。在这里，为了演示目的，假定*nix环境。

更改目录到${PACKAGE}/bin，命令行输入mqadmin，您应该看到以下帮助菜单:

The most commonly used mqadmin commands are:
   updateTopic          Update or create topic
   deleteTopic          Delete topic from broker and NameServer
   updateSubGroup       Update or create subscription group
   deleteSubGroup       Delete subscription group from broker
   updateBrokerConfig   Update broker's config
   updateTopicPerm      Update topic perm
   topicRoute           Examine topic route info
   topicStatus          Examine topic Status info
   topicClusterList     get cluster info for topic
   brokerStatus         Fetch broker runtime status data
   queryMsgById         Query Message by Id
   queryMsgByKey        Query Message by Key
   queryMsgByUniqueKey  Query Message by Unique key
   queryMsgByOffset     Query Message by offset
   queryMsgByUniqueKey  Query Message by Unique key
   printMsg             Print Message Detail
   sendMsgStatus        Send msg to broker
   brokerConsumeStats   Fetch broker consume stats data
   producerConnection   Query producer's socket connection and client version
   consumerConnection   Query consumer's socket connection, client version and subscription
   consumerProgress     Query consumers's progress, speed
   consumerStatus       Query consumer's internal data structure
   cloneGroupOffset     Clone offset from other group
   clusterList          List all of clusters
   topicList            Fetch all topic list from name server
   updateKvConfig       Create or update KV config
   deleteKvConfig       Delete KV config
   wipeWritePerm        Wipe write perm of broker in all name server
   resetOffsetByTime    Reset consumer offset by timestamp(without client restart)
   updateOrderConf      Create or update or delete order conf
   cleanExpiredCQ       Clean expired ConsumeQueue on broker.
   cleanUnusedTopic     Clean unused topic on broker
   startMonitoring      Start Monitoring
   statsAll             Topic and Consumer tps stats
   syncDocs             Synchronize wiki and issue to github.com
   allocateMQ           Allocate MQ
   checkMsgSendRT       Check message send response time
   clusterRT            List All clusters Message Send RT

有关特定命令的更多信息，请参见“mqadmin help”。如果您想获得关于特定命令的更多信息，如“clusterList”，只需键入mqadmin help clusterList，您将会看到：

usage: mqadmin clusterList [-h] [-i <arg>] [-m] [-n <arg>]
 -h,--help                Print help
 -i,--interval <arg>      specify intervals numbers, it is in seconds
 -m,--moreStats           Print more stats
 -n,--namesrvAddr <arg>   Name server address list, eg: 192.168.0.1:9876;192.168.0.2:9876

复制模式

为了确保不会丢失成功发布的消息，RocketMQ提供了一个复制模式，具有两种复制方式：Sync和Async，以获得更强的持久性和高可用性。

复制: Sync / Async Broker

像许多复制系统一样，同步的brokers等待提交日志复制到slave再给ack。而异步brokers则在master上的消息处理完后立即返回。

如何配置

在conf文件夹下，有三个预构建配置与RocketMQ的分布一起，供您参考:

2m-2s-sync
2m-2s-async
2m-noslave

Note: 所有的配置均ASYNC_FLUSH.

部署

以2m-2s-sync为例。首先，启动两个名称服务器，如快速启动部分所示。假设它们的IPs是192.168.0.2和192.168.0.3。

然后启动brokers(假设二进制RocketMQ位于/home/rocketmq/dist)

>cd /home/rocketmq/dist/bin
>bash mqbroker -c ../conf/2m-2s-sync/broker-a.properties -n 192.168.0.2:9876,192.168.0.3:9876
>bash mqbroker -c ../conf/2m-2s-sync/broker-a-s.properties -n 192.168.0.2:9876,192.168.0.3:9876
>bash mqbroker -c ../conf/2m-2s-sync/broker-b.properties -n 192.168.0.2:9876,192.168.0.3:9876
>bash mqbroker -c ../conf/2m-2s-sync/broker-b-s.properties -n 192.168.0.2:9876,192.168.0.3:9876
How to verify
Execute the following command to verify according to the CLI section:
> bash mqadmin clusterlist