ThinkPHP6 と Swoole で構築された RPC サービスを使用した高可用性タスク キューの実装

ThinkPHP6 と Swoole で構築された RPC サービスを使用した高可用性タスク キューの実装

[はじめに]
タスク キューは、最新の開発において重要な役割を果たします。時間のかかるタスクをメインプロセスから分離し、システムの応答速度を向上させ、システム障害やネットワークの中断時にタスクの信頼性と高可用性を確保できます。この記事では、ThinkPHP6 と Swoole を使用して高可用性タスク キューを構築し、非同期タスク処理を実装し、タスク キュー管理用の RPC サービスを提供する方法を紹介します。

[環境の準備]
開始する前に、次のような開発環境を準備する必要があります。

1. PHP 環境。PHP 7.4 以降を使用することをお勧めします。
2. Composer をインストールしてプロジェクトの依存関係を管理;
3. MySQL データベースをインストールしてタスク関連情報を保存;
4. Redis をインストールしてタスク キューのリアルタイム通知と監視を実装;
5. Swoole 拡張機能をインストールして、高パフォーマンスの RPC サービスと非同期タスク処理を実装します。

[プロジェクトの構築]

1. プロジェクトの作成
   Composer を使用して、新しい ThinkPHP6 プロジェクトを作成します。

composer create-project topthink/think hello-think

2. 依存関係の追加
   Swoole と Swoole-ide-helper の依存関係を、プロジェクトのルート ディレクトリにあるcomposer.json ファイルに追加します。

"require": {
    "swoole/swoole": "4.6.7",
    "swoole/ide-helper": "4.6.7"
}

次に、composer update コマンドを実行して依存関係をインストールします。

3. Swoole の RPC サービスとスケジュールされたタスクの構成
   プロジェクト ルート ディレクトリの config ディレクトリに swoole.php 構成ファイルを作成し、次の内容を追加します:

return [
    'rpc' => [
        'listen_ip' => '0.0.0.0',
        'listen_port' => 9501,
        'worker_num' => 4,
        'task_worker_num' => 4,
    ],
    'task' => [
        'task_ip' => '127.0.0.1',
        'task_port' => 9502,
    ],
    'timer' => [
        'interval' => 1000,
    ],
];

4. RPC サーバーの作成
   プロジェクトの app ディレクトリに rpc ディレクトリを作成し、rpc ディレクトリにサーバー ディレクトリを作成します。次に、TaskServer.php ファイルを作成し、次の内容を追加します:

namespace apppcserver;

use SwooleServer;
use thinkRpcServer;
use thinkacadeConfig;

class TaskServer
{
    protected $server;

    public function start()
    {
        $this->server = new Server(Config::get('swoole.rpc.listen_ip'), Config::get('swoole.rpc.listen_port'));

        $rpcServer = new RpcServer($this->server);

        $rpcServer->classMap([
            'apppcserviceTaskService',
        ]);

        $rpcServer->start();
    }
  
}

5. RPC サービスの作成
   rpc ディレクトリにサービス ディレクトリを作成し、サービス ディレクトリに TaskService を作成します。ファイル。 TaskService.php ファイルでは、addTask や getTask などのいくつかの特定の RPC メソッドを定義します。

namespace apppcservice;

class TaskService
{
    public function addTask($data)
    {
        // 处理添加任务的逻辑，将任务添加到任务队列中
    }

    public function getTask($id)
    {
        // 处理获取任务的逻辑，从任务队列中获取相关任务信息
    }

    // 其他RPC方法...
}

[タスクキューの実装]

1. タスクキューテーブルの作成
   MySQLデータベースにタスク関連の情報を格納するタスクテーブルを作成します。

CREATE TABLE `task` (
  `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
  `task_name` varchar(255) DEFAULT NULL,
  `task_data` text,
  `task_status` tinyint(1) DEFAULT NULL,
  `create_time` int(11) DEFAULT NULL,
  `update_time` int(11) DEFAULT NULL,
  PRIMARY KEY (`id`),
  KEY `task_status` (`task_status`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

2. タスク モデルの作成
   appmodel ディレクトリに Task.php ファイルを作成し、次の内容を追加します:

namespace appmodel;

use thinkModel;

class Task extends Model
{
    protected $autoWriteTimestamp = true;
    protected $dateFormat = 'Y-m-d H:i:s';
}

3. タスクの作成処理ロジック
   appservice ディレクトリに TaskService.php ファイルを作成し、次の内容を追加します。

namespace appservice;

use appmodelTask;

class TaskService
{
    public function addTask($data)
    {
        $task = new Task;
        $task->task_name = $data['task_name'];
        $task->task_data = $data['task_data'];
        $task->task_status = 0;
        $task->save();

        // TODO: 将任务添加到任务队列中
    }

    public function getTask($id)
    {
        return Task::find($id);
    }

    // 其他任务处理逻辑...
}

4. RPC サーバーがタスク処理ロジックを呼び出します
   TaskService.php にタスクを追加します。メソッドでは、タスクをデータベースに保存してからタスク キューに追加するなど、タスクを追加するロジックを処理します。

[スケジュールされたタスクの実装]

1. スケジュールされたタスクの処理ロジックを作成する
   appservice ディレクトリに TimerService.php ファイルを作成し、次の内容を追加します:

namespace appservice;

use appmodelTask;
use SwooleTimer;

class TimerService
{
    public function start()
    {
        Timer::tick(config('swoole.timer.interval'), function() {
            // TODO: 定时检查任务队列，处理待执行的任务
        });
    }
  
    // 其他定时任务处理逻辑...
}

2. TaskServer.php にスケジュールされたタスクを追加します。
   TaskServer.php の start メソッドに、スケジュールされたタスクの起動ロジックを追加します。

public function start()
{
    $this->server = new Server(Config::get('swoole.rpc.listen_ip'), Config::get('swoole.rpc.listen_port'));

    $rpcServer = new RpcServer($this->server);

    $rpcServer->classMap([
        'apppcserviceTaskService',
    ]);

    $timerService = new TimerService();
    $timerService->start();

    $rpcServer->start();
}

[RPC サービスとタスクキューの開始]
プロジェクトのルートディレクトリで以下のコマンドを実行し、RPC サービスとタスクキューを開始します。

php think swoole:rpc start

[RPC 呼び出しの例]
RPC を使用してアプリケーション内のタスク キューを呼び出す例。

class Index extends Controller
{
    public function index()
    {
        $taskService = new pppcserviceTaskService();
        $taskService->addTask([
            'task_name' => '任务名称',
            'task_data' => '任务数据',
        ]);
    }
}

[概要]
ThinkPHP6 と Swoole 拡張機能を使用することで、可用性の高いタスク キュー システムを構築できます。 RPC サービスを使用して、タスク キューを管理し、タスクの追加およびタスクを取得するためのインターフェイスを提供し、タスクの非同期処理を実現し、システムの応答速度と可用性を向上します。同時に、Swooleのスケジュールタスク機能を使用すると、タスクキューを定期的に確認し、保留中のタスクをタイムリーに処理できます。このようなシステム アーキテクチャは、システムの処理能力を向上させるだけでなく、優れた拡張性と耐障害性も備えています。

以上がThinkPHP6 と Swoole で構築された RPC サービスを使用した高可用性タスク キューの実装の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。