TP6 Think-Swoole の RPC サービスとメッセージ キューの統(tǒng)合とアプリケーション

現(xiàn)代のソフトウェア開(kāi)発では、RPC サービス (リモート プロシージャ コール) とメッセージ キューが一般的な技術(shù)的手段です。分散システムでのサービス呼び出しと非同期メッセージ処理を?qū)g現(xiàn)します。 Think-Swoole コンポーネントを TP6 フレームワークに統(tǒng)合すると、RPC サービスとメッセージ キューの機(jī)能を簡(jiǎn)単に実裝でき、開(kāi)発者が理解して適用できる簡(jiǎn)潔なコード例が提供されます。

1. RPC サービスの統(tǒng)合と使用

1. Swoole 拡張機(jī)能のインストール
   Think-Swoole の RPC サービスを統(tǒng)合する前に、まず Swoole 拡張機(jī)能をインストールする必要があります。 pecl コマンドを使用するか、ソース コードを手動(dòng)でダウンロードしてコンパイルしてインストールできます。
2. 構(gòu)成フレームワーク ファイル
   TP6 フレームワークの config/service.php ファイルを開(kāi)き、次の構(gòu)成項(xiàng)目を追加します。

return [
    // ... 其他配置項(xiàng)
    
    // RPC服務(wù)配置
    'rpc' => [
        // 默認(rèn)的RPC服務(wù)器
        'default' => [
            'host' => '0.0.0.0',      // 監(jiān)聽(tīng)地址
            'port' => 9501,           // 監(jiān)聽(tīng)端口
            'worker_num' => 4,        // 工作進(jìn)程數(shù)
            'package_max_length' => 2 * 1024 * 1024,    // 最大包長(zhǎng)度
            'open_eof_check' => true, // 開(kāi)啟EOF檢測(cè)
            'package_eof' => "

",    // 包結(jié)束標(biāo)記
        ]
    ],
];

3. RPC サービス クラスの作成
   アプリケーションの app/rpc ディレクトリに TestRpc クラスを作成します。コードは次のとおりです:

namespace apppc;

class TestRpc
{
    public function hello($name)
    {
        return 'Hello, ' . $name;
    }
}

4. RPC サービスの登録
   app/rpc/SwooleRpc.php ファイルを開(kāi)き、次のコードを追加します:

namespace apppc;

use thinkswooleRpcServer;
use thinkswoolepcProtocol;
use apppcTestRpc;

class SwooleRpc extends Server
{
    protected function register(): void
    {
        $protocol = new Protocol();
        $protocol->withServices([
            'TestRpc' => new TestRpc(),
        ]);

        $this->setProtocol($protocol);
    }
}

5. RPC サービスの開(kāi)始
   ターミナルを開(kāi)き、アプリケーションのルート ディレクトリに切り替えて、次のコマンドを?qū)g行して RPC サービスを開(kāi)始します。

php think swoole:rpc

この時(shí)點(diǎn)で、RPC サービスは正常に統(tǒng)合されました。 RPC クライアントを使用して、サーバーにリクエストを送信し、対応するデータを受信できます。

6. RPC クライアントを使用する
   app の下にあるコントローラー ファイルを開(kāi)き、次のコードを追加します:

namespace appcontroller;

use thinkswoolepcClient;

class Index
{
    public function index()
    {
        $rpc = new Client('http://127.0.0.1:9501');

        $result = $rpc->call('TestRpc', 'hello', ['Think-Swoole']);

        var_dump($result);

        return 'Hello, ThinkPHP6 + Think-Swoole';
    }
}

このように、# にアクセスするときに、 # #/index/index インターフェイスでは、リクエストは RPC クライアントを通じて RPC サーバーに送信され、結(jié)果が返されます。

Redis 拡張機(jī)能のインストール
1. Think-Swoole のメッセージ キューを統(tǒng)合する前に、Redis 拡張機(jī)能をインストールする必要があります。
   pecl コマンドを使用するか、ソース コードを手動(dòng)でダウンロードしてコンパイルしてインストールできます。
設(shè)定フレームワーク ファイル
2. TP6 フレームワークの
   config/swoole_http.php ファイルを開(kāi)き、次の設(shè)定項(xiàng)目を追加します。

return [
    // ... 其他配置項(xiàng)
    
    // 消息隊(duì)列配置
    'mq' => [
        // 默認(rèn)的消息隊(duì)列服務(wù)器
        'default' => [
            'host' => 'localhost',      // 主機(jī)地址
            'port' => 6379,             // 端口號(hào)
            'auth' => 'your_password',   // 密碼（可選）
            'db' => 0,                  // 數(shù)據(jù)庫(kù)編號(hào)（可選）
            'timeout' => 1,             // 超時(shí)時(shí)間（可選）
        ]
    ],
];

メッセージ キューを作成する Consumer
3. は、アプリケーションの
   app ディレクトリの下に mq ディレクトリを作成し、Consumer.php ファイルを作成します。コードは次のとおりです。

namespace appmq;

use thinkswoolemqConsumerInterface;
use thinkswoolemqMessageInterface;
use thinkswoolemqMessageHandlerInterface;

class Consumer implements ConsumerInterface
{
    public function consume(MessageInterface $message, MessageHandlerInterface $handler): void
    {
        // 根據(jù)自己的業(yè)務(wù)邏輯處理消息
        $data = $message->getBody();

        $handler->callback(MessageHandlerInterface::ACK);
    }
}

メッセージ キュー コンシューマの登録
4. 
   config/event.php ファイルを開(kāi)き、次の構(gòu)成を追加します:

use appmqConsumer;

return [
    // ... 其他配置項(xiàng)
    
    // 注冊(cè)消息隊(duì)列事件
    'subscribe' => [
        'mq:TestQueue' => Consumer::class,    // TestQueue為消息隊(duì)列的名稱
    ],
];

メッセージの発行
5. コントローラー ファイルを開(kāi)き、次のコードを追加します。
   

namespace appcontroller;

use thinkswoolemqPublisher;

class Index
{
    public function index()
    {
        $queue = 'TestQueue';
        $data = 'Hello, Think-Swoole';

        Publisher::publish($queue, $data);

        return 'Hello, ThinkPHP6 + Think-Swoole';
    }
}

このようにして、

/index/index インターフェイスにアクセスすると、メッセージはメッセージ キューにパブリッシュされ、コンシューマーは自動(dòng)的にメッセージを受信して??処理します。

この時(shí)點(diǎn)で、メッセージ キューが正常に統(tǒng)合されました。パブリッシングメッセージとコンシューマを組み合わせることで、効率的な非同期メッセージ処理を?qū)g現(xiàn)できます。
概要:

この記事では、Think-Swoole の RPC サービスとメッセージ キューを ThinkPHP6 フレームワークに統(tǒng)合する方法を紹介し、具體的なコード例を示します。これらの例を通じて、RPC サービスとメッセージ キューを簡(jiǎn)単に使用して、システムのパフォーマンスとスケーラビリティを向上させることができます。この記事が、Think-Swoole の RPC サービスとメッセージ キューの理解と適用に役立つことを願(yuàn)っています。


以上がTP6 Think-Swoole の RPC サービスとメッセージ キューの統(tǒng)合とアプリケーションの詳細(xì)內(nèi)容です。詳細(xì)については、PHP 中國(guó)語(yǔ) Web サイトの他の関連記事を參照してください。