置顶必读(2) |《SpringBoot + MQ全家桶实战》专栏目录清单，简直夯爆了！

本文收录于《SpringBoot MQ全家桶实战》专栏。专栏围绕 Spring Boot 环境下主流消息中间件的集成、原理、实战、选型与架构设计展开覆盖RabbitMQ、Kafka、RocketMQ、Pulsar、NATS、ZeroMQ等常见消息技术栈持续更新中欢迎订阅学习。如果你正在经历这些问题消息丢失、重复消费、消息堆积、延迟消息不会设计、削峰填谷不会落地、分布式事务不会处理、MQ 选型总是拿不准那么这套专栏就是为你准备的。本专栏不是零散的 API 教程而是一套真正面向企业实战、架构设计、生产可用、面试进阶的 MQ 系统化学习路线。我们会从基础概念 → Spring Boot 集成 → 可靠性保障 → 高并发优化 → 生产环境治理 → 选型方法论逐步展开帮助你把 MQ 从“会用”提升到“会设计、会排障、会讲清楚”。专栏持续更新中后续还会不断补充更多实战案例、性能调优、故障排查、源码分析、面试高频题解析与项目落地方案。一次订阅持续学习后续更新内容无需重复付费适合长期收藏与系统进阶。本专栏导读介绍请往这里走《SpringBoot MQ全家桶实战》专栏导读欢迎前往阅读打卡~全文目录 摘要 完整学习路径总览300节一、MQ 零基础入门专题8节⚪ 认知觉醒篇⚪ 架构选型篇二、RabbitMQ 专题42节 基础入门篇 可靠性机制篇 消费端设计篇 高级特性篇 架构设计篇 业务实战篇⚫ 性能优化篇⚪ 集群与运维篇三、Apache Kafka 专题44节 基础入门篇 核心机制篇 消费模型篇 高级特性篇 架构设计篇 业务实战篇⚫ 性能调优篇️ 运维与高可用篇 排障与面试篇四、Apache RocketMQ 专题44节 基础入门篇 核心机制篇 消费模型篇 高级特性篇 架构设计篇 业务实战篇⚫ 性能调优篇️ 运维与高可用篇 排障与面试篇五、Apache ActiveMQ 专题44节 基础入门篇 核心机制篇 消费模型篇 高级特性篇 架构设计篇 业务实战篇⚫ 性能调优篇️ 运维与高可用篇 排障与面试篇六、Apache Pulsar 专题46节 基础入门篇 核心机制篇 消费模型篇 高级特性篇 架构设计篇 业务实战篇⚫ 性能调优篇️ 运维与高可用篇 排障与面试篇七、NATS 专题38节 基础入门篇 核心机制篇 消费模型篇 高级特性篇 架构设计篇 实战篇⚫ 运维与调优篇 排障与面试篇八、ZeroMQ 专题30节 基础入门篇 核心机制篇 通信模型篇 高级特性篇 架构设计篇 实战篇九、MQ 终极专题5节 学习福利 · 限时开放 Who am I? 摘要在高并发、微服务、异步化、削峰填谷、最终一致性这些关键词越来越常见的今天消息队列已经不只是“中间件”而是很多系统架构设计里绕不开的核心能力。你可能已经写过RabbitTemplate.convertAndSend()也可能接触过 Kafka 的 Topic / Partition甚至在项目里用过 RocketMQ 的延迟消息。但真正决定你能不能从“会用 MQ”进阶到“会设计 MQ 架构”的不是 API 熟练度而是你是否建立起一套完整的消息驱动系统思维。这套专栏正是为这个目标准备的。它不是简单堆砌概念也不是只讲某一个 MQ 产品而是围绕SpringBoot MQ 全家桶实战教学演练带你从入门、进阶到实战、调优、运维、面试一步步建立完整认知最终形成自我沉淀将所学灵活运用到实际应用中去。 完整学习路径总览300节章节主题定位建议时长第1章零基础入门与全景认知 入门1-2周第2章RabbitMQ 基础入门 进阶1-2周第3章RabbitMQ 核心机制与实战 高阶1-2周第4章Kafka 基础入门 进阶1-2周第5章Kafka 核心机制与性能调优 高阶2-3周第6章RocketMQ 基础入门 进阶1-2周第7章RocketMQ 核心机制与业务实战 高阶2-3周第8章ActiveMQ 与 JMS 体系 经典1周第9章Pulsar 专题 云原生1-2周第10章NATS 专题⚡ 轻量高性能1周第11章ZeroMQ 专题 通信框架1周第12章消息可靠性与最终一致性️ 核心1-2周第13章幂等、顺序、延迟、重试、DLQ 机制1-2周第14章高并发削峰填谷与异步解耦 架构1-2周第15章微服务消息驱动架构设计️ 架构1-2周第16章业务实战订单、日志、数据同步 实战2-3周第17章性能调优与吞吐优化⚙️ 调优1-2周第18章运维部署与高可用设计️ 运维1-2周第19章排障实战与高频面试题 面试1周第20章MQ 选型方法论与终极总结 收官1周…持续更新中 扩展持续完善一、MQ 零基础入门专题8节⚪ 认知觉醒篇第1节为什么要学 MQ后端开发的进阶分水岭 核心价值第2节生活中的 MQ快递驿站模型 异步思维的深度解析第3节MQ 的三大核心神技解耦 异步 削峰填谷第4节MQ 基础名词大通关Producer / Consumer / Broker / Topic / Queue⚪ 架构选型篇第5节主流 MQ 家族大阅兵RabbitMQ / Kafka / RocketMQ / Pulsar 谁主沉浮第6节消息协议全景图AMQP / MQTT / STOMP / JMS 协议深度对比第7节如何选择你的第一个 MQ业务场景驱动的技术选型方法论第8节SpringBoot 集成 MQ 的通用套路从依赖导入到自动配置的底层逻辑二、RabbitMQ 专题42节 基础入门篇第1节环境搭建与基础入门核心概念 AMQP 协议 快速上手第2节核心概念详解Exchange / Queue / Binding / RoutingKey 架构模型第3节五种消息模型详解工作模式 应用场景 对比分析第4节Topic 模式深度实战通配符路由 匹配规则 业务建模第5节消息发送与消费流程生产者 消费者 生命周期 可靠性机制篇第6节消息持久化机制数据安全 磁盘存储 durability第7节消息确认机制ACK Confirm 可靠性保障第8节消息丢失问题分析生产端 / Broker / 消费端第9节生产者确认机制Confirm 异步回调 性能优化第10节Return 机制详解Mandatory 路由失败处理 消费端设计篇第11节ACK 机制对比自动ACK vs 手动ACK 消费安全第12节消费失败重试机制重试策略 死信转移第13节幂等消费实战去重设计 Redis / DB 方案第14节重复消费问题分析消息投递语义 解决方案第15节消息顺序性问题顺序消费 分区策略 高级特性篇第16节死信队列设计DLQ 死信路由 应用场景第17节TTL 机制详解消息过期 队列过期 应用模型第18节延迟队列实现TTL DLX 技术选型第19节延迟插件实战x-delayed-message 原理解析第20节订单超时关闭延迟队列 业务建模 架构设计篇第21节消息可靠投递最终一致性 多重保障机制第22节最终一致性方案MQ 本地事务 补偿机制第23节Outbox 模式实战本地消息表 CDC 思想第24节分布式事务解决方案2PC / TCC / MQ 对比第25节电商订单系统设计业务拆分 消息驱动架构 业务实战篇第26节秒杀系统设计削峰填谷 限流 异步化第27节系统解耦设计事件驱动 异步架构第28节日志收集架构异步写入 流式处理第29节微服务消息驱动事件总线 解耦通信⚫ 性能优化篇第30节消息积压问题堆积原因 扩容方案第31节高并发消费优化吞吐量 QPS 提升第32节消费者模型设计线程池 Prefetch 限流第33节存储机制解析内存 磁盘 Page Cache第34节Lazy Queue 实战惰性队列 内存优化⚪ 集群与运维篇第35节集群模式详解普通集群 数据分布第36节镜像队列设计HA 数据同步机制第37节节点宕机处理故障恢复 高可用保障第38节生产部署优化参数调优 性能配置第39节监控与告警Prometheus 可观测性第40节故障排查实战问题定位 排查流程第41节消息异常分析积压 重复 丢失第42节面试高频问题核心原理 场景题三、Apache Kafka 专题44节 基础入门篇第1节环境搭建与基础入门核心概念 快速上手第2节核心概念详解Broker / Topic / Partition / Offset第3节架构原理解析分布式设计 数据流转第4节消息发送与消费流程Producer Consumer第5节Topic 与 Partition 机制分区策略 扩展性 核心机制篇第6节消息存储机制日志结构 顺序写入第7节消息确认机制ACK 机制 可靠性保障第8节消息丢失问题分析生产端 Broker 消费端第9节副本机制详解ISR Leader 选举第10节数据一致性设计高可用 数据安全 消费模型篇第11节消费模型详解Pull 模式 设计思想第12节消费者组机制Consumer Group Rebalance第13节Offset 管理机制提交策略 位移控制第14节重复消费问题原因分析 解决方案第15节消息顺序性问题分区有序 全局有序 高级特性篇第16节消息重试机制失败处理 重试策略第17节死信队列设计DLQ 实现思路第18节延迟消息实现时间轮 方案对比第19节消息压缩机制性能优化 存储优化第20节批量发送与批量消费吞吐优化 架构设计篇第21节消息可靠投递生产者 Broker 消费端第22节最终一致性方案MQ 分布式系统设计第23节Outbox 模式实战事务消息 解耦设计第24节分布式事务解决方案Kafka 实现思路第25节微服务架构设计基于消息驱动 业务实战篇第26节电商订单系统设计异步架构 解耦[第27节秒杀系统削峰填谷高并发处理第28节日志收集系统ELK Kafka 架构第29节实时数据处理流式计算基础第30节数据同步架构缓存 数据一致性⚫ 性能调优篇第31节消息积压问题原因分析 解决方案第32节高并发优化策略吞吐量提升第33节生产者性能调优批量 压缩 ACK第34节消费者性能优化拉取 并发模型第35节磁盘与页缓存机制顺序IO优化️ 运维与高可用篇第36节集群架构设计多 Broker 扩展性第37节副本同步机制ISR 数据恢复第38节Broker 宕机处理故障转移机制第39节生产环境部署参数配置优化第40节监控与告警系统Kafka 运维体系 排障与面试篇第41节常见故障排查线上问题分析第42节消息堆积与消费延迟排查与优化第43节重复消费与数据丢失问题定位第44节高频面试题解析Kafka 核心考点四、Apache RocketMQ 专题44节 基础入门篇第1节环境搭建与基础入门核心概念 快速上手第2节核心概念详解Producer / Consumer / Topic / Tag第3节架构原理解析NameServer Broker 机制第4节消息发送与消费流程同步 异步 单向第5节Topic 与 队列模型逻辑结构 设计思想 核心机制篇第6节消息存储机制CommitLog ConsumeQueue第7节消息刷盘机制同步刷盘 异步刷盘第8节消息确认机制ACK 重试机制第9节消息丢失问题分析生产端 Broker 消费端第10节高可用机制主从复制 故障切换 消费模型篇第11节消费模式详解集群模式 广播模式第12节消费重试机制失败重试 死信队列第13节幂等消费设计去重方案 实现思路第14节顺序消息机制局部有序 全局有序第15节延迟消息机制定时消息实现原理 高级特性篇第16节事务消息机制半消息 最终一致性第17节死信队列设计DLQ 原理 实战应用第18节消息过滤机制Tag SQL 过滤第19节批量消息与压缩机制性能优化第20节消息轨迹追踪Trace 机制 架构设计篇第21节消息可靠投递完整方案 架构设计第22节最终一致性方案事务消息实战第23节分布式事务解决方案MQ 实现思路第24节微服务架构设计基于消息驱动第25节电商订单系统设计MQ 架构落地 业务实战篇第26节秒杀系统削峰填谷高并发实战第27节订单系统异步解耦业务拆分设计第28节延迟消息实战订单超时关闭第29节日志异步处理架构削峰 解耦第30节数据同步架构缓存 数据一致性⚫ 性能调优篇第31节消息积压问题原因分析 解决方案第32节高并发优化策略吞吐量提升第33节生产者性能调优批量 重试机制第34节消费者性能优化并发消费模型第35节存储性能优化刷盘 文件结构️ 运维与高可用篇第36节集群架构设计多 Broker 部署第37节主从同步机制数据复制原理第38节Broker 宕机处理故障恢复机制第39节生产环境部署参数配置优化第40节监控与告警系统运维体系设计 排障与面试篇第41节常见故障排查线上问题分析第42节消息堆积与消费延迟排查与优化第43节重复消费与消息丢失问题定位第44节高频面试题解析核心考点总结五、Apache ActiveMQ 专题44节 基础入门篇第1节环境搭建与基础入门核心概念 快速上手第2节核心概念详解Broker / Queue / Topic / JMS第3节架构原理解析消息模型 设计思想第4节消息发送与消费流程生产者 消费者第5节点对点与发布订阅模式Queue vs Topic 核心机制篇第6节消息持久化机制KahaDB 存储策略第7节消息确认机制ACK 事务机制第8节消息丢失问题分析可靠性保障方案第9节事务消息机制本地事务 XA 事务第10节消息重试机制失败处理 重发策略 消费模型篇第11节消费模式详解同步消费 异步消费第12节消费者负载均衡多消费者机制第13节幂等消费设计重复消费解决方案第14节消息顺序性问题顺序消费机制第15节死信队列设计DLQ 实现原理 高级特性篇第16节消息过滤机制Selector 机制第17节延迟消息实现定时投递机制第18节消息优先级机制Priority 设计第19节虚拟主题Virtual Topic 实战第20节网络连接器Network of Brokers 架构设计篇第21节消息可靠投递完整方案 架构设计第22节最终一致性方案MQ 数据一致性第23节分布式事务解决方案JMS 实现思路第24节系统解耦设计基于消息驱动第25节传统系统改造引入 MQ 架构 业务实战篇第26节订单系统异步解耦业务拆分设计第27节日志异步处理削峰 解耦第28节通知系统设计短信 邮件第29节任务队列设计异步任务处理第30节数据同步架构系统间通信⚫ 性能调优篇第31节消息积压问题原因分析 解决方案第32节高并发优化策略吞吐量提升第33节消费者性能优化并发处理模型第34节存储性能优化持久化调优第35节网络通信优化连接 传输优化️ 运维与高可用篇第36节集群架构设计Master-Slave 模式第37节高可用方案共享存储 ZooKeeper第38节Broker 宕机处理故障恢复机制第39节生产环境部署配置优化第40节监控与告警系统运维体系 排障与面试篇第41节常见故障排查线上问题分析第42节消息堆积与延迟问题排查第43节重复消费与数据异常问题定位第44节高频面试题解析JMS MQ 考点六、Apache Pulsar 专题46节 基础入门篇第1节环境搭建与基础入门核心概念 快速上手第2节核心概念详解Tenant / Namespace / Topic第3节架构原理解析Broker BookKeeper 分离存储第4节消息发送与消费流程Producer Consumer第5节Topic 与分区机制分区设计 扩展能力 核心机制篇第6节消息存储机制Ledger Segment 结构第7节消息确认机制ACK 累积确认第8节消息丢失问题分析可靠性保障方案第9节多副本机制BookKeeper 副本设计第10节一致性与持久化机制数据安全设计第11节消息重试机制失败处理 重试策略第12节消息压缩机制性能优化 存储优化 消费模型篇第13节消费模式详解Exclusive / Shared / Failover第14节消费者组机制订阅模型 负载均衡第15节消息顺序性问题有序消费设计第16节重复消费问题幂等设计 去重方案第17节死信队列设计DLQ 实现思路 高级特性篇第18节延迟消息机制定时消息实现第19节消息回放机制Replay 历史数据消费第20节多租户机制Tenant Namespace 隔离第21节跨地域复制Geo-Replication第22节函数计算Pulsar Functions 实战 架构设计篇第23节消息可靠投递生产端 Broker 存储第24节最终一致性方案MQ 分布式架构第25节微服务架构设计事件驱动系统第26节实时数据平台设计流式处理架构第27节数据湖集成大数据生态 业务实战篇第28节电商系统架构异步化 解耦第29节日志收集系统流式数据处理第30节实时推荐系统消息驱动第31节IoT 消息系统设备通信架构第32节数据同步系统跨系统一致性⚫ 性能调优篇第33节消息积压问题原因分析 优化方案第34节高并发优化策略吞吐量提升第35节生产者性能调优批量 压缩第36节消费者性能优化并发消费模型第37节存储性能优化BookKeeper 调优️ 运维与高可用篇第38节集群架构设计多 Broker 多 Bookie第39节副本机制数据复制 容灾第40节Broker 宕机处理故障恢复机制第41节生产环境部署配置优化第42节监控与告警系统运维体系 排障与面试篇第43节常见故障排查线上问题分析第44节消息堆积与延迟问题排查第45节重复消费与数据异常问题定位第46节高频面试题解析核心原理总结七、NATS 专题38节 基础入门篇第1节环境搭建与基础入门核心概念 快速上手第2节核心概念详解Subject / Publisher / Subscriber第3节架构原理解析轻量级消息模型第4节消息发布与订阅机制Pub/Sub 模型第5节请求响应模式Request-Reply 实现 核心机制篇第6节消息传输机制高性能 低延迟第7节消息可靠性设计JetStream 机制第8节消息持久化机制Stream 存储第9节ACK 机制详解确认与重试第10节消息丢失问题分析可靠性方案 消费模型篇第11节消费模式详解Push vs Pull第12节消费者组机制Queue Group第13节消息重试机制失败处理第14节顺序消费机制有序性保障第15节死信队列设计DLQ 实现思路 高级特性篇第16节JetStream 实战流式消息系统第17节消息回放机制Replay 功能第18节延迟消息实现时间调度第19节流控机制Backpressure 控制第20节多租户设计隔离机制 架构设计篇第21节云原生架构设计微服务通信第22节消息驱动架构事件驱动设计第23节最终一致性方案MQ 分布式第24节系统解耦设计高并发场景第25节实时通信系统设计低延迟场景 实战篇第26节微服务通信实战服务间调用第27节实时消息推送系统WebSocket MQ第28节日志收集系统轻量架构第29节IoT 消息系统设计设备通信第30节高并发系统设计低延迟优化⚫ 运维与调优篇第31节性能优化策略吞吐量 延迟第32节集群架构设计高可用部署第33节节点故障处理自动恢复第34节生产环境部署配置优化第35节监控与告警系统运维体系 排障与面试篇第36节常见问题排查线上问题分析第37节消息延迟与丢失问题定位第38节高频面试题解析核心考点八、ZeroMQ 专题30节 基础入门篇第1节环境搭建与基础入门核心概念 快速上手第2节核心概念详解Socket / Context / Pattern第3节架构原理解析去中心化通信模型第4节消息通信模式请求响应 发布订阅第5节多种通信模式详解Push/Pull Pipeline 核心机制篇第6节消息传输机制高性能通信原理第7节异步通信模型非阻塞设计第8节线程模型解析多线程通信第9节消息队列机制内存队列设计第10节可靠性机制消息保障方案 通信模型篇第11节请求响应模型REQ/REP第12节发布订阅模型PUB/SUB第13节管道模型Push/Pull第14节Dealer/Router 模型高级路由第15节多模式组合设计复杂通信 高级特性篇第16节负载均衡机制分布式通信第17节高性能优化零拷贝机制第18节网络协议支持TCP / IPC / INPROC第19节安全机制加密 认证第20节消息序列化协议设计 架构设计篇第21节分布式通信架构系统设计第22节微服务通信方案高性能 RPC第23节实时系统设计低延迟架构第24节高并发系统设计通信优化第25节消息驱动架构事件系统 实战篇第26节分布式任务系统任务调度第27节实时数据处理流式通信第28节日志收集系统高性能架构第29节RPC 框架实现通信封装第30节高频交易系统设计极低延迟九、MQ 终极专题5节第1节MQ 专题五大消息队列对比Kafka vs RabbitMQ vs RocketMQ vs Pulsar第2节MQ 专题技术选型方法论业务场景 架构设计第3节MQ 专题高并发系统设计削峰填谷 限流 解耦第4节MQ 专题分布式事务全解MQ 实现方案第5节MQ 专题面试终极总结大厂高频题加油这一套系统的完成绝对是技术生涯的一大里程碑 学习福利 · 限时开放 这套《SpringBoot MQ全家桶实战》专栏真正想带给你的不只是“会发消息、会收消息”而是一整套可以迁移到真实项目里的消息驱动架构思维。当你把这套内容学完你会明显发现自己看系统的方式变了你不再只关心“这条消息怎么发出去”而是会开始思考这条消息该不该发发到哪一种 MQ 更合适如何保证消息不丢、不重、不过期消费失败后怎么兜底如何支撑高并发场景如何设计可观测、可恢复、可扩展的消息系统这才是 MQ 真正的进阶之路。最后如果这篇文章对你有所帮助帮忙给作者来个一键三连关注、点赞、收藏您的支持就是我坚持写作最大的动力。同时欢迎大家关注技术号:「猿圈奇妙屋」 以便学习更多同类型的技术文章免费白嫖最新BAT互联网公司面试题、4000G PDF编程电子书、简历模板、技术文章Markdown文档等海量资料。ps本文涉及所有源代码均已上传至Gitee开源供同学们直接对照学习 Gitee传送门同时原创开源不易欢迎给个star想体验下被的感jio非常感谢❗ Who am I?我是 bug菌活跃于 CSDN | 掘金 | InfoQ | 51CTO | 华为云 | 阿里云 | 腾讯云 等技术社区CSDN 博客之星 Top30、华为云多年度十佳博主卓越贡献奖、掘金多年度人气作者 Top40掘金、InfoQ、51CTO 等平台签约及优质作者全网粉丝累计30w。更多高质量技术内容及成长资料可查看这个合集入口 点击查看 硬核技术号「猿圈奇妙屋」期待你的加入一起进阶、一起打怪升级。- End -