インターネットの急速な発展とリアルタイム監(jiān)視に対する人々の需要の高まりに伴い、Web ベースのリアルタイム監(jiān)視システムの人気が高まっています。この記事では、Workerman を使用してリアルタイム監(jiān)視システムを?qū)g裝する方法を紹介します。このシステムは、ログ、パフォーマンス指標(biāo)、マシンの狀態(tài)など、必要に応じて複數(shù)のデータ タイプを監(jiān)視できます。また、管理者を支援するリアルタイム アラーム機(jī)能も提供します。システムの稼働狀況をタイムリーに把握します。

Workerman は、純粋な PHP で書かれた高性能 TCP/UDP サーバー フレームワークで、高い同時(shí)実行性、低いレイテンシー、簡単な拡張という特徴があります。 Workerman を使用すると、ロング リンク サービス、チャット ルーム、オンライン ゲーム サーバーなど、高性能で同時(shí)実行性の高いアプリケーション シナリオを簡単に実裝できます。以下では、Workerman を使用してリアルタイム監(jiān)視システムを?qū)g裝する方法を紹介します。

1. Workerman アプリケーションの作成

Workerman を使用する前に、フレームワークをダウンロードしてインストールする必要があります。ここでは Linux 環(huán)境を例として、composer を使用してインストールします。ターミナルに次のコマンドを入力して Workerman をインストールします。

composer require workman/workerman

インストールが完了したら、PHP ファイルを作成して最初の Workerman アプリケーションを作成できます。

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

// ポート 2345 をリッスンし、次を使用して通信するワーカーを作成します。 WebSocket プロトコル
$ws_worker = new WorkermanWorker("websocket://0.0.0.0:2345");

// 外部サービスを提供する 4 つのプロセスを開始します
$ws_worker->count = 4;

// クライアントが正常に接続したら、ウェルカム メッセージを送信します。
$ws_worker->onConnect = function ($connection) {

$connection->send('Welcome to workerman!');

};

// クライアントがデータを送信すると、それを処理します。
$ws_worker->onMessage = function ($connection, $data) {

// 把收到的消息回顯給客戶端
$connection->send($data);

};

// クライアントがデータを送信するとき、切斷 接続されたら、プロセス
$ws_worker->onClose = function ($connection) {

echo "Connection closed

";
};

// Worker
WorkermanWorker を?qū)g行します。 :run();

上記のコードでは、ポート 2345 をリッスンし、WebSocket プロトコルを使用して通信するワーカーを作成しました。クライアントが正常に接続すると、ウェルカム メッセージが送信されます。クライアントがデータを送信すると、ウェルカム メッセージが送信されます。 , 受信したデータはクライアントにエコーされます; クライアントが切斷すると、接続が閉じられたことを示すメッセージが出力されます. 最後に Worker を起動(dòng)して実行します。

2. リアルタイム監(jiān)視機(jī)能

Workerman アプリケーションを正常に作成できましたが、これではリアルタイム監(jiān)視のニーズが満たされません。次に、Workerman を使用してリアルタイム監(jiān)視機(jī)能を?qū)g裝する方法を紹介します。リアルタイムを明確にする必要があります 監(jiān)視システムはどのようなデータを監(jiān)視する必要がありますか? ここでは例としてログを取り上げます

2.1 監(jiān)視ログ

リアルタイム監(jiān)視システムは、業(yè)務(wù)システムで生成されたログをリアルタイムでフロントエンドにプッシュ表示 Worker の onMessage コールバック関數(shù)で業(yè)務(wù)システムのログディレクトリを監(jiān)視し、ログ內(nèi)容をリアルタイムでフロントエンドに送信できます。コードは次のとおりです:

require_once DIR . '/vendor /autoload.php';
use WorkermanLibTimer;
use WorkermanWorker;

$ws_worker = new Worker("websocket://0.0.0.0:2345");

$ ws_worker->count = 4;

$log_dir = '/path/to/log-dir/ ';
$monitor_interval = 1; // ログ ファイルを監(jiān)視する時(shí)間間隔、単位: 秒

$ws_worker->onMessage = function ($connection, $data) use($log_dir) {

// do something

};

