您现在的位置：程式碼之家 >> 編程語言 > >> Java 程式設計 >> Java 相關知識

事務策略：高並發模式——縮小事務作用域以提升吞吐量與並發性

編輯：Java 相關知識

API 層策略雖健壯，但對高吞吐量、高並發應用而言，長事務持有資源鎖過久，導致連接耗盡、死鎖、鎖升級（行級→頁級→表級）。高並發事務策略通過極小化事務作用域，縮短鎖持有時間，換取性能與並發能力，但需承擔數據一致性風險的折衷。

核心折衷：一致性 vs 並發性

獲益：事務耗時從秒級降至毫秒級，理論吞吐量提升數十倍。
代價：
1. 讀操作在事務外執行，可能遇到失效數據異常（更新基於舊數據）。
2. 實現難度大，易出錯，測試成本高，缺乏統一實現模式。

決策建議：先用 API 層策略進行高負載測試；若出現吞吐量低、死鎖、等待多，再遷移至高並發策略。

架構特徵：事務起始點不固定

高並發策略架構圖

客戶端層無事務邏輯，支持任意客戶端類型（Web、桌面、JMS、WS）。
事務可能在 API 層、業務層、甚至 DAO 層開始，缺乏一致性，增加治理難度。
通常需程序化事務縮小作用域，但不應強行統一模型，視具體場景選擇聲明式/程序化。

實現技巧一：先讀取技巧

將所有讀取、驗證、合規檢查移至事務外部，僅將寫操作包裹在極短事務中。

重構前（API 層策略，事務 6100ms）

@TransactionAttribute(REQUIRED)
public void processTrade(TradeData trade) {
    // 所有讀取、驗證、合規、寫操作均在事務內
    TraderData trader = service.getTrader(trade.getTraderID());
    validateTraderEntitlements(trade, trader);
    verifyTraderLimits(trade, trader);
    performPreTradeCompliance(trade, trader);
    service.insertTrade(trade);
    AcctData acct = service.getAcct(trade.getAcctId());
    verifyFundsAvailability(acct, trade);
    adjustBalance(acct, trade);
    service.updateAcct(trade);
    performPostTradeCompliance(trade, trader);
}

重構後（高並發策略，事務 300ms）

public void processTrade(TradeData trade) {
    UserTransaction txn = null;
    try {
        // 1. 事務外：所有讀取、驗證、計算
        TraderData trader = service.getTrader(trade.getTraderID());
        validateTraderEntitlements(trade, trader);
        verifyTraderLimits(trade, trader);
        performPreTradeCompliance(trade, trader);
        AcctData acct = service.getAcct(trade.getAcctId());
        verifyFundsAvailability(acct, trade);
        adjustBalance(acct, trade);
        performPostTradeCompliance(trade, trader);

        // 2. 極短事務：僅寫操作
        txn = (UserTransaction) ctx.lookup("UserTransaction");
        txn.begin();
        service.insertTrade(trade);
        service.updateAcct(trade);
        txn.commit();
    } catch (Exception up) {
        if (txn != null) txn.rollback();
        throw up;
    }
}

關鍵風險：讀取數據無鎖保護，若同一實體被併發修改，提交時可能拋出失效數據異常（需 ORM 版本檢查機制輔助）。前提假設：單用戶操作單一實體（如交易者僅操作自己的帳戶）。

EJB 程序化事務聲明

@TransactionManagement(TransactionManagementType.BEAN) // 類級別，不可混用聲明式
@Stateless
public class TradingServiceImpl { ... }

實現技巧二：低層技巧

保持聲明式事務模型，將寫操作下沉至調用棧較低層的公共方法，該方法標記 REQUIRED 啟動事務。

@TransactionAttribute(SUPPORTS) // 父方法無事務
public void processTrade(TradeData trade) {
    // 讀取、驗證、計算...
    processTradeUpdates(trade, acct); // 調用寫方法
}

@TransactionAttribute(REQUIRED) // 子方法啟動事務
public void processTradeUpdates(TradeData trade, AcctData acct) {
    try {
        service.insertTrade(trade);
        service.updateAcct(trade);
    } catch (Exception up) {
        ctx.setRollbackOnly();
        throw up;
    }
}

隱患：非事務擁有者（子方法）執行回滾，父方法無法感知、無法採取糾正措施，提交時可能拋異常。實現缺乏一致性，像「缺牙的曲棍球員」。