分散システム architecture において、従来の同期トランザクションは強い整合性を保証する一方で、システム全体のレイテンシ増大やスループット低下を招く主要な要因となります。特に、外部 API 呼び出しや長時間実行タスクが含まれる場合、メインスレッドがブロックされることで可用性に悪影響を及ぼします。本稿では、Apache Seata を活用し、非同期処理モデルを導入することでこれらのボトルネックを解消し、データ整合性を保ちつつシステム性能を向上させる手法について解説します。

非同期トランザクションの必要性とアーキテクチャ

マイクロサービス環境下では、Seata の標準的な AT モードなどが提供する同期制御は、短時間の処理には有効ですが、以下のようなケースでは不適切です。

• 長時間実行タスク：動画処理や複雑な集計作業など
• 高頻度書き込み：キャンペーン期间的な在庫確保など
• 外部依存連携：決済ゲートウェイや物流システムとの連携
• トラフィック変動：ピーク時のリクエスト集中対策

Seata は、Spring の非同期機能と連携し、トランザクションコンテキスト（XID）を非同期スレッドへ正しく伝播させる仕組みを提供します。これにより、メインのビジネスロジックをブロックせずに、バックグラウンドでトランザクション処理を完了させることが可能になります。

実装ガイド：設定とコード構成

依存関係の追加

プロジェクトのビルド設定に Seata のスターター依赖を追加します。Maven を使用する場合は以下の通りです。

<dependency>
    <groupId>org.apache.seata</groupId>
    <artifactId>seata-spring-boot-starter</artifactId>
    <version>2.5.0</version>
</dependency>

非同期設定の定義

application.yml において、非同期処理を有効化し、スレッドプールパラメータを調整します。

seata:
  tx-service-group: default_tx_group
  service:
    vgroup-mapping:
      default_tx_group: default
  client:
    async:
      enabled: true
      thread-pool:
        core-size: 20
        max-size: 100
        queue-capacity: 2000

サービス層の実装

グローバルトランザクションのアノテーションと、非同期実行アノテーションを組み合わせます。ここでは、購入フローを例に、在庫確保と決済処理を非同期で行う実装を示します。

@Service
public class PurchaseFlowHandler {

    @Autowired
    private StockApiClient stockApiClient;
    
    @Autowired
    private PaymentGatewayClient paymentGatewayClient;

    @GlobalTransactional(rollbackFor = Exception.class)
    public String initiatePurchase(PurchaseRequest purchaseReq) {
        // ローカルトランザクション：購入記録の保存
        PurchaseRecord record = new PurchaseRecord();
        record.setUserId(purchaseReq.getUserId());
        record.setAmount(purchaseReq.getTotalAmount());
        saveRecord(record);
        
        // 非同期で在庫確保を実行
        processStockReservation(purchaseReq.getSkuId(), purchaseReq.getQuantity());
        
        // 非同期で決済処理を実行
        initiatePaymentFlow(record.getId(), purchaseReq.getTotalAmount());
        
        return record.getId();
    }
    
    @Async
    public CompletableFuture<Void> processStockReservation(Long skuId, Integer quantity) {
        return CompletableFuture.runAsync(() -> {
            stockApiClient.reserveStock(skuId, quantity);
        });
    }
    
    @Async
    public CompletableFuture<Void> initiatePaymentFlow(String recordId, BigDecimal amount) {
        return CompletableFuture.runAsync(() -> {
            paymentGatewayClient.charge(recordId, amount);
        });
    }
}

スレッドプールの構成

Seata が非同期スレッド内でトランザクションコンテキストを認識できるよう、適切な Executor を定義します。

@Configuration
@EnableAsync
public class TransactionExecutorConfig {

    @Bean(name = "seataTransactionExecutor")
    public Executor taskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(20);
        executor.setMaxPoolSize(100);
        executor.setQueueCapacity(2000);
        executor.setThreadNamePrefix("seata-tx-async-");
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        executor.initialize();
        return executor;
    }
}

エラー処理と補償ロジック

非同期処理における例外はメインスレッドに即座に伝播しないため、明示的な捕获と補償処理が必要です。

@Async
public CompletableFuture<Void> processStockReservation(Long skuId, Integer quantity) {
    return CompletableFuture.runAsync(() -> {
        try {
            stockApiClient.reserveStock(skuId, quantity);
        } catch (Exception ex) {
            log.warn("在庫確保に失敗しました。補償処理を開始します", ex);
            // 在庫戻しなどの補償アクション
            stockApiClient.releaseStock(skuId, quantity);
            // グローバルロールバックをトリガー
            throw new RuntimeException("在庫確保エラー", ex);
        }
    });
}

パフォーマンス評価と適用基準

同期トランザクションと非同期トランザクションの特性を比較し、適切な適用場面を選定することが重要です。

負荷テスト（1000 TPS 環境）における性能比較結果は以下の通りです。非同期化により、レスポンスタイムの大幅な短縮とスループットの向上が確認できます。

運用上の注意点と対策

非同期トランザクションを導入する際、以下の課題に対処する必要があります。

1. コンテキストの伝播失敗：@GlobalTransactional が付与されたメソッドと同じクラス内から@Async を呼び出す場合、AOP プロキシの仕様によりコンテキストが失われる可能性があります。自己注入を行うか、TransactionSynchronizationManager を利用して XID を明示的に引き継ぐ必要があります。
2. リソース枯渇：タスクキューが溢れるとシステム全体が停滞する恐れがあります。モニタリングツールを用いてスレッドプール使用率を常時監視し、キュー容量を適切に設定してください。
3. 整合性保証の弱化：非同期処理は最終整合性モデルを採用することが多いです。重要な業務では、Saga パターンやローカルメッセージ表を組み合わせて、データ不整合への対策を講じます。
4. タイムアウト設定：非同期タスクは完了までの時間が変動するため、トランザクションのタイムアウト値は同期処理の 3 倍程度に設定し、予期せぬロールバックを防ぎます。