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

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

王林

リリース： 2023-10-12 13:12:25

オリジナル

920 人が閲覧しました

使用TP6 Think-Swoole构建的RPC服务实现分布式事务处理

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

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

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

アーキテクチャの概要

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

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

ThinkPHP 6 のインストール

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

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

ログイン後にコピー

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

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

Swoole プラグインの構成

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

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

ログイン後にコピー

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

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

ログイン後にコピー

RPC サービスの作成

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

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

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

<?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' => [
        // ...
    ],
    // ...
];

ログイン後にコピー

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

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

ディレクトリに

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

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

ログイン後にコピー

RPC サービスを呼び出す

app/controller

TransactionController.php

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

/transaction/beginTransaction

/transaction/commit

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

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