So implementieren Sie mit Workerman ein Echtzeitüberwachungssystem

Mit der rasanten Entwicklung des Internets und der steigenden Nachfrage der Menschen nach Echtzeitüberwachung werden webbasierte Echtzeitüberwachungssysteme immer beliebter. In diesem Artikel wird erläutert, wie Sie mit Workerman ein Echtzeitüberwachungssystem implementieren. Das System kann nach Bedarf mehrere Datentypen überwachen, z. B. Protokolle, Leistungsindikatoren, Maschinenstatus usw. Es bietet außerdem Echtzeit-Alarmfunktionen, um Administratoren zu unterstützen Erfassen Sie den Betriebsstatus des Systems rechtzeitig.

Workerman ist ein leistungsstarkes TCP/UDP-Server-Framework, das in reinem PHP geschrieben ist und sich durch hohe Parallelität, geringe Latenz und einfache Erweiterung auszeichnet. Mit Workerman können Sie problemlos einige leistungsstarke Anwendungsszenarien mit hoher Parallelität implementieren, z. B. Dienste mit langer Verbindung, Chatrooms, Online-Spieleserver usw. Im Folgenden stellen wir vor, wie Sie mit Workerman ein Echtzeitüberwachungssystem implementieren.

1. Erstellen Sie eine Workerman-Anwendung

Bevor Sie Workerman verwenden, müssen Sie das Framework herunterladen und installieren. Hier nehmen wir die Linux-Umgebung als Beispiel und installieren sie mit Composer. Geben Sie im Terminal den folgenden Befehl ein, um Workerman zu installieren:

composer require workerman/workerman

Nach Abschluss der Installation können wir unsere erste Workerman-Anwendung erstellen, indem wir eine PHP-Datei erstellen.

require_once DIR '/vendor/autoload.php';

// Erstellen Sie einen Worker, um Port 2345 abzuhören und über das Websocket-Protokoll zu kommunizieren
$ws_worker = new WorkermanWorker("websocket:/ /0.0. 0.0:2345");

// Starten Sie 4 Prozesse, um Dienste für die Außenwelt bereitzustellen
$ws_worker->count = 4;

// Wenn der Client erfolgreich eine Verbindung herstellt, senden Sie eine Willkommensnachricht
$ws_worker ->onConnect = function ($connection) {

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

};

// Wenn der Client Daten sendet, verarbeiten Sie diese
$ws_worker->onMessage = function ($connection, $data) {

// 把收到的消息回显给客户端
$connection->send($data);

};

// Wenn der Client die Verbindung trennt, verarbeiten Sie es
$ws_worker->onClose = function ($connection) {

echo "Connection closed

";
};

// Run Worker
WorkermanWorker::run();

Im obigen Code haben wir einen Worker erstellt, der Port 2345 abhört und über das Websocket-Protokoll kommuniziert. Wenn der Client erfolgreich eine Verbindung herstellt, wird eine Willkommensnachricht gesendet, und die empfangenen Daten werden an den gesendet Client; Wenn der Client die Verbindung trennt, wird eine Meldung ausgegeben, dass die Verbindung geschlossen ist.

2. Implementieren Sie die Echtzeitüberwachungsfunktion.

Wir haben jetzt erfolgreich eine Workerman-Anwendung erstellt entspricht nicht unseren Echtzeit-Überwachungsanforderungen. Als nächstes stellen wir vor, wie wir Workerman zur Implementierung der Echtzeit-Überwachungsfunktion verwenden Protokolle als Beispiel.

Wir müssen die im Geschäftssystem generierten Protokolle überwachen und sie zur Anzeige in Echtzeit übertragen Rufen Sie die onMessage-Rückruffunktion des Workers auf und senden Sie dann den Protokollinhalt in Echtzeit an das Frontend:

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; Zeitintervall für die Überwachung von Protokolldateien, Einheit: Sekunden

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

// do something

};

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

echo "Connection closed

";

};

/ Protokolldateien überwachen

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)) {
            // 实时推送日志信息到前端
            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 stellt die bereit Timer-Klasse, die regelmäßig eine Rückruffunktion auslösen kann. Wir können sie verwenden, um das Protokollverzeichnis regelmäßig zu überwachen. Beim Lesen des Protokollinhalts müssen Sie auf die zuletzt gelesene Position achten, um zu vermeiden, dass der Inhalt wiederholt an derselben Position gelesen wird. Schieben Sie den Protokollinhalt nach dem Lesen an das Frontend, um ihn in Echtzeit anzuzeigen.

2.2 Realisierung der Echtzeit-Alarmfunktion

Im Echtzeit-Überwachungssystem ist auch die Echtzeit-Alarmfunktion ein wesentlicher Bestandteil. Wir können Alarminformationen in Echtzeit an das Frontend senden, wenn durch die Überwachung erkannte Alarmereignisse auftreten. Das Folgende ist ein Codebeispiel für die Alarmfunktion:

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; // Zeitintervall zur Überwachung von Alarmereignissen, Einheit: Sekunden

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

// do something

};

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

echo "Connection closed

";

};

// Alarmereignisse überwachen

Timer::add($alarm_interval, function ( ) use( $ws_worker) {

// 监控逻辑
$alarm_type = 'warning'; // 告警类型
$alarm_data = 'alarm data'; // 告警数据
if ($alarm_type && $alarm_data) {
    // 实时推送告警信息到前端
    foreach($ws_worker->connections as $con){
        if ($con->websocket) {
            $con->send(json_encode(array(
                'type' => 'alarm',
                'data' => $alarm_data,
                'alarm_type' => $alarm_type
            )));
        }
    }
}

});

Überwachen Sie Alarmereignisse regelmäßig, und die Überwachungslogik wird entsprechend den spezifischen Geschäftsanforderungen implementiert. Wenn ein Alarmereignis auftritt, werden die Alarminformationen in Echtzeit an das Frontend übertragen .

3. Zusammenfassung

Der Einsatz von Workerman zur Implementierung eines Echtzeitüberwachungssystems kann uns dabei helfen, den Betriebsstatus des Systems in Echtzeit zu erfassen und die Effizienz und Genauigkeit des Systembetriebs und der Systemwartung zu verbessern. In diesem Artikel wird erläutert, wie Sie mit Workerman Protokollüberwachungs- und Echtzeitalarmfunktionen im Überwachungssystem implementieren und entsprechende Codebeispiele bereitstellen. Mit diesen Grundlagen können wir je nach spezifischen Geschäftsanforderungen entsprechend erweitern und ein umfassenderes Echtzeit-Überwachungssystem vervollständigen.

Das obige ist der detaillierte Inhalt vonSo implementieren Sie mit Workerman ein Echtzeitüberwachungssystem. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!