01
消息队列概述
什么是消息队列、为什么交易系统需要消息队列、核心价值（解耦、异步、削峰）
基础架构
02
消息模型详解
点对点模型(Queue)、发布订阅模型(Topic)、区别与适用场景
模型对比
03
RabbitMQ入门
核心概念(Exchange/Queue/Binding)、安装启动、Hello World
RabbitMQ入门
04
RabbitMQ交换机类型
Direct · Topic · Fanout · Headers Exchange
交换机路由
05
RabbitMQ高级特性
消息确认(ACK)、死信队列(DLX)、延迟队列、消息持久化
可靠性高级
06
Kafka核心概念
Topic/Partition · Producer/Consumer · Broker/Cluster · Offset
Kafka概念
07
Kafka安装与配置
Zookeeper依赖、集群搭建、命令行操作Topic
部署运维
08
Kafka生产者详解
发送模式(同步/异步)、分区策略、ACKS可靠性配置
生产者可靠性
09
Kafka消费者详解
消费组、Rebalance、位移提交(自动/手动)、幂等消费
消费者偏移量
10
Kafka高级特性
日志压缩(Log Compaction)、事务消息、Exactly-Once语义
高级Exactly-Once
11
RocketMQ入门
核心概念(NameServer/Broker/Producer/Consumer)、安装部署
RocketMQ入门
12
RocketMQ消息类型
普通消息、顺序消息、事务消息、定时/延时消息
消息类型事务
13
RocketMQ高级特性
消息重试、死信队列、消息轨迹、批量消息
高级重试
14
消息队列选型对比
RabbitMQ vs Kafka vs RocketMQ vs Pulsar · 性能/可靠性/功能
选型对比
15
消息序列化与协议
JSON · Avro · Protobuf · Thrift · 序列化对性能影响
序列化协议
16
消息幂等性设计
唯一ID生成、去重表、状态机、分布式锁方案
幂等设计
17
消息顺序性保证
全局/局部顺序、Kafka分区顺序、RocketMQ队列顺序
顺序分区
18
消息可靠性保障
生产端重试、Broker持久化、消费端ACK、消息回溯
可靠性ACK
19
消息积压处理
积压原因分析、扩容消费端、临时Topic分流、降级策略
积压运维
20
消息轨迹与链路追踪
OpenTracing规范、SkyWalking集成、日志埋点方案
追踪可观测
21
消息队列监控与告警
Prometheus+Grafana、TPS/延迟/积压量、告警规则
监控告警
22
消息队列高可用设计
集群部署、主从切换、多副本、故障转移
高可用集群
23
消息队列安全
SSL/TLS加密、SASL认证、ACL权限控制、网络隔离
安全加密
24
交易系统订单场景实战
订单创建异步通知、库存扣减消息、支付回调处理
实战订单
25
交易系统风控场景实战
实时风控规则引擎、异常交易检测、消息延迟分析
风控实时
26
交易系统对账场景实战
每日对账文件生成、差异消息处理、自动调账流程
对账实战
27
消息队列与微服务集成
Spring Boot + RabbitMQ/Kafka/RocketMQ · 异步通信
微服务Spring
28
消息队列与大数据集成
Kafka Connect、Flink消费Kafka、实时数仓架构
大数据Flink
29
消息队列压测与调优
JMeter/Kafka压测工具、参数调优(批量/缓冲区/线程)
压测调优
30
消息队列故障排查实战
消息丢失、重复消费、顺序错乱 · 排查工具与思路
排障实战