快捷導(dǎo)航

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

更新時(shí)間：2025年04月09日 08:27:07 作者：碼農(nóng)阿豪@新空間

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

引言

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

1. 問(wèn)題背景

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

@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);
        }
    }
}

問(wèn)題現(xiàn)象：

當(dāng) removeByIds() 返回 false（刪除失敗或未刪除記錄）時(shí)，拋出 CustomerException 并回滾事務(wù)。

日志顯示：

com.middle.exception.CustomerException: 事務(wù)處理請(qǐng)求異常

2. 問(wèn)題分析

2.1 事務(wù)回滾機(jī)制

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

2.2 removeByIds 返回 false 的原因

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

3. 優(yōu)化方案

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

優(yōu)化 deleteFlowConfirm 方法，避免因“記錄不存在”等合法場(chǎng)景觸發(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("刪除失敗，請(qǐng)重試或聯(lián)系管理員");
            } else {
                log.warn("嘗試刪除不存在的記錄: flowId={}, ids={}", flowId, list);
            }
        }
    }
}

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

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

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

方案1：樂(lè)觀鎖重試

@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());

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

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

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

在關(guān)鍵位置添加日志：

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