RocketMQ

rocketMQ是做什么的我就不用解释了吧，以及他的背景。本文主要是为了让大家明白RocketMQ的工作原理。

架构图

上图，双箭头代表是双向通信，ProducerGroup和ConsumerGroup以及Broker集群，NameServer集群在互相通信的时候，是每个实例之间的通信。举个例子：上图中ProducerGroup和NameSevrer通信来说，是三台Producer实例分别与三台NameServer实例都会进行通信（当然前提是Producer默认注册了三台Producer实例配置了三台NameServer的地址），但是三台NameServer之间不会进行通信，他们是多活的模式，不是主备的模式。

主要名词解释

• ProducerGroup

  由一组Producer组成，如果只是单纯的发送普通消息，本身没有什么特别含义，发送分布式事务消息时，
  如果 Producer 中途意外宕机，Broker会主动回调Producer Group内的任意一台机器来确认事务状态。
  

• ConsumerGroup

  标识一类Consumer的集合名称，这类Consumer通常消费一类消息，且消费逻辑一致。同
  Consumer Group下的各个实例将共同消费topic的消息，起到负载均衡的作用。
  消费进度以Consumer Group为粒度管理，不同Consumer Group之间消费进度彼此不受影响，
  即消息A被Consumer Group1消费过，也会再给Consumer Group2消费。
  注： RocketMQ要求同一个Consumer Group的消费者必须要拥有相同的注册信息，
  即必须要听一样的topic(并且tag也一样)。
  

• Client

  RocketMQ里面有Client这个概念，Consumer和Producer都是Client，可以这么理解：
  生产者和消费者都是客户端，且都具备一个Client应该有的属性，因为RocketMQ对Client有一些限制和规定，
  所以在使用Consumer和Producer的时候也要注意这些规定和限制。对应的有个ClientConfig类。
  

• Producer

  Producer是一个Client，用来生产消息,并发送到指定Topic,甚至Broker和Queue。
  

• PushConsumer

  推送模式的消费者，即消息由MQ主动推送过来
  

• PullConsumer

  拉取模式的消费者，自己控制消息的消费，包括消费量和进度等
  

• Topic

  主题，是一个虚拟的概念，是一类消息的抽象，消息的具体存放是放在Broker上面的，
  一个Topic可以存放在多个Broker的多个Queue上面。
  

• Broker

  节点，就是服务器，发送的消息真正存放的地方，也是真正集群部署的基本单位，
  

• Tag
  tag是消息的标志，发送消息的时候可以指定，接收消息的时候也可以按照这个Tag来过滤消息。

• Queue
  是消息存在也是生产者投放消息和消费者消费信息的目的地。