多操作全成全败方案：数据库事务vs并行任务？求最优实现

现有方案的问题 #

方案一：数据库事务内执行云存储上传 #

这个方案无法满足全成全败的要求，核心问题在于云存储操作不受数据库事务管控：

• 若数据库保存成功但云存储上传失败，事务回滚会撤销数据库操作，但已上传的图片无法自动删除，导致数据不一致。
• 同时，长时间持有数据库事务（等待云存储上传完成）会占用数据库连接，降低系统并发能力，甚至引发锁等待问题。

方案二：并行任务执行双操作 #

该方案同样不满足全成全败的原子性要求：

• 两个操作并行执行，无法保证同步结果。比如数据库保存成功后，图片上传失败，已写入数据库的数据无法回滚；反之若图片上传成功但数据库保存失败，已上传的图片也无法自动清理。
• 并行执行还可能引发时序问题，比如业务逻辑依赖未持久化的数据库数据，导致潜在bug。

最优实现方式：补偿事务（Compensating Transaction） #

要实现严格的全成全败，需采用先执行单个操作，成功后执行第二个操作，若第二个失败则对第一个操作做反向补偿的思路，具体流程可分为两种顺序：

顺序一：先存数据库，再传图片 #

1. 执行数据库数据保存操作
   • 保存失败，直接返回错误，无需后续操作
2. 数据库保存成功后，执行云存储图片上传
   • 上传成功，完成所有操作并返回结果
   • 上传失败，执行补偿：删除刚保存的数据库数据，同时删除已上传的部分图片，返回错误

代码示例

var uploadedFileUrls = new List<string>();
var newData = new YourDataEntity { /* 填充数据 */ };

try
{
    // 1. 保存数据到数据库
    await _dbContext.DataEntities.AddAsync(newData);
    await _dbContext.SaveChangesAsync();

    // 2. 上传图片到云存储
    foreach (var file in request.Files)
    {
        var url = await _cloudStorage.UploadAsync(file);
        uploadedFileUrls.Add(url);
    }

    // 可选：更新数据库中的图片URL
    newData.ImageUrls = uploadedFileUrls;
    await _dbContext.SaveChangesAsync();
}
catch (Exception ex)
{
    // 执行补偿操作
    if (newData.Id != default)
    {
        _dbContext.DataEntities.Remove(newData);
        await _dbContext.SaveChangesAsync();
    }
    foreach (var url in uploadedFileUrls)
    {
        await _cloudStorage.DeleteAsync(url);
    }
    throw; // 抛出异常，由上层处理错误
}

顺序二：先传图片，再存数据库 #

流程逻辑与上述一致，只是调换操作顺序：

1. 先上传图片到云存储
   • 上传失败，直接返回错误
2. 上传成功后，保存数据到数据库
   • 保存失败，执行补偿：删除已上传的图片，返回错误

额外注意事项 #

• 补偿操作本身可能失败（比如删除数据库数据时数据库宕机），需引入重试机制或人工补偿流程，确保最终一致性。
• 如果业务允许一定程度的最终一致性，也可采用可靠消息队列+异步处理的方式：将操作消息放入队列，由消费者执行双操作，失败时重试或触发补偿，适合实时性要求不高的场景。

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