Swoole と Workerman のメッセージ キューとリアルタイム モニタリングの共同処理機能

Swoole と Workerman は、高性能ネットワーク プログラミングとリアルタイム アプリケーション開発に広く使用されている 2 つの人気のある PHP フレームワークです。いずれも強力なメッセージキューやリアルタイム監視機能を備えており、連携処理により効率的なタスク実行やシステム管理を実現します。

メッセージ キューは、メッセージの送信者と受信者を分離するメカニズムであり、非同期シナリオで大量のメッセージまたはタスクを処理するために使用されます。 Swoole と Workerman はどちらも、複数のタスク間の依存関係を解決し、時間のかかる操作をキューに入れて非同期処理を行い、システムの応答速度と同時実行機能を向上させるために使用できるメッセージ キューの実装を提供します。

Swoole のメッセージ キューは、共有メモリとディスク ファイルに基づいた方式を採用しており、信頼性とパフォーマンスに優れています。以下は、Swoole のメッセージ キューの使用方法を示すサンプル コードです。

<?php
$queue = new SwooleMsgQueue(0x7000001);
$pid = pcntl_fork();
if ($pid == -1) {
    die("fork failed
");
} elseif ($pid > 0) {
    // 父进程，发送消息到队列
    $message = "Hello, Swoole!";
    $queue->push($message);
    echo "Message sent: $message
";
    pcntl_wait($status);
} else {
    // 子进程，接收消息并处理
    $message = $queue->pop();
    echo "Message received: $message
";
    exit(0);
}

Workerman のメッセージ キューは、基盤となるストレージとして Redis を使用し、Redis のパブリッシュおよびサブスクライブ メカニズムを通じてメッセージの送受信を実装します。以下は、Workerman のメッセージ キューの使用方法を示すサンプル コードです。

<?php
require_once __DIR__ . '/vendor/autoload.php';

use WorkermanWorker;
use WorkermanLibTimer;

$worker = new Worker();
$worker->count = 1;

$worker->onWorkerStart = function ($worker) {
    $redis = new Redis();
    $redis->connect('127.0.0.1', 6379);
    
    // 订阅名为“task”的频道
    $redis->subscribe(['task'], function ($redis, $channel, $message) {
        echo "Message received: $message
";
        // 在这里处理消息
    });
};

Worker::runAll();

リアルタイム監視とは、システムのステータスとパフォーマンスの指標をリアルタイムで表示できることを意味し、開発者がシステムの動作を理解するのに役立ちます。システム。 Swoole と Workerman はどちらも、開発者が問題を迅速に特定して解決できる強力なリアルタイム監視機能を提供します。以下は、Swoole のリアルタイム監視の使用方法を示すサンプル コードです。

<?php
$http = new SwooleHttpServer("0.0.0.0", 9501);

$http->on('request', function ($request, $response) use ($http) {
    $stats = $http->stats();
    $response->end(json_encode($stats));
});

$http->start();

上記のコードでは、HTTP サーバーが作成され、リクエストが受信されると、現在のサーバーのステータスと統計が表示されます。が返されます。 http://localhost:9501 にアクセスすると、リアルタイムの監視情報を表示できます。

Workerman のリアルタイム監視には、パフォーマンス データを influxdb に保存し、grafana を通じて表示できる grafana influxdb などのサードパーティ監視ツールを使用する必要があります。以下は、簡略化されたサンプル コードです。

<?php
$worker = new WorkermanWorker('text://0.0.0.0:1234');
$worker->count = 1;

$worker->task = function ($connection, $data) {
    // 处理任务
    $connection->send("Task completed");
};

$worker->onWorkerStart = function ($worker) {
    // 创建一个influxdb的连接
    $client = new InfluxDBClient('localhost', '8086');
    $database = $client->selectDB('workerman_stats');
    
    // 创建一个定时器，定时将性能数据写入influxdb
    Timer::add(1, function () use ($worker, $database) {
        $data = [
            [
                'measurement' => 'connections',
                'tags' => [
                    'worker' => $worker->id,
                ],
                'fields' => [
                    'value' => count($worker->connections),
                ],
            ],
        ];
        
        $database->writePoints($data);
    });
};

Worker::runAll();

上記のコードでは、Worker から継承されたカスタム Worker クラスが作成され、タイマーを通じてパフォーマンス データを influxdb に書き込みます。開発者は、grafana でデータ ソースとダッシュボードを構成して、システムの動作をリアルタイムで監視できます。

要約すると、Swoole と Workerman はどちらも強力なメッセージ キューとリアルタイム監視機能を備えており、開発者が高性能のリアルタイム アプリケーション システムを構築するのに役立ちます。開発者は自分のニーズに応じて適切なフレームワークを選択し、サンプルコードに基づいて実用的なアプリケーションを開発できます。

以上がSwoole と Workerman のメッセージ キューとリアルタイム モニタリングの共同処理機能の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。