Analyse et statistiques en temps réel des données des appareils à l'aide de PHP et MQTT

Utilisez PHP et MQTT pour réaliser des analyses et des statistiques en temps réel des données des appareils

Aperçu :
Avec le développement rapide de l'Internet des objets, de plus en plus d'appareils sont connectés via le réseau et génèrent une grande quantité de données en temps réel . L'analyse et les statistiques en temps réel de ces données peuvent nous aider à mieux comprendre l'utilisation des équipements, à détecter les pannes d'équipement à l'avance et à optimiser les performances de l'équipement. Cet article expliquera comment utiliser les protocoles PHP et MQTT pour réaliser une analyse et des statistiques en temps réel des données de l'appareil.

Introduction à MQTT :
MQTT est un protocole léger de transmission de messages de publication/abonnement, simple, compact, facile à mettre en œuvre et adapté aux environnements avec une bande passante réseau limitée. Les deux concepts fondamentaux du protocole MQTT sont l'éditeur et l'abonné. L'éditeur envoie le message à un sujet spécifique (Topic), et l'abonné reçoit le message en s'abonnant à ce sujet. Le protocole MQTT utilise une méthode de communication asynchrone et il n'y a pas de relation directe entre les éditeurs et les abonnés.

Les étapes pour utiliser PHP et MQTT pour obtenir une analyse et des statistiques en temps réel des données de l'appareil sont les suivantes :

Étape 1 : Installer et configurer le serveur MQTT
Vous devez d'abord installer et configurer un serveur MQTT, vous pouvez choisir Eclipse Mosquitto, EMQ ou RabbitMQ, etc.

Étape 2 : Écrivez le code PHP
Créez un fichier PHP, nommé mqtt_client.php, et ajoutez le code suivant dans le fichier :

<?php

require('phpMQTT.php');

$server = 'mqtt_server_ip'; // MQTT服务器的IP地址
$port = 1883; // MQTT服务器的端口号
$client_id = 'phpmqtt_client'; // 客户端ID

$mqtt = new phpMQTT($server, $port, $client_id);

if(!$mqtt->connect(true, NULL, NULL, NULL, NULL)){
    exit(1);
}

$topics['device_data/#'] = array('qos' => 0, 'function' => 'analyze_and_statistics');

$mqtt->subscribe($topics, 0);

while($mqtt->proc()){
}

$mqtt->close();

function analyze_and_statistics($topic, $msg){
    // 在此处进行设备数据分析与统计的业务逻辑处理
    
    echo "Received message on topic: $topic
";
    echo "Message: $msg
";
}

Étape 3 : Écrivez la logique d'analyse des données et de traitement statistique
Dans le code ci-dessus, la fonction analyse_et_statistiques définit traitement de logique métier pour l'analyse et les statistiques des données reçues de l'appareil. Vous pouvez écrire du code logique dans cette fonction selon vos propres besoins, comme calculer la moyenne, le maximum, le minimum, etc. en temps réel.

Étape 4 : Publier les données de l'appareil
Dans le code côté appareil, utilisez le protocole MQTT pour publier les données de l'appareil dans la rubrique correspondante. Par exemple, vous pouvez publier une rubrique appelée device_data/temperature et envoyer des données de température sous forme de messages à cette rubrique.

<?php

require('phpMQTT.php');

$server = 'mqtt_server_ip';
$port = 1883;
$client_id = 'device_client_1';

$mqtt = new phpMQTT($server, $port, $client_id);

if(!$mqtt->connect(true, NULL, NULL, NULL, NULL)){
    exit(1);
}

$mqtt->publish('device_data/temperature', '25.6', 0);

$mqtt->close();

Après avoir exécuté le fichier mqtt_client.php, il s'abonnera au sujet des données de l'appareil via MQTT et appellera la fonction analyse_and_statistics pour l'analyse des données et les statistiques lors de la réception des données.

Résumé :
Cet article explique comment utiliser les protocoles PHP et MQTT pour réaliser une analyse et des statistiques en temps réel des données de l'appareil. En vous abonnant au sujet des données de l'appareil et en écrivant le code de traitement de logique métier correspondant, nous pouvons analyser les données de l'appareil en temps réel et effectuer des calculs statistiques. Cette méthode d'analyse et de statistiques en temps réel peut nous aider à mieux comprendre l'utilisation de l'équipement et à améliorer les performances et la stabilité de l'équipement. En même temps, cette solution est flexible et évolutive et peut s'adapter à des scénarios d'applications IoT de différentes tailles et besoins.

Ci-dessus sont les étapes et les exemples de code pour utiliser PHP et MQTT pour mettre en œuvre une analyse et des statistiques en temps réel des données de l'appareil. J'espère que cela vous sera utile.

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!