01
消息接口概述
什么是消息接口 · 核心价值 · 与API区别 · 典型应用场景
概念入门
02
消息模型基础
点对点(P2P) · 发布订阅(Pub/Sub) · Producer/Consumer/Broker/Topic
模型核心
03
消息协议入门
HTTP轮询/长轮询 · WebSocket · AMQP · MQTT
协议网络
04
消息序列化
JSON · Protobuf · Avro vs Thrift · 性能测试
序列化编码
05
消息路由机制
Direct · Topic · Fanout · Headers
路由交换机
06
消息可靠性
ACK确认 · 持久化 · 重试策略 · 死信队列(DLQ)
可靠性ACK
07
消息顺序性
全局/局部顺序 · 实现方案 · 分区保证 · 顺序消费代价
顺序分区
08
消息幂等性
幂等定义 · 重复原因 · 去重方案 · 业务层实现
幂等去重
09
消息事务
本地消息表 · 事务消息(RocketMQ) · 最大努力通知 · TCC
事务一致性
10
消息积压处理
积压原因 · 消费扩容 · 降级策略 · 监控告警
积压运维
11
消息过滤
Tag过滤 · SQL92 · 自定义Filter · 性能对比
过滤表达式
12
消息回溯
时间戳回溯 · Offset回溯 · 应用场景 · 局限性
回溯重放
13
消息轨迹
轨迹采集 · 存储方案 · 查询分析 · 可视化
轨迹链路
14
消息延迟
延迟消息实现 · 延迟级别 · 延迟队列 · 精度控制
延迟定时
15
消息批量
批量发送/消费 · 大小调优 · 批量与吞吐量
批量吞吐
16
消息压缩
Gzip · Snappy · LZ4 · 压缩比与CPU开销
压缩算法
17
消息安全
SASL认证 · TLS加密 · 消息加密 · ACL控制
安全加密
18
消息监控
TPS/延迟/积压 · Prometheus+Grafana · 告警规则 · 监控大盘
监控可观测
19
消息高可用
主从架构 · 多副本 · Leader选举 · 故障转移
高可用HA
20
消息容灾
同城双活 · 异地多活 · 切换策略 · 数据一致性
容灾双活
21
消息存储
CommitLog · ConsumeQueue · 刷盘策略 · 零拷贝
存储文件
22
消息网络
Reactor/Proactor · 连接管理 · 心跳 · 流量控制
网络IO
23
消息客户端
设计原则 · 连接池 · 重连机制 · 版本管理
客户端SDK
24
消息与微服务
异步解耦 · 事件驱动 · Saga · CQRS
微服务架构
25
消息与大数据
数据管道 · Kafka+Flink · 数据湖 · 实时数仓
大数据流处理
26
消息与IoT
MQTT应用 · 设备路由 · 边缘处理 · 海量连接
IoTMQTT
27
消息与云原生
K8s集群 · Operator · Serverless · 成本优化
云原生K8s
28
消息选型
Kafka vs RocketMQ vs RabbitMQ vs Pulsar · 决策树
选型对比
29
消息性能调优
OS调优 · JVM调优 · 网络调优 · 业务层调优
调优性能
30
消息实战案例
电商订单流 · 日志采集 · 实时风控 · IM消息系统
实战案例