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

Swoole と Workerman は、PHP をベースとした 2 つの高性能ネットワーク通信フレームワークであり、メッセージ キューの処理とリアルタイム ログ分析における協調処理機能を備えています。この記事では、メッセージ キューとリアルタイム ログ分析におけるアプリケーションを紹介し、読者がそれらをよりよく理解して使用できるように、いくつかの具体的なコード例を示します。

1. Swoole と Workerman の概要
1.1 Swoole
Swoole は、PHP 用に設計された高性能ネットワーク通信フレームワークで、PHP がマルチプロセス、非同期 IO およびコルーチン機能をサポートできるようにします。 Swooleは、TCP/UDPサーバー、WebSocketサーバー、非同期クライアント、コルーチン、プロセス管理などの機能コンポーネントを豊富に提供しており、Web開発、ゲームサーバー、IoT、分散アプリケーションなどの分野に適しています。

1.2 Workerman
Workerman は、シンプルで効率的な PHP 非同期ネットワーク通信フレームワークであり、高性能 TCP/UDP サーバーの構築に使用できます。 Workerman は、マルチプロセスおよびイベント駆動型メソッドを通じて PHP の非同期 IO モデルを実装し、カスタム プロトコル、ハートビート検出、接続プールなどの機能をサポートします。 Workerman は、リアルタイム プッシュ、ゲーム サーバー、モノのインターネット、チャット ルームなどのシナリオに適しています。

2. メッセージ キューの処理
メッセージ キューは、非同期メッセージ送信を実装するために使用される、パブリッシュ/サブスクライブ モデルに基づく通信メカニズムです。 Swoole と Workerman は両方とも、システム コンポーネントの分離、非同期処理タスク、分散システムの実装などのシナリオで使用できるメッセージ キュー処理機能を提供します。

以下は、Swoole のメッセージ キュー関数を使用してパブリッシュ/サブスクライブ モデルを実装するサンプル コードです。

// 创建一个消息队列
$queue = new SwooleCoroutineChannel();

// 生产者向队列中发布消息
SwooleCoroutine::create(function () use ($queue) {
    while (true) {
        $message = rand(1, 100);
        $queue->push($message);
        echo "Producer: push message {$message}" . PHP_EOL;
        usleep(1000000);
    }
});

// 消费者从队列中获取消息
SwooleCoroutine::create(function () use ($queue) {
    while (true) {
        $message = $queue->pop();
        echo "Consumer: get message {$message}" . PHP_EOL;
        usleep(500000);
    }
});

上記のコードでは、メッセージ キューは SwooleCoroutineChannel を通じて作成されます。プロデューサは while ループを使用して乱数をキューにプッシュし、コンシューマは while ループを使用してキューからメッセージをポップして出力します。

Workerman のメッセージ キュー処理機能を使用するサンプル コードは次のとおりです。

// 创建一个消息队列
$queue = new WorkermanMessageQueueQueue();

// 生产者向队列中发布消息
WorkermanWorker::runAll();
WorkermanWorker::create(function ($worker) use ($queue) {
    $worker->onWorkerStart = function () use ($queue) {
        WorkermanTimer::add(1, function () use ($queue) {
            $message = rand(1, 100);
            $queue->push($message);
            echo "Producer: push message {$message}" . PHP_EOL;
        });
    };
});

// 消费者从队列中获取消息
WorkermanWorker::create(function ($worker) use ($queue) {
    $worker->onWorkerStart = function () use ($queue) {
        WorkermanTimer::add(2, function () use ($queue) {
            $message = $queue->pop();
            echo "Consumer: get message {$message}" . PHP_EOL;
        });
    };
});

上記のコードでは、WorkermanMessageQueueQueue を使用してメッセージ キューを作成します。プロデューサはタイマー WorkermanTimer::add() を使用して乱数をキューにプッシュし、コンシューマもタイマーを使用してキューからメッセージをポップし、出力します。

3. リアルタイム ログ分析
リアルタイム ログ分析は、大量のログ データをリアルタイムに処理および分析するための技術的手段です。 Swoole と Workerman はどちらもリアルタイムのログ分析機能を提供しており、大量のログ情報を処理するために使用できます。

以下は、Swoole を使用してリアルタイム ログ分析を実装するためのサンプル コードです:

// 监听一个TCP端口并接收日志数据
$server = new SwooleServer("0.0.0.0", 9501, SWOOLE_PROCESS, SWOOLE_SOCK_TCP);
$server->set([
    'worker_num' => 4,
]);
$server->on('connect', function ($server, $fd) {
    echo "Client {$fd} connected" . PHP_EOL;
});
$server->on('receive', function ($server, $fd, $fromId, $data) {
    // 对接收到的日志数据进行实时处理和分析
    echo "Receive log data: {$data}" . PHP_EOL;
});
$server->on('close', function ($server, $fd) {
    echo "Client {$fd} closed" . PHP_EOL;
});
$server->start();

上記のコードでは、TCP サーバーが作成され、クライアントによって送信されたデータを受信して​​処理します。 「receive」イベントをリッスンすることによって、データをログに記録します。

Workerman を使用してリアルタイム ログ分析を実装するサンプル コードは次のとおりです。

// 监听一个UDP端口并接收日志数据
$worker = new WorkermanWorker('udp://0.0.0.0:9502');
$worker->onMessage = function ($connection, $data) {
    // 对接收到的日志数据进行实时处理和分析
    echo "Receive log data: {$data}" . PHP_EOL;
};
WorkermanWorker::runAll();

上記のコードでは、$worker- を設定することで UDP サーバーが作成され、受信および処理されます。 >onMessage コールバック関数 クライアントから送信されたログ データ。

4. 概要
この記事では、メッセージ キューとリアルタイム ログ分析における Swoole と Workerman のアプリケーションを紹介し、いくつかの具体的なコード例を示します。 Swoole と Workerman の機能を使用することで、メッセージ キューとリアルタイム ログをより適切に処理および分析し、システムの非同期処理とリアルタイムのニーズを満たすことができます。この記事が、読者の皆様が Swoole と Workerman のメッセージ キューおよびリアルタイム ログ分析機能をよりよく理解し、使用する一助になれば幸いです。

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