Javaバックエンド機能開発で分散トランザクションを実装するにはどうすればよいですか?

Java バックエンド関数開発で分散トランザクションを実装するにはどうすればよいですか?

分散システムでは、トランザクション処理は一般的かつ重要な要件です。 Java バックエンド開発では、複数のサービスを介してデータ操作が実行されるシナリオがよくありますが、このとき、データの一貫性と信頼性を確保するために分散トランザクションを実装する方法を検討する必要があります。この記事では、分散トランザクションを実装する一般的な方法を紹介し、コード例で説明します。

1. 分散トランザクションとは何ですか?

分散トランザクションとは、複数の独立したアプリケーションまたはサービスが関与するトランザクション操作を指します。各アプリケーションまたはサービスには独自のデータベースがあり、これらのデータベースは異なる場所にあります。物理ノード。分散トランザクションでは、データの一貫性を維持するために、参加している各アプリケーションまたはサービスがトランザクションを正しく送信またはロールバックできることを確認する必要があります。

2. 分散トランザクションを実装する方法

1. メッセージ キューに基づく 2 フェーズ コミット (2PC)

2PC は一般的な実装分散です。従来のトランザクション方法のアイデアは、各参加者 (Participant) のトランザクション操作を調整するコーディネーター (Coordinator) を導入することです。具体的な手順は次のとおりです。

(1) 調整準備フェーズ (Prepare Phase): コーディネーターはすべての参加者に準備リクエストを送信し、参加者がトランザクションを実行する準備ができていることを要求します。参加者は準備操作を完了すると、準備完了メッセージ (Ready) をコーディネーターに送信します。

(2) グローバル コミット フェーズ (コミット フェーズ): すべての参加者から準備メッセージを受信した後、コーディネーターはグローバル コミット リクエストを送信し、参加者にトランザクション コミット操作の実行を要求します。参加者は送信操作を完了すると、送信完了メッセージ (コミット) をコーディネーターに送信します。

(3) グローバル ロールバック フェーズ (ロールバック フェーズ): いずれかの参加者が準備フェーズまたはグローバル コミット フェーズで失敗した場合、コーディネーターはグローバル ロールバック リクエストを送信し、参加者にトランザクションのロールバック操作を実行するよう要求します。 。

2. 信頼性の高いメッセージ確認に基づく結果整合性 (TCC)

TCC は、信頼性の高いメッセージ確認に基づく結果整合性スキームであり、その基本的な考え方は、次の 3 つの段階があります。リソースの確認、取り消しを行い、トランザクション制御を実現します。具体的な手順は次のとおりです。

(1) 試行フェーズ: 参加者はリソースを予約し、ローカルでトランザクション操作を実行します。

(2) 確認フェーズ: 参加者は確認メッセージを送信し、実際のトランザクション送信操作を実行します。

(3) キャンセルフェーズ: いずれかの参加者が確認フェーズで失敗した場合、元に戻す操作が実行され、予約されたリソースが解放されます。

3. コード例

以下は Spring Boot と Spring Cloud に基づく Java の例で、メッセージ キューに基づいて 2PC を使用して分散トランザクションを実装する方法を示しています。

まず、関連する依存関係を pom.xml ファイルに追加する必要があります:

<!-- Spring Boot -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter</artifactId>
</dependency>

<!-- Spring Cloud -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-stream-binder-rabbit</artifactId>
</dependency>

次に、メッセージ キューに基づいて 2PC サービスを作成します:

@Service
public class TransactionService {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    @Transactional
    public void performTransaction() {
        // 执行本地事务操作

        // 发送准备请求消息
        rabbitTemplate.convertAndSend("transactionExchange", "prepare");

        // 等待所有参与者返回准备就绪消息
        // ...

        // 发送全局提交请求
        rabbitTemplate.convertAndSend("transactionExchange", "commit");

        // 等待所有参与者返回提交完成消息
        // ...
    }

    @RabbitListener(queues = "prepareQueue")
    public void handlePrepareMessage(String message) {
        // 处理准备请求消息
        // ...

        // 发送准备就绪消息
        rabbitTemplate.convertAndSend("transactionExchange", "ready");
    }

    @RabbitListener(queues = "commitQueue")
    public void handleCommitMessage(String message) {
        // 处理全局提交请求消息
        // ...

        // 发送提交完成消息
        rabbitTemplate.convertAndSend("transactionExchange", "commitComplete");
    }
}

上記ではたとえば、RabbitMQ をメッセージ キューとして使用すると、メッセージ キューに基づく 2PC ソリューションが実装されます。特定のメッセージ処理ロジックは、ビジネス ニーズに応じて調整できます。

結論:

この記事では、Java バックエンド開発で分散トランザクションを実装する一般的な方法を紹介し、コード例を使用して説明します。実際の開発では、ビジネス ニーズに合った分散トランザクション ソリューションを選択することが非常に重要であり、パフォーマンスや可用性などの要素も考慮する必要があります。この記事が分散トランザクションを実装する際の読者の参考になれば幸いです。

以上がJavaバックエンド機能開発で分散トランザクションを実装するにはどうすればよいですか?の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。