Java 中怎么用编程式事务包装多步骤第三方 API 补偿逻辑-java教程-PHP中文网

java编程式事务应仅保障本地状态可逆性，通过transactiontemplate执行主数据修改、补偿元信息持久化和待重试任务插入；外部api调用必须剥离至异步补偿调度器独立执行。

java 中怎么用编程式事务包装多步骤第三方 api 补偿逻辑

Java 中用编程式事务包装多步骤第三方 API 补偿逻辑，核心不是“把 API 调用塞进事务”，而是**用事务保障本地状态的可逆性，再用独立补偿机制兜住远程调用的不确定性**。直接在 TransactionTemplate 里发 HTTP 请求是危险且反模式的，必须拆解为“本地事务 + 异步补偿”两层。

先明确边界：哪些该进事务，哪些绝对不能进

TransactionTemplate 只应包裹真正需要 ACID 保证的本地操作：

记录主业务数据（如创建订单、扣减库存）
持久化补偿元信息（如 saga_step_log 表：记录哪一步执行了、参数快照、补偿接口地址、当前状态 SU/FA/UN）
插入待重试任务（如 retry_task 表，含重试次数、下次执行时间、原始请求体）

以下操作严禁出现在 TransactionTemplate 的 doInTransaction 回调中：

调用任何外部 HTTP 接口（包括第三方 API）
发送消息（如 Kafka/RocketMQ）——除非使用事务消息并绑定同一数据库连接
执行耗时计算或文件 IO

补偿逻辑的三要素必须落库，不可只存在内存

每一步涉及第三方 API 的操作，都要在事务内完成“可追溯、可重放、可终止”的状态登记：

Alibabacloud Sdk Client Initialization For Java

在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。

下载

快照存值，不存逆运算：比如调用支付接口前，把用户账户余额 500 写入 balance_snapshot 字段；补偿时不写 SET amount = amount + 100，而写 SET amount = 500
状态机驱动：每个步骤对应一条 saga_step 记录，status 字段明确为 INIT / EXECUTING / SUCCESS / FAILED / COMPENSATING / COMPENSATED
幂等标识必填：生成全局唯一 business_id + step_id 组合作为补偿键，每次补偿前查表确认是否已执行过

异步补偿任务要独立调度，不依赖原事务上下文

事务提交后，立刻触发补偿调度器（如 Spring @Scheduled 或 Quartz），而非在 doInTransaction 里 sleep 或轮询：

定时扫描 status = 'FAILED' 且 retry_count
对每条记录，调用对应补偿接口（如 refundService.compensate(paymentId)）
补偿成功则更新 status = 'COMPENSATED'；失败则递增 retry_count 并设置下次执行时间（如 2ⁿ 秒后）
所有补偿动作本身也需有日志和异常捕获，失败记录进 error_compensation_log 表供人工介入

典型代码结构示意

事务内只做三件事：改主数据、记快照、写任务。其余全部剥离：

transactionTemplate.execute(status -> {
    // 1. 主业务入库（如创建订单）
    orderMapper.insert(order);

    // 2. 记录支付步骤快照（含原始金额、用户ID、支付前余额）
    sagaStepMapper.insert(SagaStep.builder()
        .businessId(order.getId())
        .stepId("pay_step_1")
        .compensateUrl("https://api.pay.com/refund")
        .snapshot("{\"preBalance\": 500, \"amount\": 100}")
        .status("INIT")
        .build());

    // 3. 插入待补偿任务（状态为 PENDING）
    retryTaskMapper.insert(RetryTask.builder()
        .businessId(order.getId())
        .stepId("pay_step_1")
        .retryCount(0)
        .nextExecuteTime(LocalDateTime.now().plusSeconds(5))
        .build());

    return null;
});

之后由独立线程池处理 RetryTask，调用外部 API 并更新 saga_step 状态 —— 这部分完全脱离数据库事务生命周期。