VIP20

本课程属于：034-Kafka性能调优 数据工程与实时数据平台 · 共 20 门相关课程，组合学习更完整。

查看所属VIP全部课程 →

← 返回所属目录咨询 / 购买

Exactly Once 语义落地

📚 共计 30 章节

点击此处阅读海量试读课程：100+行业、1000+细分领域

Exactly Once 概述

什么是 Exactly Once、为什么需要 Exactly Once、端到端 Exactly Once 的挑战。

核心概念端到端

消息投递语义

At Most Once、At Least Once、Exactly Once 的定义与对比。

投递保证对比

幂等性原理

幂等的数学定义、HTTP 幂等性、业务幂等性设计。

幂等HTTP设计

分布式事务基础

ACID 理论、CAP 定理、BASE 理论。

两阶段提交（2PC）

2PC 协议流程、协调者与参与者、2PC 的优缺点。

2PC协调者协议

三阶段提交（3PC）

3PC 协议改进、超时机制、与 2PC 的对比。

3PC超时对比

Try-Confirm-Cancel 模式、TCC 落地实现、空回滚与悬挂问题。

TCC补偿空回滚

Saga 定义、编排型 Saga、choreography 型 Saga、补偿事务。

Saga编排补偿

本地消息表

本地消息表原理、定时任务扫描、可靠消息最终一致性。

本地消息定时任务最终一致性

事务消息（RocketMQ）

RocketMQ 事务消息流程、半消息机制、回查机制。

RocketMQ半消息回查

Kafka 幂等性

Kafka 幂等生产者原理、producer id 与 sequence number、开启方式。

Kafka幂等生产者sequence

Kafka 事务 API、事务协调器、隔离级别（read_committed）。

Kafka事务协调器隔离级别

Pulsar 消息去重

Pulsar 去重机制、producer name 与 sequence id、Exactly Once 保证。

Pulsar去重producer name

数据库去重表

唯一索引去重、业务主键设计、去重表清理策略。

去重表唯一索引清理策略

Redis 分布式锁去重

Redis SETNX 实现、锁超时与续期、Redlock 算法。

RedisSETNXRedlock

状态机去重

状态机模型、状态流转、幂等状态判断。

状态机流转幂等

全局唯一 ID 生成

UUID、雪花算法（Snowflake）、美团 Leaf、百度 UidGenerator。

UUIDSnowflakeLeaf

去重组件设计

通用去重 SDK 设计、SPI 扩展、注解驱动。

Flink 端到端 Exactly Once

Flink 检查点机制、两阶段提交 Sink、Kafka Sink 实现。

Flink检查点两阶段提交

Flink 与 Kafka 集成

FlinkKafkaProducer 的 Exactly Once 配置、事务超时设置。

FlinkKafka事务超时

Flink 与 Pulsar 集成

Flink Pulsar Sink 的 Exactly Once 配置。

FlinkPulsarSink

数据库 CDC 与 Exactly Once

Debezium 原理、Kafka Connect 的 Exactly Once 配置。

CDCDebeziumKafka Connect

HTTP 接口幂等性

幂等性拦截器、机制、请求去重。

RPC 框架幂等性

Dubbo 幂等性设计、gRPC 幂等性、重试策略。

DubbogRPC重试

支付系统 Exactly Once

支付幂等键设计、状态机、对账机制。

支付幂等键对账

订单系统 Exactly Once

订单去重、库存扣减幂等、分布式事务选型。

订单库存事务选型

消息中间件选型

Kafka vs RocketMQ vs Pulsar 的 Exactly Once 能力对比。

KafkaRocketMQPulsar

性能与一致性权衡

Exactly Once 的性能开销、吞吐量优化、一致性降级策略。

性能吞吐量降级

监控与运维

事务指标监控、死信队列处理、人工补偿机制。

监控死信队列补偿

总结与最佳实践

架构设计原则、常见坑点、未来趋势（流式 Exactly Once）。

最佳实践坑点趋势