让阿里大佬带你走进中间件产品:RocketMQ实战与原理解析世界中( 四 )

第6章讨论了消息的可靠性 , 以及如何让消息队列在满足业务逻辑需求的同时稳定、可靠地长期运行;

第7章讨论了在大流量场景下 , 吞吐量优先时RocketMQ的使用方法;

第8章介绍了RocketMQ与SpringBoot、Spark、 Flink以及自定义的运维工具等其他系统的对接方法;

第二部分(第9~13章) : RocketMQ原理

首先对RocketMQ的源码结构进行了整体介绍 , 然后深入分析了NameServer、各种常用消费类、主从同步机制 , 以及基于Netty的通信的源码实现 。 掌握这些源代码以后 , 读者可以快速定制属于自己的具有特殊功能的消息中间件 。

在这里重点介绍一下基于Netty的通信实现

本章分析RocketMQ底层通信的实现机制 , 作为一个分布式消息队列 , 通信的质量至关重要 。 基于TCP协议和Socket实现-一个高效、稳定的通信程序并不容易 , 有很多大大小小的“坑”等待着经验不足的开发者 。 RocketMQ 选择不重复发明轮子 , 基于Netty库来实现底层的通信功能 。

推荐阅读