课程介绍

无论你是后端开发、全栈开发、系统架构，还是大数据开发、测试领域，吃透消息中间件都将显著增强你的技术实力。本课程将引领大家从0到1独立构建一款分布式消息中间件，全面洞悉其架构精髓与底层设计智慧。从容应对生产环境中消息队列的复杂挑战，不仅提升对MQ技术的驾驭能力，还能根据实际业务需求进行灵活改造，助力你在消息处理领域高效破局

课程目录

• 第1章 课程导学介绍
• 1-1 手写消息中间件–课程导学
• 1-2 课程详细内容安排
• 第2章 深入常用消息队列原理
• 2-1 RabbitMq架构原理深入剖析
• 2-2 RocketMq架构原理深入剖析
• 2-3 Kafka架构原理深入剖析
• 2-4 三种消息队列对比剖析
• 第3章 消息中间件架构设计篇 【平价资源：666root.com 微AG110 360】
• 3-1 本章介绍
• 3-10 本章回顾
• 3-2 CommitLog介绍-MQ的消息都存在哪儿？
• 3-3 ConsumerQueue介绍-面对多消费者，消息的分配要如何设计
• 3-4 消息集群架构思考（一）为什么消息队列还需用到注册中心？
• 3-5 消息集群架构思考（二）多节点存储的架构要如何实现？
• 3-6 复杂消息功能思考（一）消息重试机制如何实现？
• 3-7 复杂消息功能思考（二）延迟消息要怎么做？
• 3-8 复杂消息功能思考（三）事务消息是怎么一回事？
• 3-9 复杂消息功能思考（四）内存映射自扩容设计思路
• 第4章 【手写篇 – 第一步】 数据存储核心 – commitLog设计与实战
• 4-10 mq基础配置的封装
• 4-11 Broker的启动类设计
• 4-12 commitLog写入逻辑细节分析
• 4-13 如何获取最新写入的commitLog文件
• 4-14 消息内容结构体设计
• 4-15 消息结构体封装的实践
• 4-16 commitlog文件剩余空间检测机制
• 4-17 消息投递offset更新机制的实现
• 4-18 消息写入的配置属性同步更新 (1)
• 4-18 消息写入的配置属性同步更新 (2)
• 4-19 多线程场景下mmap的读写如何优化
• 4-2 代码仓库介绍
• 4-20 commitlog追加写入数据测试
• 4-3 消息原始数据存储结构讲解
• 4-4 操作系统原理之 – 传统文件IO读写介绍
• 4-5 基于mmap的读写工具封装（一）基础功能的实现
• 4-6 基于mmap的读写工具封装（二）mmap的内存释放讲解
• 4-7 基于mmap的读写工具封装（三）mmap工具的效果验证
• 4-8 如何实现mq消息的顺序写入
• 4-9 mq消息存储配置的管理
• 第5章 【手写篇 – 第二步】消息分派的核心 – ConsumeQueue分析与实战
• 5-1 本章介绍
• 5-10 consumeQueue处理器的基础接口定义
• 5-11 consumeQueue的offset定位获取
• 5-12 consumequeue的数据读取实现
• 5-13 consumequeue的offset更新实现
• 5-14 多消费者消费效果验证
• 5-2 针对ConsumerQueue的dispatcher操作
• 5-3 consumequeue的文件存储结构设计
• 5-4 【实战】ConsumeQueue存储结构实现（一）ConsumerQueue的offset数据结构设计
• 5-5 【实战】ConsumeQueue存储结构实现（二）offset映射模型的实现
• 5-6 【实战】ConsumeQueue存储结构实现（三）ConsumeQueue的offset定时刷盘机制
• 5-7 【实战】ConsumeQueue存储 预热链路逻辑搭建
• 5-8 【实战】ConsumeQueue文件的预热实现
• 5-9 consumequeue文件的映射写入和offset更新
• 第6章 【手写篇 – 第三步】注册中心 – nameserver设计与实战
• 6-1 本章介绍
• 6-10 nameserver集群架构的设计思路剖析
• 6-17 nameserver主从复制-同步复制，异步复制，半同步复制的三种模式实现(一)
• 6-19 链式复制架构的介绍
• 6-20 链式复制的初始化实现mov
• 6-21 链式复制的同步实现-全链路同步的实现
• 6-22 链式复制的实现-全链路ack反馈的实现
• 6-24 本章回顾
• 6-3 注册中心的设计与实现（一）事件总线的发布能力实现
• 6-4 注册中心的设计与实现（二）基于spi机制实现处理器实现
• 6-5 注册中心的设计与实现（三）事件监听的逻辑完善
• 6-6 注册中心的设计与实现（四）非法节点的剔除逻辑完善
• 6-7 注册中心的设计与实现（五）broker与nameserver的网络通信建立
• 6-8 注册中心的设计与实现（六）broker远程通信sdk的封装实现
• 6-9 broker和nameserver的访问测试
• 第7章 【手写篇 – 第四步】客户端SDK设计与实战
• 7-1 本章介绍
• 7-10 消息重平衡过程的梳理
• 7-11 重平衡问题讲解
• 7-12 Kakfa,RocketMQ中的重平衡策略了解
• 7-13 消息消费需要考虑哪些问题
• 7-14 消费者消息拉取监听器实现
• 7-15 消息拉去请求链路完善
• 7-16 消费端拉消息场景测试
• 7-17 消费端拉数据后回应ack
• 7-18 全链路mq推送与消费验证
• 7-19 本章回顾
• 7-2 如何设计一款消息队列的客户端SDK
• 7-3 Netty异步转同步的功能封装
• 7-4 Producer角色如何与NameServer建立网络连接
• 7-6 客户端拉取出broker地址功能实现
• 7-7 Producer端消息发送基础接口定义
• 7-8 Producer发送数据到Broker端持久化实现
• 7-9 Consumer基础接口的开发
• 第8章 【手写篇 -第五步】broker高可用架构拓展实战
• 8-1 本章介绍
• 8-10 Broker主从异步复制的实现
• 8-11 Broker主从同步复制实现与验证
• 8-12 Broker主从切换过程中会遇到的问题
• 8-13 Broker主节点宕机监听处理
• 8-14 Broker主从切换效果实现
• 8-15 本章总结
• 8-2 Broker的主从复制思路整理
• 8-3 topic的动态创建实现
• 8-4 动态创建topic效果验证
• 8-5 Broker集群模式下的实例注册逻辑实现
• 8-6 面对Broker集群，客户端拉取ip的实现
• 8-7 Broker集群的复制逻辑剖析
• 8-8 Broker的主从链接通道初始化建立实现
• 8-9 Broker主从节点多目录文件拆解
• 第9章 【手写篇 – 第六步】复杂消息处理(一） – 消息重试功能的设计与实现
• 9-1 本章介绍
• 9-10 时间轮事件事件回调通知
• 9-11 重试监听器回调
• 9-12 重试主题的自动创建
• 9-13 消息重试队列推送和消费的实现
• 9-14 本章回顾
• 9-2 消息重试设计思路实现
• 9-3 消息重试Netty请求链路打通
• 9-4 Consumer消息重试链路在时间轮中的运作细节梳理
• 9-5 重试消息的存储效果验证
• 9-6 时间轮组件的实现（一）
• 9-7 时间轮组件的实现（二）
• 9-8 时间轮组件的效果验证
• 9-9 多极时间轮的切换验证
• 第10章 【手写篇 – 第七步】复杂消息处理(二） – 延迟消息功能的设计与实现
• 10-1 本章介绍
• 10-2 延迟消息设计以及使用场景介绍
• 10-3 延迟消息的效果实现
• 10-4 延迟消息的持久化实现
• 10-5 延迟消息的数据恢复如何实现
• 10-6 本章介绍
• 第11章 【手写篇 – 第八步】复杂消息处理(三） -事务消息功
• 11-1 本章介绍
• 11-2 事务消息设计思路回顾
• 11-3 事务消息的half消息提交
• 11-4 本地事务回调接口的实现
• 11-5 事务消息回调处理
• 11-6 事务消息的效果验证
• 11-7 本章回顾
• 第12章 【手写篇 – 第九步】可视化管理控制台设计与实战1
• 12-1 本章介绍
• 12-2 基础控制台的接口开发
• 12-3 Broker数据的上报实现
• 12-4 控制台的基础开发思路梳理
• 12-5 控制台效果演示
• 12-6 本章介绍
• 第13章 【手写篇 – 第十步】基于消息队列综合实战
• 13-1 本章介绍
• 13-2 MQ多泳道环境的实现
• 13-3 Kafka和实时计算
• 13-4 本章回顾
• 第14章 课程回顾与常见面试题剖析
• 14-1 本章介绍
• 14-2 课程回顾
• 资料
• 源码+文档