RocketMQ 分布式消息中间件实战
课程简介
本课程围绕 Apache RocketMQ 展开,从基础入门、核心原理到高级特性、SpringBoot 项目实战,由浅入深讲解 RocketMQ 分布式消息中间件。RocketMQ 是阿里开源、Apache 顶级分布式消息系统,经历多年双十一万亿级消息流转打磨,广泛应用于异步解耦、流量削峰、分布式事务、即时通讯等业务场景。课程结合大量实操案例、代码演示、问题排错,帮助大家掌握 RocketMQ 的使用、原理、集群部署以及业务落地,具备企业级消息中间件开发与运维能力。
课程内容
第一章 RocketMQ 快速入门
- RocketMQ 简介与发展历史:起源、阿里双十一实战表现、项目发展历程
- 核心组件概念详解:Producer、ProducerGroup、Consumer、ConsumerGroup、NameServer、Broker、Topic、MessageQueue 核心角色职责
- 环境部署实战
- 二进制非 Docker 安装,解决内存不足启动报错问题
- Java 原生 API 编写生产者、消费者完成消息收发
- 解决 Broker 内网 IP 访问失败常见坑
- Docker 快速部署 RocketMQ 服务
- 部署 RocketMQ‑Console 可视化管理控制台
- 基础消息开发
- Topic 创建,同步消息发送、异步消息发送
- Message 消息结构详解,Tag 标签过滤消费
- SQL 语法消息属性过滤,掌握过滤配置开启方式
第二章 RocketMQ 核心原理
- 顺序消息:业务场景(订单流转)、生产者消息投递策略、有序消费者编码实现,理解顺序消息实现原理
- 分布式事务消息
- 分布式事务问题场景
- 半消息(Half Message)、消息回查核心概念
- 事务消息完整执行流程、生产者 / 监听器 / 消费者完整代码实现,理解 Commit/Rollback 逻辑
- Consumer 消费者原理
- Push、Pull 消费模式底层实现,长轮询机制原理
- 集群消费模式、广播消费模式区别与代码实践
- 消息重复消费问题,业务幂等性解决方案
- RocketMQ 存储机制
- CommitLog、ConsumeQueue 存储结构,零拷贝技术
- 同步刷盘、异步刷盘原理,不同刷盘方式优缺点与配置
第三章 RocketMQ 高级特性与项目实战
- 消息重试策略
- Producer 生产者发送失败重试配置
- Consumer 消费异常重试、超时重试,手动控制最大重试次数
- RocketMQ 集群部署
- 4 种集群模式对比:单 Master、多 Master、多 Master 多 Slave 异步复制、多 Master 多 Slave 同步双写,各模式优缺点、适用场景
- Docker 搭建 2M2S(两主两从)集群实操,完整配置文件讲解
- SpringBoot 整合 RocketMQ
- starter 依赖安装与配置
- SpringBoot 实现普通消息生产、消费
- SpringBoot 下分布式事务消息完整开发
- 企业级项目实战:分布式 WebSocket 即时通讯
- 分布式 IM 业务痛点,RocketMQ 广播模式解决方案
- 结合 WebSocket+MongoDB+RocketMQ 实现跨服务消息推送实战开发
课程亮点
✅ 实战导向,踩坑教学 课程还原真实开发遇到的各类报错:JVM 内存不足启动失败、Broker 内网 IP 外部无法访问、SQL 过滤不生效、异步发送 shutdown 导致消息丢失等,讲解报错原因和解决方案,学完能够处理生产常见问题。
✅ 原理 + 代码双结合 不只教 API 调用,深入拆解底层原理:长轮询、存储结构、事务消息回查机制、集群 HA 原理;每一个知识点配套完整可运行 Java 代码,原生 API 和 SpringBoot 两套实现。
✅ 覆盖企业生产场景 包含顺序消息、分布式事务消息、集群搭建、消息重试、幂等性处理,同时落地分布式 WebSocket 即时通讯真实业务案例,对接实际工作业务。
✅ 部署方式全覆盖 同时讲解二进制手动部署、Docker 容器部署,可视化控制台安装,掌握开发环境、集群环境搭建。
✅ 知识点体系完整 从基础入门→核心原理→高级特性→集群运维→项目实战完整闭环,适合开发人员掌握消息中间件技术栈,应对面试和项目开发。
适合人群
- Java 后端开发工程师,想要学习分布式消息中间件
- 想要掌握 RocketMQ 用于项目解耦、分布式事务开发的开发者
- 需要应对中间件相关面试,理解 RocketMQ 底层原理的同学
- 想要学习分布式 IM、异步业务场景实现的开发人员
学习收获
- 熟练掌握 RocketMQ 环境搭建,理解各个核心组件作用
- 熟练使用原生 API、SpringBoot 完成各类消息开发(普通消息、顺序消息、事务消息)
- 理解 RocketMQ 存储、消费、集群底层原理,看懂生产配置
- 掌握消息重试、重复消费问题处理方案
- 可以独立完成 RocketMQ 集群部署,理解主从同步机制
- 能够基于 RocketMQ 完成分布式业务落地开发
老师介绍
老苗一对一私教:https://yjoffer.com/aboutus/one2one/one2one.html
