Java分散システムにSAGAパターンを実装します

SAGAモードを使用して、Java分散システムのデータの一貫性を維持し、ローカルトランザクションシーケンスと補償メカニズムを介して分散トランザクションを置き換えます。 2。スプリングブーツでオーケストレーションされたサガを使用することをお勧めし、Orderagaクラスは支払いおよび在庫サービスの実行とロールバックを調整します。 3.信頼性を向上させるために、再試行、慣性、および持続的な佐賀状態を追加します。 4。線形プロセス最適化オーケストレーションは、複雑なイベント駆動型シナリオで考慮されます。

Java（特に複数のマイクロサービスに及ぶJavaに分散システムを構築する場合、分散トランザクションに依存せずにサービス全体のデータの一貫性を維持するという課題に遭遇することがよくあります。それが佐賀パターンが登場するところです。

佐賀パターンとは何ですか？

SAGAは、各サービスが独自のデータベースを更新するローカルトランザクションのシーケンスです。 1つのステップが失敗した場合、SAGAは、以前のステップで行われた変更を取り消す補償トランザクションを実行します。これは、2フェーズのコミット（2PC）に代わるものであり、それに伴う緊密な結合とパフォーマンスの問題を回避します。

サガを実装する主な方法は2つあります。

1. 振り付け- 各サービスはイベントを公開し、その他のサービスはそれらに反応します（分散型）。
2. オーケストレーション- セントラルオーケストレーター（サガマネージャー）は、各サービスに次に何をすべきかを伝えます（集中化）。

Javaシステムの場合、特にSpring Bootを使用している場合、オーケストレーションは実装とデバッグが簡単になります。

JavaにSaga Orchestrationを実装する方法

これらのサービスでeコマースアプリを構築しているとしましょう。

• 注文サービス
• 支払いサービス
• 在庫サービス

ユーザーは注文を配置します→支払いを処理する必要があります→在庫は予約する必要があります。

ステップが失敗した場合は、前の手順をロールバックする必要があります（たとえば、在庫が失敗した場合は、支払いを返金します）。

1。サガオーケストレーターを定義します

フローを調整するOrderSagaクラスを作成します。

 @サービス
パブリッククラスオーダーガ{

    プライベート最終PaymentserviceClient Paymentservice;
    プライベート最終inventoryServiceClient InventoryService;

    public void execute（注文注文）{
        boolean paymentsuccess = false;
        boolean inventorysuccess = false;

        試す {
            //ステップ1：支払いを処理します
            Paymentservice.Charge（order.getCustomerid（）、order.getTotal（））;
            paymentsuccess = true;

            //ステップ2：在庫を予約します
            inventoryservice.reserve（order.getItems（））;
            inventorysuccess = true;

            // 成功！確認された順序をマークします
            order.setstatus（orderstatus.confirmed）;
        } catch（例外e）{
            //逆順序で補償アクションをトリガーします
            if（inventorysuccess）{
                inventoryservice.release（order.getItems（））;
            }
            if（paymentsuccess）{
                paymentservice.refund（order.getCustomerId（）、order.getTotal（））;
            }

            order.setstatus（orderstatus.failed）;
            eを投げる;
        }
    }
}

2。レトリと慣習性とともに回復力があります

実際のシステムでは、サービスは一時的に利用できない場合があります。 spring retryまたはresilience4jを使用してロジックを再試行します：

 @retry（name = "inventoryservice"、fallbackmethod = "handleinventoryfailure"）
パブリックボイドリザーブ（リスト<アイテム>アイテム）{
    InventoryServiceClient.Reserve（items）;
}

また、補償アクション（払い戻しやリリースなど）が理想的な人物であることを確認してください。副作用なしで複数回呼び出すことができます。

3. SAGA STATEを永続させる（オプションですが推奨）

長期にわたるサガまたはクラッシュの回復については、サガ状態をデータベースに保存します（たとえば、JPAの使用）：

 @実在物
パブリッククラスのsagainstance {
    @ID
    プライベートストリングサガイド;
    Private String OrderId;
    Private String currentState; //例えば、「Payment_done」
    Private LocalDateTime CreatedAT;
}

各ステップの後にこの状態を更新して、オーケストレーターがクラッシュした場合に再開できるようにします。

4.イベントを使用してゆるい結合（オプション）

直接HTTP呼び出しの代わりに、ドメインイベントを公開します（例えば、KafkaまたはRabbitMQを介して）。オーケストレーターはこれらに耳を傾け、次のステップを決定します。これにより、結合が減少し、スケーラビリティが向上します。

Java開発者向けの重要なヒント

• spring Spring Boot Spring Cloud Openfeignを使用して、サービスからサービスへのクリーンコールを使用します。
• controllerコントローラーではなく、専用のサービスクラスでサガロジックをラップします。
• debuggingデバッグ（SLF4J MDC）のすべてのステップと報酬を記録します。
• timeTimeAutを明示的に処理します - サガを永遠にぶら下げさせないでください。
• testテスト障害シナリオ：サービス停止をシミュレートし、報酬の作業を確認します。

振り付けとオーケストレーションを使用するタイミング

• オーケストレーション：理解しやすく、テストしやすく、線形フローの方が適しています（注文例のように）。
• 振り付け：サービスが独立して進化する複雑でイベント駆動型のシステムの方が良いが、追跡してデバッグするのは難しい。

サガから始まるほとんどのJavaチームにとって、オーケストレーションが行く方法です。

佐賀パターンを実装することは、失敗を避けることではなく、それらのために優雅に設計することです。 Javaでは、Spring Boot's Ecosystemを使用して、ステップと補償に分解すると、驚くほど簡単です。

以上がJava分散システムにSAGAパターンを実装しますの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。