一、概述

参考链接：
http://rocketmq.apache.org/docs/rmq-arc/
http://rocketmq.apache.org/docs/rmq-deployment/
http://rocketmq.apache.org/docs/cli-admin-tool/

二、RocketMQ Architecture 结构

RocketMQ工作结构图

RocketMQ主要由4部分组成：

• name servers
  服务发现及路由
• brokers
  
  broker模块

1. Remoting Module:远程模块，负责处理客户端的请求（producer、consumers、cmd line）
2. Client Manager：管理Producers/Consumers，并且维护Consumers的Topic订阅
3. Store Service：支持用简单的API对硬盘上的消息进行查询、存储
4. HA Service：提供Master与Slaver之间的数据同步
5. Index Service：根据给定的key简历消息索引

• producers
• consumers

三、Deployment（部署）

1. Name Server部署建议
   建议部署2个以上的Name Server
2. Broker
   A broker set contains one master with brokerId set to 0 and several slaves with non-zero brokerIDs
   一个broker集合包括一个bokerId = 0的master，以及一些 brokerIDs !=0 的slave，在一个集合中的broker必须拥有相同的brokerName，

• Configuration 建议的配置如下：

3. CLI Admin Tool 命令行工具
   常用命令行命令如下：

   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

4. pre-built config（预设配置）
   在 ~/rocketmq/conf下有几个预设的配置文件，方便启动部署，注意，这些配置中的flush方式都是：ASYNC_FLUSH

• 2m-2s-sync：多个master，多个slave（SYNC_MASTER）
• 2m-2s-async：多个master，多个slave（ASYNC_MASTER）
• 2m-noslave：多个master，无slave模式
  以 2m-2s-sync 为例，启动方式如下：

>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

上面的例子，启动了2对broker（master-slave）