📚 课程目录第1章事务基础概念

1. 事务基础概念：ACID特性、本地事务与分布式事务、事务边界定义

1.1 事务的本质与ACID特性

事务（Transaction）是数据库系统与消息系统中保证数据一致性的核心抽象。它将一组读写操作捆绑为一个不可分割的逻辑单元，要么全部成功提交，要么全部失败回滚。ACID 是事务必须满足的四个基本属性：

属性	全称	含义	开发环境典型问题
A	Atomicity（原子性）	事务内的操作要么全部完成，要么全部不做	部分写入后进程崩溃，数据半更新
C	Consistency（一致性）	事务前后数据满足所有约束（外键、唯一、业务规则）	违反唯一索引或业务校验未通过
I	Isolation（隔离性）	并发事务之间互不干扰，效果等价于串行执行	脏读、不可重复读、幻读
D	Durability（持久性）	已提交事务的修改永久保存，不因故障丢失	磁盘故障或消息队列未落盘

  开发环境调试要点： 在 development 环境中，ACID 的隔离性常被忽略。默认的 READ COMMITTED 隔离级别在并发写入时可能导致 Kafka 消息消费端读到不一致的数据库快照。建议在调试阶段显式设置隔离级别为 REPEATABLE READ 或使用 SELECT ... FOR UPDATE 锁定关键行。

1.2 本地事务与分布式事务

根据事务参与的资源数量与范围，事务分为本地事务和分布式事务两大类：

本地事务（Local Transaction）：仅操作单一数据源（如单个数据库或单个 Kafka 集群）。由资源管理器（如数据库连接、Kafka Producer）直接管理，使用 BEGIN/COMMIT/ROLLBACK 控制。性能高，实现简单。
分布式事务（Distributed Transaction）：跨多个数据源（如数据库 + Kafka + Redis）或跨多个服务节点。需要协调器（Coordinator）保证全局一致性，典型协议包括 XA、TCC、Saga、Kafka 事务幂等性。

开发环境选择建议： 在 development 环境中，优先使用本地事务 + 最终一致性补偿（如定时任务或消息重试）来模拟分布式事务效果。避免直接引入 XA 两阶段提交，因为开发环境通常不具备完整的 XA 资源管理器配置，且调试复杂度高。

1.3 事务边界定义

事务边界（Transaction Boundary）是指事务开始到结束的范围。在 Spring 与 Kafka 集成的开发环境中，事务边界通常由以下三个维度共同决定：

方法边界：使用 @Transactional 注解标记的 Spring 方法，事务在方法进入时开启，方法退出时提交或回滚。
消息边界：Kafka 消息的 send() 调用是否被包裹在事务中。Kafka 事务要求 Producer 初始化 transactional.id，并通过 beginTransaction() / commitTransaction() 控制。
资源边界：事务跨越的数据源数量。单一数据源为本地事务边界；多个数据源（如数据库 + Kafka）需要分布式事务协调。

边界类型	Spring 配置方式	Kafka 事务集成方式	开发环境调试难点
方法边界	`@Transactional(propagation=REQUIRED)`	KafkaTemplate 自动参与事务	事务传播行为导致意外回滚
消息边界	`@KafkaListener` + `@Transactional`	KafkaMessageListenerContainer 事务同步	消费偏移量提交与事务提交顺序
资源边界	`@Transactional(transactionManager="chainedTransactionManager")`	ChainedKafkaTransactionManager	部分资源提交成功、部分失败

常见陷阱： 在 development 环境中，事务边界定义不清晰会导致“幽灵消息”或“丢失消息”。例如：数据库事务已提交，但 Kafka 消息发送失败，下游消费者收到不一致的数据。务必在调试时启用 spring.kafka.producer.transaction-id-prefix 并配合 @Transactional 使用。

1.4 事务边界在 Kafka 消息链路中的体现

在 Kafka 消息链路中，事务边界决定了消息的生产、消费与确认的原子性范围。以下是一个典型的 Spring Boot + Kafka 事务边界示例：

@Service
public class OrderService {

    @Autowired
    private JdbcTemplate jdbcTemplate;

    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;

    @Transactional
    public void createOrder(Order order) {
        // 1. 写入数据库（本地事务）
        jdbcTemplate.update("INSERT INTO orders (id, status) VALUES (?, ?)", 
            order.getId(), "CREATED");

        // 2. 发送 Kafka 消息（参与同一事务）
        kafkaTemplate.send("order-events", order.getId(), 
            "OrderCreated:" + order.getId());

        // 3. 事务提交：数据库写入 + Kafka 消息发送 同时生效或同时回滚
    }
}

上述代码中，事务边界从 createOrder 方法开始，到方法结束为止。数据库操作与 Kafka 消息发送被绑定在同一个事务中。如果数据库写入失败，Kafka 消息不会发送；如果 Kafka 发送失败，数据库写入也会回滚。

  调试技巧： 在 development 环境中，可以通过设置 spring.kafka.producer.transaction-id-prefix=tx- 和 spring.kafka.consumer.isolation-level=read_committed 来验证事务边界是否生效。消费者端设置 read_committed 后，只有已提交事务的消息才会被消费，未提交或回滚的消息会被自动过滤。