rocketmq介绍

<h4 class="heading" data-id="heading-2">
  1. 灵活可扩展性
</h4>

<p>
  RocketMQ 天然支持集群，其核心四组件（Name Server、Broker、Producer、Consumer）每一个都可以在没有单点故障的情况下进行水平扩展。
</p>

<h4 class="heading" data-id="heading-3">
  2. 海量消息堆积能力
</h4>

<p>
  RocketMQ 采用零拷贝原理（零拷贝，指的是应用内存与内核内存不存在拷贝）实现超大的消息的堆积能力，据说单机已可以支持亿级消息堆积，而且在堆积了这么多消息后依然保持写入低延迟。
</p>

<blockquote>
  <p>
    零拷贝主要的任务就是避免CPU将数据从一块存储拷贝到另外一块存储，主要就是利用各种零拷贝技术，避免让CPU做大量的数据拷贝任务，减少不必要的拷贝，或者让别的组件来做这一类简单的数据传输任务，让CPU解脱出来专注于别的任务。这样就可以让系统资源的利用更加有效。
  </p>
</blockquote>

<p>
  常见的零拷贝包含一下两种方式：
</p>

<ul>
  <li>
    使用 mmap + write 方式 优点:即使频繁调用,使用<span style="color: #ff0000;">小块文件传输</span>,效率也很高 缺点:不能很好的利用 DMA 方式,会比 sendfile 多消耗 CPU,内存安全性控制复杂,需要避免 JVM Crash 问题。
  </li>
  <li>
    使用 sendfile 方式 优点:可以利用 DMA 方式,消耗 CPU 较少,大块文件传输效率高,无内存安全新问题。 缺点:小块文件效率低于 mmap 方式,只能是 BIO 方式传输,不能使用 NIO。
  </li>
</ul>

<p>
  rocketmq选择的第一种，
</p>

<h4 class="heading" data-id="heading-4">
  3. 支持顺序消息
</h4>

<p>
  可以保证消息消费者按照消息发送的顺序对消息进行消费。顺序消息分为全局有序和局部有序，一般推荐使用局部有序，即生产者通过将某一类消息按顺序发送至同一个队列来实现。
</p>

<h4 class="heading" data-id="heading-5">
  4. 多种消息过滤方式
</h4>

<p>
  消息过滤分为在服务器端过滤和在消费端过滤。服务器端过滤时可以按照消息消费者的要求做过滤，优点是减少不必要消息传输，缺点是增加了消息服务器的负担，实现相对复杂。消费端过滤则完全由具体应用自定义实现，这种方式更加灵活，缺点是很多无用的消息会传输给消息消费者。
</p>

<h4 class="heading" data-id="heading-6">
  5. 支持事务消息
</h4>

<p>
  RocketMQ 除了支持普通消息，顺序消息之外还支持事务消息，这个特性对于分布式事务来说提供了又一种解决思路。
</p>

<h4 class="heading" data-id="heading-7">
  6. 回溯消费
</h4>

<p>
  回溯消费是指消费者已经消费成功的消息，由于业务上需求需要重新消费，RocketMQ 支持按照时间回溯消费，时间维度精确到毫秒，可以向前回溯，也可以向后回溯。
</p>

<p>
  

</p>

    <h1>
      RocketMQ 集群部署模式
    </h1>
    
    <p>
      1）单 master 模式<br /> 也就是只有一个 master 节点，称不上是集群，一旦这个 master 节点宕机，那么整个服务就不可用，适合个人学习使用。
    </p>
    
    <p>
      2）多 master 模式<br /> 多个 master 节点组成集群，单个 master 节点宕机或者重启对应用没有影响。<br /> 优点：所有模式中性能最高<br /> 缺点：单个 master 节点宕机期间，未被消费的消息在节点恢复之前不可用，消息的实时性就受到影响。<br /> 注意：使用同步刷盘可以保证消息不丢失，同时 Topic 相对应的 queue 应该分布在集群中各个节点，而不是只在某各节点上，否则，该节点宕机会对订阅该 topic 的应用造成影响。
    </p>
    
    <p>
      3）多 master 多 slave 异步复制模式<br /> 在多 master 模式的基础上，每个 master 节点都有至少一个对应的 slave。master<br /> 节点可读可写，但是 slave 只能读不能写，类似于 mysql 的主备模式。<br /> 优点： 在 master 宕机时，消费者可以从 slave 读取消息，消息的实时性不会受影响，性能几乎和多 master 一样。<br /> 缺点：使用异步复制的同步方式有可能会有消息丢失的问题。
    </p>
    
    <p>
      4）多 master 多 slave 同步双写模式<br /> 同多 master 多 slave 异步复制模式类似，区别在于 master 和 slave 之间的数据同步方式。<br /> 优点：同步双写的同步模式能保证数据不丢失。<br /> 缺点：发送单个消息 RT 会略长，性能相比异步复制低10%左右。<br /> 刷盘策略：同步刷盘和异步刷盘（指的是节点自身数据是同步还是异步存储）<br /> 同步方式：同步双写和异步复制（指的一组 master 和 slave 之间数据的同步）<br /> 注意：要保证数据可靠，需采用同步刷盘和同步双写的方式，但性能会较其他方式低。
    </p>