Construire un système de surveillance en temps réel basé sur Workerman-Workerman-php.cn

Construire un système de surveillance en temps réel basé sur Workerman

王林

Libérer： 2023-08-10 14:09:20

original

806 Les gens l'ont consulté

Construire un système de surveillance en temps réel basé sur Workerman

Créer un système de surveillance en temps réel basé sur Workerman

Avec le développement continu d'Internet et des technologies de l'information, les systèmes de surveillance en temps réel ont reçu de plus en plus d'attention de tous les horizons. Le système de surveillance en temps réel peut être utilisé pour surveiller les serveurs, les équipements réseau, les données des capteurs, etc., détecter les problèmes en temps opportun et prendre les mesures correspondantes. Dans cet article, nous présenterons comment créer un système simple de surveillance en temps réel à l'aide du framework PHP Workerman.

Workerman est un framework de serveur SOCKET hautes performances développé uniquement en PHP, qui peut transmettre des données au navigateur en temps réel via du code PHP. Il est léger, performant et facile à étendre, et convient parfaitement au développement de systèmes de surveillance en temps réel.

Tout d'abord, nous devons installer Workerman sur le serveur. Il peut être installé via la commande suivante :

composer require workerman/workerman

Copier après la connexion

Une fois l'installation terminée, nous créons d'abord un simple fichier de serveur de surveillance server.php, le code est le suivant :

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

use WorkermanWorker;

$monitor = new Worker('websocket://0.0.0.0:2345');
$monitor->count = 4;

$monitor->onWorkerStart = function($monitor) {
    echo "监控服务器启动
";
};

$monitor->onMessage = function($connection, $data) {
    global $monitor;
    // 处理从客户端接收到的数据
    // 这里可以进行数据处理和分析，并将结果推送给客户端
};

Worker::runAll();

Copier après la connexion

Dans le code ci-dessus, nous introduisons d'abord le framework Workerman et créez un objet serveur de surveillance $monitor. L'adresse d'écoute est websocket://0.0.0.0:2345, ce qui signifie écouter le port 2345 de toutes les adresses IP. Ensuite, définissez l'attribut count de l'objet $monitor sur 4, ce qui signifie démarrer 4 processus du serveur de surveillance. Enfin, nous définissons la fonction de rappel onWorkerStart et la fonction de rappel onMessage de l'objet $monitor pour gérer la logique de démarrage du serveur et de réception des messages client.

Ensuite, nous écrivons une simple page frontale index.html pour afficher les données de surveillance. Le code est le suivant :

<!DOCTYPE html>
<html>
<head>
    <meta charset="UTF-8">
    <title>实时监控</title>
    <script src="https://code.jquery.com/jquery-3.6.0.min.js"></script>
</head>
<body>
    <div id="monitor"></div>

    <script>
        var ws = new WebSocket("ws://your-server-ip:2345");

        ws.onopen = function(event) {
            console.log("连接成功");
        };

        ws.onmessage = function(event) {
            var data = JSON.parse(event.data);
            // 处理从服务器接收到的数据
            // 这里可以更新前端页面的内容，展示监控数据
        };

        ws.onclose = function(event) {
            console.log("连接关闭");
        };
    </script>
</body>
</html>

Copier après la connexion

Dans le code ci-dessus, nous utilisons la technologie WebSocket pour communiquer avec le serveur en temps réel. Créez d’abord un objet WebSocket ws et spécifiez l’adresse et le numéro de port du serveur. Ensuite, nous utilisons les événements onopen, onmessage, onclose et autres de l'objet WebSocket pour gérer la logique de connexion au serveur, de réception des données du serveur et de fermeture de la connexion.

Enfin, nous pouvons écrire la logique de traitement et d'analyse des données dans la fonction de rappel onMessage dans le fichier server.php, et envoyer les données à la page front-end en temps réel via l'objet WebSocket. Voici un exemple simple :

$monitor->onMessage = function($connection, $data) {
    global $monitor;

    // 处理从客户端接收到的数据
    $result = // 处理和分析数据的逻辑

    // 将结果推送给客户端
    foreach($monitor->connections as $client) {
        $client->send(json_encode($result));
    }
};

Copier après la connexion

Dans le code ci-dessus, nous utilisons d'abord une variable $result pour le traitement et l'analyse des données et y enregistrons les résultats. Ensuite, parcourez toutes les connexions client via une boucle foreach et utilisez la méthode send pour envoyer les résultats à chaque client sous la forme d'une chaîne JSON.

Grâce aux étapes ci-dessus, nous avons réussi à créer un système de surveillance simple en temps réel à l'aide du framework Workerman. En introduisant le fichier index.html dans la page frontale, une communication en temps réel et un affichage des données avec le serveur de surveillance peuvent être obtenus.

Bien sûr, l'exemple ci-dessus n'est qu'une simple démonstration, et le système de surveillance en temps réel réel sera plus complexe et complet. Vous pouvez étendre et améliorer davantage ce système en fonction de vos propres besoins, en ajoutant davantage d'indicateurs et de fonctions de suivi. J'espère que cet article pourra vous aider à comprendre l'utilisation du framework Workerman et le développement de systèmes de surveillance en temps réel.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!