ThinkPHP6 と Swoole によって開発された RPC サービスを使用した効率的なキャッシュ管理

Swoole が開発した ThinkPHP6 および RPC サービスを使用して、効率的なキャッシュ管理を実現します

はじめに:
最新の Web アプリケーションでは、キャッシュ管理はパフォーマンスと高速応答を向上させるために行われます。重要なパーツのひとつ。データ アクセスを高速化するために、通常はキャッシュを使用して頻繁にアクセスされるデータを保存し、毎回の複雑なデータベース クエリ操作を回避します。この記事では、ThinkPHP6 と Swoole を使用して、キャッシュ管理機能を実装する効率的な RPC (リモート プロシージャ コール) サービスを開発する方法を紹介します。

1. はじめに
ThinkPHP は、開発者が高パフォーマンスの Web アプリケーションを迅速に構築できるようにする豊富な機能とコンポーネントを提供する優れた PHP 開発フレームワークです。 Swoole は、PHP コードを非同期かつノンブロッキングで実行するように変換できる高性能 PHP 拡張機能で、アプリケーションの同時実行性と応答速度を大幅に向上させます。この記事では、Web アプリケーション開発フレームワークとして ThinkPHP6 を使用し、Swoole と組み合わせて効率的なキャッシュ管理システムを実装します。

2. アーキテクチャ設計
効率的なキャッシュ管理を実現するには、キャッシュ操作用のインターフェイスを提供する RPC サービスを設計する必要があります。 RPC サービスは独立して実行でき、Web アプリケーションからリクエストを受信し、処理のためにキャッシュ サーバーに転送します。具体的なアーキテクチャ設計は次のとおりです。

1. Web アプリケーションは、RPC クライアントを呼び出してリクエストを送信します。
2. RPC クライアントは要求を RPC サーバーに送信します。
3. RPC サーバーはリクエストを受信して​​処理します。
4. RPC サーバーは、特定のキャッシュ操作のためにリクエストをキャッシュ サーバーに転送します。
5. キャッシュ サーバーは結果を RPC サーバーに返します。
6. RPC サーバーは結果を RPC クライアントに返します。
7. RPC クライアントは結果を Web アプリケーションに返します。

3. コードの実装

1. ThinkPHP6 と Swoole のインストール
   始める前に、ThinkPHP6 と Swoole 拡張機能をインストールする必要があります。Composer コマンドを使用して以下をインストールできます。
   combos require topthink/think-swoole
   composer require swoole/swoole
2. RPC サーバーの作成
   まず、RPC サーバーの機能を実装するための RpcServer という名前のクラスを作成します。コードは次のとおりです:

namespace apppc;

use SwooleHttpServer;
use SwooleProcess;
use SwooleCoroutine;
use SwooleRuntime;
use think acadeDb;
use thinkContainer;

class RpcServer
{

private $serv;
private $processNum;

public function __construct($port, $processNum)
{
    $this->serv = new Server('0.0.0.0', $port);
    $this->processNum = $processNum;
}

public function start()
{
    $this->serv->on('Start', [$this, 'onStart']);
    $this->serv->on('ManagerStart', [$this, 'onManagerStart']);
    $this->serv->on('Request', [$this, 'onRequest']);
    $this->serv->on('WorkerStart', [$this, 'onWorkerStart']);

    $this->serv->set([
        'worker_num' => $this->processNum,
    ]);

    $this->serv->start();
}

public function onStart($serv)
{
    Process::daemon();
    swoole_set_process_name('rpc_server');
}

public function onManagerStart($serv)
{
    swoole_set_process_name('rpc_manager');
}

public function onRequest($request, $response)
{
    Coroutine::create(function () use ($request, $response) {
        $container = Container::getInstance();
        $container->instance('thinkRequest', $request);
        $container->instance('thinkResponse', $response);

        $http = $container->make('thinkApp', [
            $container,
        ]);

        $response = $http->run();
        $response->send();
    });
}

public function onWorkerStart($serv, $workerId)
{
    if ($workerId >= $serv->setting['worker_num']) {
        Runtime::enableCoroutine();
    }
}

}

3. キャッシュ管理コントローラーの作成
   次に、という名前の CacheController を作成します。コントローラー クラスは、キャッシュ操作の特定のロジックを実装するために使用されます。コードは次のとおりです。

namespace apppccontroller;

use think acadeCache;

class CacheController
{

public function get($key)
{
    return Cache::get($key);
}

public function set($key, $value, $expire = null)
{
    return Cache::set($key, $value, $expire);
}

public function delete($key)
{
    return Cache::delete($key);
}

}

4. ルーティングの構成
   アプリケーションのルート ディレクトリで、rpc.php ファイルを作成し、次のコードを追加します:

use think acadeRoute;

Route:: group('rpc', function () {

Route::rule('cache/:action', 'rpc.Cache/:action');

});

5. RPC サーバーを開始します
   最後に、エントリ ファイルを書き込む必要があります。 RPCサーバーを起動します。パブリック ディレクトリに、rpc.php という名前のファイルを作成し、次のコードを追加します:

use apppcRpcServer;

require DIR . '/.. / vendor/autoload.php';

$port = 9501; // 実行中のポート番号
$processNum = 4; // プロセス数

$server = new RpcServer($ port , $processNum);
$server->start();

4. RPC クライアントを使用してキャッシュ管理サービスを呼び出す
Web アプリケーションでは、RPC クライアントを使用してキャッシュ管理サービスを呼び出すことができます、キャッシュを操作します。以下は、RPC クライアントを使用するためのサンプル コードです。

$client = new SwooleHttpClient('127.0.0.1', 9501);

// キャッシュ/get メソッドを呼び出して、キャッシュ値
$request = array(

'action' => 'get',
'key' => 'user:1',

);
$client->post('/rpc/cache', $request);
$response = json_decode($client ->body, true);
if ($response['status'] == 200) {

echo '缓存值为：' . $response['data'];

}

// キャッシュ/セット メソッドを呼び出して、キャッシュ値
$request = array(

'action' => 'set',
'key' => 'user:1',
'value' => 'John Doe',
'expire' => 3600,

);
$client->post('/rpc/cache', $request);
$response = json_decode($client ->body, true) ;
if ($response['status'] == 200) {

echo '设置缓存成功';

}

// キャッシュ/削除メソッドを呼び出して、キャッシュされた値
$request = 配列 (

'action' => 'delete',
'key' => 'user:1',

);
$client->post('/rpc/cache', $request);
$response = json_decode($client ->body, true);
if ($response['status'] == 200) {

echo '删除缓存成功';

}

概要:
この記事の概要では、ThinkPHP6 と Swoole を使用して、キャッシュ管理機能を実装する効率的な RPC サービスを開発する方法を学びました。 RPC サーバーと RPC クライアントの連携により、キャッシュされたデータを簡単に呼び出して操作することができ、アプリケーションのパフォーマンスが向上し、ユーザーにより良いエクスペリエンスを提供できます。もちろん、キャッシュ管理に加えて、他の機能モジュールを組み合わせて、さまざまなアプリケーション シナリオのニーズを満たすさらに多くの RPC サービスを開発することもできます。この記事があなたの開発作業に役立つことを願っています。

以上がThinkPHP6 と Swoole によって開発された RPC サービスを使用した効率的なキャッシュ管理の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。