TP6 Think-Swoole で構築された RPC サービスを使用した分散トランザクション処理

TP6 Think-Swoole で構築された RPC サービスを使用して分散トランザクション処理を実装する

分散システムは、最新のインターネット アプリケーションでますます一般的になってきています。ただし、分散トランザクション処理は、分散環境で一貫性を実現するのが課題です。複数のサービスにわたる複雑なビジネス ロジックを扱う場合、データの一貫性と信頼性を確保することが特に重要になります。

この記事では、ThinkPHP 6 と Swoole を使用して RPC (Remote Procedure Call、リモート プロシージャ コール) サービスを構築し、このサービスを通じて分散トランザクション処理を実装します。基本的な RPC サービスを作成する方法と、それを通じてトランザクション操作を実行する方法を説明します。

1. アーキテクチャの概要

次のアーキテクチャを使用して分散トランザクション処理を実装します。

• メイン アプリケーション (クライアント):コア アプリケーションは、ビジネス ロジックの処理と分散トランザクションの処理を担当します。
• サブアプリケーション (サーバー): これは RPC サービス プロバイダーであり、リモート呼び出しリクエストの受信と実行を担当します。
• データベース: データベース ストレージ エンジンとして MySQL を使用します。

2. ThinkPHP 6 のインストール

まず、ThinkPHP 6 をインストールする必要があります。インストールは Composer を通じて完了できます。次のコマンドを実行します。

composer create-project topthink/think=6.* myproject

3. Swoole 拡張機能のインストール

ThinkPHP の Swoole プラグインを使用するには、次のコマンドもインストールする必要があります。 Swoole 拡張機能。インストールガイドは Swoole の公式 Web サイトでご覧いただけます。

4. Swoole プラグインの構成

ThinkPHP 6 では、Swoole プラグインが拡張機能として提供されています。アプリケーション構成ファイル config/app.php で構成する必要があります。次のコード セグメントを見つけます。

return [
    // ...
    'ext' => [
        // ...
    ],
    // ...
];

以下に示すように、thinkswooleSwoole を ext 配列に追加します。

return [
    // ...
    'ext' => [
        thinkswooleSwoole::class,
    ],
    // ...
];

5. RPC サービスの作成

ThinkPHP 6 では、ミドルウェアを使用して RPC サービスを実装できます。新しいミドルウェア クラスを作成し、app/middleware ディレクトリに RpcMiddleware.php という名前のファイルを作成し、その中に次のコードを記述します。 RPC サービスの構成

6. ThinkPHP 6 では、構成ファイルを通じてミドルウェアを定義できます。
config/middleware.php

ファイルを開き、次のように使用するミドルウェア クラスを追加します。

<?php

namespace appmiddleware;

use SwooleCoroutine;
use thinkswoolepcserverResponse;
use thinkswoolepcserverReceiveContext;
use thinkswooleRpc;

class RpcMiddleware
{
    public function handle(ReceiveContext $context, Closure $next)
    {
        // 执行远程过程调用
        $response = new Response();
        $rpc = new Rpc();
        $rpc->dispatch($context->getRaw(), $response);
        // 获取执行结果
        $result = $response->getMessage();

        if ($response->getCode() === Rpc::RESULT_CODE_SUCCESS) {
            // 执行成功，将结果返回给客户端
            $context->reply($result);
        } else {
            // 出现错误，设置错误代码和消息
            $context->setCode($response->getCode());
            $context->setMessage($response->getMessage());
        }

        return $next($context);
    }
}

次に、ファイルを config/swoole.php に追加する必要があります。

ファイル内に追加の設定を行います。次のコード スニペットを見つけます:

return [
    // ...
    // rpc服务中间件
    appmiddlewareRpcMiddleware::class,
];

次のコードを rpc

配列に追加します:

return [
    // ...
    'rpc' => [
        // ...
    ],
    // ...
];

トランザクション サービスの作成

7. 分散トランザクションを処理するために、TransactionService という名前のサービス クラスを作成します。
app/rpc/services

ディレクトリに

TransactionService.php という名前のファイルを作成し、その中に次のコードを記述します。

return [
    // ...
    'rpc' => [
        'server' => [
            // 绑定服务地址和端口
            'host' => '127.0.0.1',
            'port' => 9502,
        ],
        'services' => [
            // 注册服务
            'AppRpcServicesTransactionService',
        ],
    ],
    // ...
];

RPC サービスを呼び出す

#最後に、メイン アプリケーションで RPC サービスを呼び出し、分散トランザクション処理を実行します。新しいコントローラー クラスを作成し、
8. app/controller
ディレクトリに

TransactionController.php

という名前のファイルを作成し、その中に次のコードを記述します: <div class="code" style="position:relative; padding:0px; margin:0px;"><pre class='brush:php;toolbar:false;'>&lt;?php namespace apppcservices; use thinkswoolepcRequest; use thinkswoolepcResponse; class TransactionService { public function beginTransaction(Request $request, Response $response) { // 执行事务开始操作 // ... $response-&gt;setCode(Response::CODE_SUCCESS); $response-&gt;setMessage('事务开始成功'); } public function commit(Request $request, Response $response) { // 执行事务提交操作 // ... $response-&gt;setCode(Response::CODE_SUCCESS); $response-&gt;setMessage('事务提交成功'); } public function rollback(Request $request, Response $response) { // 执行事务回滚操作 // ... $response-&gt;setCode(Response::CODE_SUCCESS); $response-&gt;setMessage('事务回滚成功'); } }</pre><div class="contentsignin">ログイン後にコピー</div></div> <code> RPC サービスのテスト

これで、ブラウザまたは他の HTTP クライアントを使用して RPC サービスをテストできます。ブラウザで
9. /transaction/beginTransaction
、

/transaction/commit

、および /transaction/rollback ルートにアクセスして、RPC でトランザクションの開始、コミット、トランザクションをトリガーします。ロールバック操作。操作が成功すると、「操作成功」メッセージが表示されます。 これは、TP6 Think-Swoole によって構築された RPC サービスを使用して分散トランザクション処理を実装する基本プロセスです。 RPC サービスを通じて、分散環境で複雑なトランザクション操作を処理し、データの一貫性と信頼性を確保できます。

以上がTP6 Think-Swoole で構築された RPC サービスを使用した分散トランザクション処理の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。