👂 Spring Framework 講座【第46回】システムを疎結合にする！〜イベント駆動型アーキテクチャの基本〜

前回、Spring Cacheを活用してアプリケーションの性能を向上させる方法を学びました。

ここからは、システムの高度な設計に関するトピックに進みます。大規模なシステムやマイクロサービスでは、コンポーネント間の**結合度（Coupling）**を下げ、疎結合にすることが重要です。これにより、一部の機能変更が他の機能に影響を与えるリスクを減らし、システムの拡張性（スケーラビリティ）と保守性を高めます。

今回は、システムを疎結合にするための強力な設計パターンである イベント駆動型アーキテクチャ（EDA: Event-Driven Architecture） の基本と、Spring Bootでの実装方法を学びます。

1. イベント駆動型アーキテクチャ（EDA）とは？

従来のシステムは、あるサービス（A）が別のサービス（B）を直接呼び出す（例：メソッド呼び出しやHTTPリクエスト）ことで処理が連携していました。これは同期的な連携であり、AはBの応答を待つ必要があります。

イベント駆動型アーキテクチャでは、コンポーネント間の直接的な呼び出しを避け、代わりに**イベント（出来事）**を介して間接的に連携します。

イベント: システム内で「何かが起こった」という事実を伝えるメッセージ（例：「注文が完了した」「ユーザーが登録された」）。
パブリッシャー（発行者）: イベントを発生させ、通知するコンポーネント。
サブスクライバー（購読者）: イベントを受信し、それに応じた処理を実行するコンポーネント。

1-1. 疎結合のメリット

パブリッシャーは、自分のイベントを誰が受け取るか（サブスクライバー）を一切知りません。サブスクライバーも、イベントがどこから来たかを知る必要はありません。

これにより、新しいサブスクライバーを追加しても、既存のパブリッシャーのコードを変更する必要がなく、高い疎結合性が実現します。

2. Spring Frameworkにおけるイベントの実装

Spring Frameworkでは、イベント駆動を実現するための仕組みを標準で提供しています。

2-1. アプリケーションイベント（Application Events）

Springのコンポーネント内で、同じDIコンテナ内にあるコンポーネントへイベントを通知する場合、アプリケーションイベントを使います。これは、マイクロサービス間の連携というより、単一のSpringアプリケーション内のサービスやコンポーネント間の疎結合に使われます。

2-2. イベントの定義（データ）

イベントは、「何が起こったか」という情報を持つ通常のJavaクラスとして定義します。

Java

public class OrderCompletedEvent {
    private final Long orderId;
    private final String customerEmail;
    
    // コンストラクタ、ゲッター
    public OrderCompletedEvent(Long orderId, String customerEmail) {
        this.orderId = orderId;
        this.customerEmail = customerEmail;
    }
    // ...
}

2-3. イベントの実行（パブリッシャー）

イベントを発行するためには、ApplicationEventPublisher インターフェースをDIで受け取り、その publishEvent メソッドを呼び出します。

Java

import org.springframework.context.ApplicationEventPublisher;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;

@Service
@RequiredArgsConstructor
public class OrderService {
    
    private final ApplicationEventPublisher eventPublisher;

    public void completeOrder(Long orderId, String email) {
        // 1. 注文DB処理などを実行
        // ...
        
        System.out.println("注文処理が完了しました。イベントを発行します。");
        
        // 2. イベントの発行
        OrderCompletedEvent event = new OrderCompletedEvent(orderId, email);
        eventPublisher.publishEvent(event);
        
        // 3. 呼び出し元はすぐに処理を終える
    }
}

2-4. イベントの購読（サブスクライバー）

イベントを受け取るコンポーネント（サブスクライバー）は、メソッドに @EventListener アノテーションを付与するだけで、特定のイベントタイプを購読できます。

Java

import org.springframework.context.event.EventListener;
import org.springframework.stereotype.Service;

@Service
public class EmailNotificationService {
    
    // OrderCompletedEventが発行されると、このメソッドが自動で呼び出される
    @EventListener
    public void handleOrderCompleted(OrderCompletedEvent event) {
        System.out.println("【メールサービス】イベントを受信しました。注文ID: " + event.getOrderId());
        // 注文完了メール送信処理を実行
    }
}

3. 同期的な実行と非同期的な実行

Springの @EventListener メソッドは、デフォルトではイベントを発行したスレッドと**同じスレッド（同期）**で実行されます。これは、イベントの処理中に例外が発生した場合、パブリッシャーの処理まで影響が及ぶ可能性があります。

この問題を解決し、真の疎結合性を高めるためには、イベント処理を非同期にする必要があります。

非同期化: イベントを処理するメソッドに、第31回で学んだ @Async アノテーションを併用します。

Java

import org.springframework.scheduling.annotation.Async;

@Service
public class InventoryUpdateService {
    
    @Async // 別スレッドで実行
    @EventListener
    public void updateInventory(OrderCompletedEvent event) {
        System.out.println("【在庫サービス】在庫更新を非同期で開始します。");
        // ... 在庫更新のロジック
    }
}

@Async を使うことで、OrderService はイベントを発行したらすぐに処理を終え、メール送信や在庫更新といったサブスクライバーの処理を待たずに済みます。