01
消息延迟概述
什么是消息延迟 · 常见表现 · 对业务的影响
概念基础
02
消息队列基础
主流MQ选型对比 · Topic/Partition/Consumer Group
KafkaRocketMQRabbitMQ
03
延迟产生原因分析
网络抖动 · 磁盘IO瓶颈 · GC停顿 · 消费端处理慢
根因网络GC
04
消息发送端优化
批量发送 · 异步发送 · 压缩 · acks合理设置
生产者吞吐
05
消息存储优化
页缓存 · 顺序写盘 · 零拷贝 · 分区策略
存储OS
06
消息消费端优化
批量拉取 · 并发消费 · 长轮询与短轮询
消费者拉取
07
网络层优化
TCP参数调优 · 连接复用 · 心跳 · 带宽限制
网络TCP
08
序列化与反序列化
Protobuf vs JSON · 性能对比 · 自定义序列化
序列化性能
09
消息堆积处理
堆积原因 · 临时扩容 · 降级策略 · 死信队列
堆积容错
10
延迟监控体系
端到端延迟 · P99/P999 · 链路追踪(OpenTelemetry)
监控可观测
11
Kafka延迟实战
ISR机制 · min.insync.replicas · acks · 重试
Kafka实战
12
RocketMQ延迟实战
延迟消息 · 事务消息 · 批量消息 · 消费重试
RocketMQ事务
13
RabbitMQ延迟实战
TTL · 死信交换机 · 延迟插件 · 惰性队列
RabbitMQTTL
14
Pulsar延迟实战
BookKeeper存储 · 分层存储 · IO隔离 · Backlog
Pulsar存储
15
Redis作为消息队列
List/Stream/PubSub延迟对比 · 可靠性权衡
Redis轻量
16
数据库变更捕获 (CDC)
Debezium延迟 · Binlog消费 · 快照与增量
CDCDebezium
17
流处理框架延迟
Flink Exactly-Once · Watermark · Checkpoint
Flink流处理
18
容器化环境延迟
K8s CNI · Pod启动延迟 · 资源争抢
K8s容器
19
云原生消息服务
AWS SQS/SNS · 阿里云RocketMQ · 腾讯云CMQ
云服务对比
20
延迟压测方法论
JMeter · Locust · 自研工具 · 指标采集
压测性能
21
全链路延迟诊断
TraceID传递 · Span关联 · 耗时分布 · 瓶颈定位
链路诊断
22
代码层面优化
减少锁竞争 · 线程池调优 · 异步化 · 协程
编码并发
23
JVM层面优化
GC日志分析 · G1/ZGC调优 · 堆外内存 · DirectBuffer
JVMGC
24
操作系统层面优化
CPU绑定 · 内存大页 · 文件系统 · 网卡多队列
OS内核
25
延迟与吞吐量权衡
批量大小 · 缓冲区 · 背压机制 · 限流策略
权衡背压
26
异地多活与延迟
跨机房同步 · 两地三中心 · 全球部署 · 一致性
多活异地
27
延迟SLA制定
SLO定义 · SLI采集 · 告警阈值 · 故障预案
SLA运维
28
经典延迟案例复盘
双十一大促 · 秒杀 · 金融交易 · IoT场景
案例复盘
29
延迟优化工具链
Arthas · async-profiler · Wireshark · iostat · perf
工具诊断
30
未来趋势
eBPF延迟观测 · RDMA网络 · 持久化内存 · Serverless MQ
前沿eBPF