RocketMQ

1 RocketMQ架构

RocketMQ是阿里巴巴中间件团队自研的一款高性能、高吞吐量、低延迟、高可用、高可靠（具备金融级稳定性）的分布式消息中间件
开源后并于2016年捐赠给Apache社区孵化，目前已经成为了Apache顶级项目。当前在国内被广泛的使用，包括互联网、电商、金融、企业服务等领域，包括：字节跳动、滴滴、微众银行等知名的互联网公司。

1.1 RocketMQ的使用场景

1.2 RocketMQ 部署架构

1.3 RocketMQ特性

1.4 消费模式Push or Pull

2 RocketMQ高级特性及原理 2.1 消息发送

2.2 消息消费

2.3 消息存储

性能对比
文件系统>关系型数据库DB

2.4 过滤消息

2.5 零拷贝原理

直接内存读取并发送文件的过程

Mmap读取并发送文件的过程

Sendfile零拷贝读取并发送文件的过程

2.6 同步复制和异步复制

2.7 高可用机制

2.8 刷盘机制

2.9 负载均衡

2.10 消息重试

对于顺序消息，当消费者消费消息失败后，消息队列 RocketMQ 会自动不断进行消息重试（每次间隔时间为 1 秒），这时，应用会出现消息消费被阻塞的情况。因此，在使用顺序消息时，务必保证应用能够及时监控并处理消费失败的情况，避免阻塞现象的发生。

2.11 死信队列

2.12 延迟消息

2.13 顺序消息

2.14 事务消息

2.15 消息查询

2.16 消息优先级

2.17 底层网络通信 - Netty高性能之道

2.18 限流

3 RocketMQ高级实战 3.1 生产者

3.2 消费者

3.3 Broker

3.4 NameServer

3.5 客户端配置

3.6 系统配置

![在这里插入图片描述](https://img-blog.csdnimg.cn/95ed26a1280344f589750c2ffa695130.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBAR0pPRUQ=,size_20,color_FFFFFF,t_70,g_se,x_16)

3.7 动态扩缩容

3.8 各种故障对消息的影响

4 RocketMQ集群 4.1 集群