分布式消息队列RocketMQ原理-进阶1

RocketMQ介绍

RocketMQ是阿里开源的一款分布式、高性能、高吞吐量的消息中间件。所谓消息中间件，即与两个角色有关：消息生产者和消息消费者。
消息生产者负责创建消息并发送到RocketMQ服务器，RocketMQ服务器会将消息持久化到磁盘，消息消费者从RocketMQ服务器拉取消息并提交给应用消费。

快速理解<生产消息>与<消费消息>

RocketMQ特点

1、支持严格的消息顺序；
2、支持Topic与Queue两种模式；
3、亿级消息堆积能力；
4、比较友好的分布式特性；
5、同时支持Push与Pull方式消费消息；

架构图

RocketMQ集群方式优缺点

单个master:

这种方式风险较大，一旦Broker
重启或者宕机时，会导致整个服务不可用，不建议线上环境使用。

多Master模式:

一个集群无 Slave，全是 Master，例如 2 个 Master 或者 3 个 Master
优点：配置简单，单个Master 宕机或重启维护对应用无影响，在磁盘配置为
RAID10 时，即使机器宕机不可恢复情况下，由与 RAID10
磁盘非常可靠，消息也不会丢（异步刷盘丢失少量消息，同步刷盘一条不丢）。性
能最高。
缺点：单台机器宕机期间，这台机器上未被消费的消息在机器恢复之前不可订阅
，消息实时性会受到受到影响。
先启动 NameServer
在机器 A，启动第一个 Master
在机器 B，启动第二个 Master

多 Master 多 Slave 模式，异步复制:

每个 Master 配置一个 Slave，有多对Master-Slave，HA
采用异步复制方式，主备有短暂消息延迟，毫秒级。
优点：即使磁盘损坏，消息丢失的非常少，且消息实时性不会受影响，因为
Master 宕机后，消费者仍然可以从 Slave
消费，此过程对应用透明。不需要人工干预。性能同多 Master 模式几乎一样。
缺点：Master 宕机，磁盘损坏情况，会丢失少量消息。
先启动 NameServer
在机器 A，启动第一个 Master
在机器 B，启动第二个 Master
在机器 C，启动第一个 Slave
在机器 D，启动第二个 Slave

多 Master 多 Slave 模式，同步双写:

每个 Master 配置一个 Slave，有多对Master-Slave，HA
采用同步双写方式，主备都写成功，向应用返回成功。
优点：数据与服务都无单点，Master宕机情况下，消息无延迟，服务可用性与数据
可用性都非常高
缺点：性能比异步复制模式略低，大约低 10%左右，发送单个消息的 RT
会略高。目前主宕机后，备机不能自动切换为主机，后续会支持自动切换功能。
先启动 NameServer
在机器 A，启动第一个 Master
在机器 B，启动第二个 Master
在机器 C，启动第一个 Slave
在机器 D，启动第二个 Slave
以上 Broker 与 Slave 配对是通过指定相同的brokerName 参数来配对，Master
的 BrokerId 必须是 0，Slave 的BrokerId 必须是大与 0 的数。另外一个 Master
下面可以挂载多个 Slave，同一 Master 下的多个 Slave通过指定不同的 BrokerId
来区分。

参考来源：RocketMQ集群方式

RocketMQ网络部署特点：

Name Server 是一个几乎无状态节点，可集群部署，节点之间无任何信息同步。

Broker部署相对复杂，Broker分为Master与Slave，一个Master可以对应多个Slave，但是一个Slave只能对应一个Master，Master与Slave的对应关系通过指定相同的BrokerName，不同的BrokerId来定义，BrokerId=0表示Master，非0表示Slave。Master也可以部署多个。每个Broker与Name Server集群中的所有节点建立长连接，定时注册Topic信息到所有Name Server。

Producer与Name Server集群中的其中一个节点（随机选择）建立长连接，定期从Name Server取Topic路由信息，并向提供Topic 服务的Master建立长连接，且定时向Master发送心跳。Producer 完全无状态，可集群部署。

Consumer与Name Server集群中的其中一个节点（随机选择）建立长连接，定期从Name Server取Topic 路由信息，并向提供Topic服务的Master、Slave建立长连接，且定时向Master、Slave发送心跳。Consumer既可以从Master订阅消息，也可以从Slave订阅消息，订阅规则由Broker配置决定。

通过这篇“RocketMQ原理与实践”可以很容易理解，RocketMQ是如何解决 <消息顺序>和<消息重复>的。

• 本文作者： GaryWu
• 本文链接： https://garywu520.github.io/2017/11/14/分布式消息队列RocketMQ原理-进阶1/
• 版权声明： 本博客所有文章除特别声明外，均采用 MIT 许可协议。转载请注明出处！