Spring事務管理之如何處理刪除操作與事務回滾

更新時間：2025年04月09日 08:27:07 作者：碼農阿豪@新空間

在實際開發(fā)中,事務管理是保證數據一致性的核心機制之一,本文將通過一個實際案例,詳細分析Spring事務中的刪除操作與回滾機制,并提供優(yōu)化方案,需要的可以參考下

引言

在實際開發(fā)中，事務管理是保證數據一致性的核心機制之一。特別是在涉及數據庫刪除操作時，如何正確處理刪除失敗、并發(fā)沖突等場景，是每個開發(fā)者需要面對的挑戰(zhàn)。本文將通過一個實際案例，詳細分析Spring事務中的刪除操作與回滾機制，并提供優(yōu)化方案。

1. 問題背景

在某個廣告流量控制系統(tǒng)中，我們需要刪除無效的媒體廣告位放量記錄。核心代碼如下：

@Service
@Transactional
public class FlowTransactionalUtil {
    @Autowired
    private OpmMediaFlowControlConfirmService confirmService;

    public void deleteMediaFlowOnline(List<OpmMediaFlowControlEntity> list, long flowId) {
        List<Long> mediaAdList = list.stream()
                .map(OpmMediaFlowControlEntity::getMediaAdId)
                .collect(Collectors.toList());

        List<Long> deleteList = confirmService.list(QueryUtils.eq(OpmMediaFlowControlConfirmEntity::getFlowId, flowId))
                .stream()
                .filter(e -> !mediaAdList.contains(e.getMediaAdId()))
                .map(OpmMediaFlowControlConfirmEntity::getId)
                .collect(Collectors.toList());

        if (!CollectionUtils.isEmpty(deleteList)) {
            RollBackExcUtils.throwExc(confirmService.removeByIds(deleteList) ? 1 : 0);
        }
    }
}

問題現象：

當 removeByIds() 返回 false（刪除失敗或未刪除記錄）時，拋出 CustomerException 并回滾事務。

日志顯示：

com.middle.exception.CustomerException: 事務處理請求異常

2. 問題分析

2.1 事務回滾機制

Spring 默認在遇到未捕獲的 RuntimeException 或 Error 時回滾事務。如果 CustomerException 不是 RuntimeException 的子類，需要顯式聲明@Transactional(rollbackFor = CustomerException.class)。

2.2 removeByIds 返回 false 的原因

原因	是否應回滾	處理建議
記錄不存在	否	記錄日志，不拋異常
并發(fā)沖突（已刪除）	否	記錄日志，不拋異常
數據庫異常	是	拋異常并回滾

3. 優(yōu)化方案

3.1 區(qū)分業(yè)務異常與技術異常

優(yōu)化 deleteFlowConfirm 方法，避免因“記錄不存在”等合法場景觸發(fā)回滾：

private void deleteFlowConfirm(long flowId, List<OpmMediaFlowControlConfirmEntity> controlConfirms) {
    List<Long> list = controlConfirms.stream()
            .filter(e -> e.getFlowId().equals(flowId))
            .map(OpmMediaFlowControlConfirmEntity::getId)
            .collect(Collectors.toList());

    if (!CollectionUtils.isEmpty(list)) {
        boolean isSuccess = confirmService.removeByIds(list);
        if (!isSuccess) {
            // 檢查是否真的存在待刪除記錄
            long actualExistCount = confirmService.count(
                QueryUtils.in(OpmMediaFlowControlConfirmEntity::getId, list)
            );
            if (actualExistCount > 0) {
                throw new CustomerException("刪除失敗，請重試或聯(lián)系管理員");
            } else {
                log.warn("嘗試刪除不存在的記錄: flowId={}, ids={}", flowId, list);
            }
        }
    }
}

3.2 顯式聲明事務回滾規(guī)則

@Transactional(rollbackFor = {CustomerException.class, RuntimeException.class})
public class FlowService {
    // ...
}

3.3 并發(fā)場景優(yōu)化

方案1：樂觀鎖重試

@Retryable(maxAttempts = 3, backoff = @Backoff(delay = 100))
public void deleteWithRetry(List<Long> ids) {
    TransactionAssert.assertSuccess(confirmService.removeByIds(ids));
}

方案2：悲觀鎖查詢

List<OpmMediaFlowControlConfirmEntity> list = confirmService.listWithLock(
    QueryUtils.eq(OpmMediaFlowControlConfirmEntity::getFlowId, flowId)
);

4. 完整優(yōu)化代碼

@Service
@Transactional(rollbackFor = CustomerException.class)
public class FlowService {
    @Autowired
    private OpmMediaFlowControlConfirmService confirmService;

    public void deleteMediaFlowOnline(List<OpmMediaFlowControlEntity> list, long flowId) {
        List<Long> mediaAdList = list.stream()
                .map(OpmMediaFlowControlEntity::getMediaAdId)
                .collect(Collectors.toList());

        // 直接條件刪除（避免查詢-刪除競態(tài)條件）
        boolean success = confirmService.deleteByFlowIdAndExcludedAdIds(flowId, mediaAdList);
        TransactionAssert.assertSuccess(success);
    }
}

// 事務斷言工具類
public class TransactionAssert {
    public static void assertSuccess(boolean condition) {
        if (!condition) {
            throw new CustomerException(SupResultCode.CODE_900000, "操作失敗，請重試");
        }
    }
}

5. 日志與監(jiān)控建議

在關鍵位置添加日志：

try {
    flowService.deleteMediaFlowOnline(list, flowId);
} catch (CustomerException e) {
    log.error("刪除失敗 - flowId: {}, 錯誤: {}", flowId, e.getMessage());
    throw e;
}