$ws_worker->onClose = function ( $connection) {

echo "Connection closed

";
};

// モニターログ ファイル
Timer::add($monitor_interval, function () use($ws_worker, $log_dir ) {

if (!is_dir($log_dir)) {
    return;
}
$files = scandir($log_dir);
foreach ($files as $file) {
    if ($file == "." || $file == "..") {
        continue;
    }
    $filename = $log_dir . '/' . $file;
    if (is_file($filename)) {
        $fp = fopen($filename, 'r');
        $lastpos = $ws_worker->lastpos[$filename] ?? 0;
        fseek($fp, $lastpos);
        $data = fread($fp, filesize($filename) - $lastpos);
        fclose($fp);
        if (!empty($data)) {
            // 實(shí)時(shí)推送日志信息到前端
            foreach($ws_worker->connections as $con){
                if ($con->websocket) {
                    $con->send(json_encode(array(
                        'type' => 'log',
                        'data' => $data,
                        'filename' => $filename
                    )));
                }
            }
            // 更新上次讀取位置
            $ws_worker->lastpos[$filename] = ftell($fp);
        }
    }
}

});

Workerman は、トリガーできる Timer クラスを提供します。コールバック関數(shù)を定期的に使用すると、ログ ディレクトリを定期的に監(jiān)視できます。ログの內(nèi)容を読み取るときは、同じ位置の內(nèi)容を繰り返し読み込まないよう、最後に読み取った位置に注意する必要があります。ログの內(nèi)容を読み取った後、フロントエンドにプッシュしてリアルタイムに表示します。

2.2 リアルタイムアラーム機(jī)能の実現(xiàn)

リアルタイム監(jiān)視システムでは、リアルタイムアラーム機(jī)能も欠かせません。監(jiān)視により検知したアラームイベントが発生した際に、リアルタイムにアラーム情報(bào)をフロントエンドに送信できます。以下はアラート関數(shù)のコード例です:

require_once DIR . '/vendor/autoload.php';
use WorkermanLibTimer;
use WorkermanWorker;

$ws_worker = new Worker("websocket://0.0.0.0:2345");

$ws_worker->count = 4;

$alarm_interval = 1; //アラーム イベントの監(jiān)視時(shí)間間隔、単位: 秒

$ws_worker->onMessage = function ($connection, $data) {

// do something

};

$ws_worker-> ;onClose = function ($connection) {

echo "Connection closed

";
};

// アラーム イベントを監(jiān)視する
Timer::add($alarm_interval, function () use( $ws_worker ) {

// 監(jiān)控邏輯
$alarm_type = 'warning'; // 告警類型
$alarm_data = 'alarm data'; // 告警數(shù)據(jù)
if ($alarm_type && $alarm_data) {
    // 實(shí)時(shí)推送告警信息到前端
    foreach($ws_worker->connections as $con){
        if ($con->websocket) {
            $con->send(json_encode(array(
                'type' => 'alarm',
                'data' => $alarm_data,
                'alarm_type' => $alarm_type
            )));
        }
    }
}

});

アラーム イベントを定期的に監(jiān)視し、特定のビジネス ニーズに従って監(jiān)視ロジックが実裝されます。アラーム イベントの発生が検出されると、アラーム情報(bào)が表示されます。リアルタイムでフロントエンドにプッシュされます。

3. 概要

Workermanを利用してリアルタイム監(jiān)視システムを?qū)毪工毪?、システムの稼働狀況をリアルタイムに把握し、システムの運(yùn)用保守の効率と精度を向上させることができます。この記事では、Workerman を使用して監(jiān)視システムにログ監(jiān)視とリアルタイム アラーム機(jī)能を?qū)g裝する方法を紹介し、対応するコード例も示します。これらの基盤により、特定のビジネス ニーズに応じて拡張し、より完全なリアルタイム監(jiān)視システムを完成させることができます。

以上がWorkerman を使用してリアルタイム監(jiān)視システムを?qū)g裝する方法の詳細(xì)內(nèi)容です。詳細(xì)については、PHP 中國語 Web サイトの他の関連記事を參照してください。