Spring Boot中第三方API与PostgreSQL的事务回滚处理方案咨询

针对你遇到的事务提交阶段异常无法捕获、第三方API操作无法随数据库回滚的问题，以下是几种可落地的解决思路：

方案1：利用Spring TransactionSynchronization监听事务生命周期 #

Spring提供的TransactionSynchronization接口可以监听事务的提交、回滚等事件。你可以在调用第三方API后注册同步器，在事务回滚时触发第三方API的撤销操作，同时保留操作上下文（比如第三方返回的实体ID）。

示例代码：

@Service
public class EntityService {
    @Autowired
    private EntityRepository entityRepository;
    @Autowired
    private ThirdPartyApiClient thirdPartyApiClient;

    @Transactional
    public void createEntity(EntityDTO dto) {
        // 1. 调用第三方API并保存返回的实体ID
        String thirdPartyEntityId = thirdPartyApiClient.createEntity(dto);
        
        // 2. 注册事务同步器，监听回滚事件
        TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
            @Override
            public void afterCompletion(int status) {
                // 判断事务是否回滚
                if (status == TransactionSynchronization.STATUS_ROLLED_BACK) {
                    // 调用第三方API的撤销/删除接口
                    thirdPartyApiClient.deleteEntity(thirdPartyEntityId);
                }
            }
        });

        // 3. 保存实体到数据库，若此处或事务提交阶段抛出异常，事务回滚后同步器会触发撤销
        Entity entity = convertToEntity(dto);
        entity.setThirdPartyId(thirdPartyEntityId);
        entityRepository.save(entity);
    }
}

注意事项：

• afterCompletion方法会在事务完全结束后执行，无论正常提交还是异常回滚都会触发。
• 确保第三方API提供的撤销接口是幂等的（多次调用不会产生额外副作用）。

方案2：手动控制事务，拆分逻辑捕获所有异常 #

缩小@Transactional的作用范围，手动管理事务的提交与回滚，这样可以直接捕获包括数据库提交阶段在内的所有异常，同时保留第三方API的上下文信息。

示例代码：

@Service
public class EntityService {
    @Autowired
    private EntityRepository entityRepository;
    @Autowired
    private ThirdPartyApiClient thirdPartyApiClient;
    @Autowired
    private PlatformTransactionManager transactionManager;

    public void createEntity(EntityDTO dto) {
        String thirdPartyEntityId = null;
        DefaultTransactionDefinition def = new DefaultTransactionDefinition();
        TransactionStatus status = transactionManager.getTransaction(def);
        
        try {
            // 1. 调用第三方API
            thirdPartyEntityId = thirdPartyApiClient.createEntity(dto);
            
            // 2. 保存到数据库
            Entity entity = convertToEntity(dto);
            entity.setThirdPartyId(thirdPartyEntityId);
            entityRepository.save(entity);
            
            // 3. 手动提交事务
            transactionManager.commit(status);
        } catch (Exception e) {
            // 4. 事务回滚+调用第三方API撤销
            transactionManager.rollback(status);
            if (thirdPartyEntityId != null) {
                thirdPartyApiClient.deleteEntity(thirdPartyEntityId);
            }
            throw new RuntimeException("创建实体失败", e);
        }
    }
}

注意事项：

• 手动控制事务时，要确保所有异常都被捕获，包括数据库提交阶段的约束违反、连接错误等。
• 需自行处理事务的生命周期，避免出现未提交或未回滚的情况。

方案3：补偿事务+消息队列实现最终一致性 #

如果第三方API的撤销操作可能因网络波动等原因失败，可以结合消息队列实现最终一致性：当数据库操作失败时，发送补偿消息到队列，由消费者重试调用第三方API的撤销接口，直到操作成功。

简化代码示例：

@Service
public class EntityService {
    @Autowired
    private EntityRepository entityRepository;
    @Autowired
    private ThirdPartyApiClient thirdPartyApiClient;
    @Autowired
    private RabbitTemplate rabbitTemplate;

    @Transactional
    public void createEntity(EntityDTO dto) {
        String thirdPartyEntityId = thirdPartyApiClient.createEntity(dto);
        
        try {
            Entity entity = convertToEntity(dto);
            entity.setThirdPartyId(thirdPartyEntityId);
            entityRepository.save(entity);
        } catch (Exception e) {
            // 发送补偿消息到队列
            rabbitTemplate.convertAndSend("compensation-queue", thirdPartyEntityId);
            throw e; // 触发事务回滚
        }
    }
}

// 补偿消息消费者
@Component
public class CompensationConsumer {
    @Autowired
    private ThirdPartyApiClient thirdPartyApiClient;

    @RabbitListener(queues = "compensation-queue")
    public void handleCompensation(String thirdPartyEntityId) {
        // 通过Spring Retry或死信队列实现重试机制
        thirdPartyApiClient.deleteEntity(thirdPartyEntityId);
    }
}

注意事项：

• 补偿消息和第三方撤销接口都要保证幂等性，避免重复执行产生问题。
• 可通过死信队列处理重试失败的消息，避免消息丢失。

内容的提问来源于stack exchange，提问作者nboisnea