Communication et contrôle de l'Internet des objets via PHP et MQTT

Avec le développement de la technologie de l'Internet des objets, de plus en plus d'appareils et d'objets sont connectés à Internet, et la communication et le contrôle entre ces appareils et objets sont nécessaires. Cet article présentera comment utiliser les protocoles PHP et MQTT pour mettre en œuvre la communication et le contrôle de l'Internet des objets.

1. Qu'est-ce que le protocole MQTT ?

MQTT (Message Queuing Telemetry Transport) est un protocole léger de transmission de messages qui est implémenté sur la base du modèle de publication/abonnement. Le protocole MQTT peut être utilisé dans des environnements réseau à faible bande passante et peu fiables et est un protocole adapté aux appareils IoT.

Les concepts de base du protocole MQTT sont :

• Client : un appareil ou une application qui peut se connecter au serveur MQTT et publier ou s'abonner à des messages.
• Serveur (Courtier) : courtier de messages MQTT, responsable de la réception, du stockage et du transfert des messages.
• Sujet : représente la catégorie ou le nom d'un message. Les sujets peuvent être constitués d'un ou plusieurs mots, séparés par "/". Par exemple, la rubrique « /sensor/humidity » représente les données d'un capteur d'humidité.
• Message : l'information véhiculée dans la communication. Les messages MQTT peuvent contenir des sujets et des charges utiles, et la charge utile peut être n'importe quelle donnée binaire.

2. Utilisez le protocole MQTT pour implémenter la communication IoT

1. Installez le serveur MQTT

Tout d'abord, vous devez installer le serveur proxy de messages MQTT sur le serveur. Les serveurs MQTT couramment utilisés incluent Mosquitto et EMQX.

Sur le système Ubuntu, vous pouvez installer Mosquitto via la commande suivante :

$ sudo apt-get update
$ sudo apt-get install mosquitto mosquitto-clients

2. PHP se connecte au serveur MQTT

PHP peut se connecter au serveur de courtier de messages MQTT en appelant la bibliothèque client MQTT pour implémenter la fonction de publication et messages d'abonnement. Les bibliothèques clientes MQTT couramment utilisées incluent phpMQTT et MQTT.php.

En utilisant la bibliothèque phpMQTT, vous pouvez utiliser le code suivant pour vous connecter au serveur MQTT et publier des messages :

<?php
require("phpMQTT.php");

$mqtt = new phpMQTT("example.com", 1883, "PHP MQTT Client");

if ($mqtt->connect()) {
    $mqtt->publish("/sensor/humidity", "25");
    $mqtt->close();
} else {
    echo "Connection failed!";
}
?>

Dans le code ci-dessus, vous devez fournir l'adresse et le numéro de port du serveur MQTT, ainsi que le nom du client. IDENTIFIANT. La méthode connect() peut être utilisée pour se connecter au serveur MQTT, la méthode publier() est utilisée pour publier des messages et la méthode close() peut fermer la connexion MQTT.

3. PHP s'abonne aux sujets MQTT

En plus de publier des messages, PHP peut également s'abonner aux sujets MQTT et recevoir des messages envoyés par le serveur MQTT.

En utilisant la bibliothèque phpMQTT, vous pouvez implémenter les fonctions d'abonnement à des sujets et de réception de messages via le code suivant :

<?php
require("phpMQTT.php");

function messageHandler($topic, $payload) {
    echo "Received message on topic: $topic
Payload: $payload

";
}

$mqtt = new phpMQTT("example.com", 1883, "PHP MQTT Client");

if ($mqtt->connect()) {
    $mqtt->subscribe("/sensor/temperature", "messageHandler");
    while ($mqtt->proc()) {}
    $mqtt->close();
} else {
    echo "Connection failed!";
}
?>

Dans le code ci-dessus, utilisez la méthode Subscribe() pour vous abonner au sujet /mainstreet/topic, et le Le paramètre $payload est reçu par la fonction de rappel messageHandler() Les nouvelles sont arrivées. La boucle code>while ($mqtt->proc()) {} peut maintenir l'état d'abonnement, recevoir et traiter les messages du serveur MQTT.

3. Utilisez les protocoles PHP et MQTT pour réaliser le contrôle IoT

Le protocole MQTT peut non seulement être utilisé pour réaliser la communication IoT, mais également pour réaliser le contrôle des appareils. Le serveur MQTT peut recevoir des messages de clients, puis envoyer les messages à d'autres clients qui ont besoin de recevoir des messages. De cette façon, un contrôle entre les appareils peut être réalisé.

1. Contrôler les lumières LED

Ce qui suit est un exemple de code pour contrôler les lumières LED à l'aide du protocole MQTT et PHP :

<?php
require("phpMQTT.php");

function messageHandler($topic, $payload) {
    $pattern = '/^led=(on|off)$/';
    if (preg_match($pattern, $payload, $matches)) {
        if ($matches[1] == "on") {
            system("gpio write 0 1"); // Turn on LED
        } else {
            system("gpio write 0 0"); // Turn off LED
        }
    }
}

$mqtt = new phpMQTT("example.com", 1883, "PHP MQTT Client");

if ($mqtt->connect()) {
    $mqtt->subscribe("/devices/led", "messageHandler");
    while ($mqtt->proc()) {}
    $mqtt->close();
} else {
    echo "Connection failed!";
}
?>

Dans le code ci-dessus, GPIO est utilisé pour contrôler l'interrupteur des lumières LED lorsque le message est reçu par MQTT. correspond au format "led=on" ou "led=off", l'interrupteur d'éclairage LED sera contrôlé.

2. Contrôler le moteur

Ce qui suit est un exemple de code pour contrôler le moteur à l'aide du protocole MQTT et PHP :

<?php
require("phpMQTT.php");

function messageHandler($topic, $payload) {
    $pattern = '/^motor=(forward|backward|stop)$/';
    if (preg_match($pattern, $payload, $matches)) {
        if ($matches[1] == "forward") {
            // Turn motor forward
        } elseif ($matches[1] == "backward") {
            // Turn motor backward
        } else {
            // Stop motor
        }
    }
}

$mqtt = new phpMQTT("example.com", 1883, "PHP MQTT Client");

if ($mqtt->connect()) {
    $mqtt->subscribe("/devices/motor", "messageHandler");
    while ($mqtt->proc()) {}
    $mqtt->close();
} else {
    echo "Connection failed!";
}
?>

Dans le code ci-dessus, utilisez des expressions régulières pour faire correspondre le contenu du message MQTT S'il correspond à ". Le format motor=forward", "motor= "backward" ou "motor=stop" contrôlera le sens de mouvement du moteur.

Résumé

Cet article présente comment utiliser les protocoles PHP et MQTT pour mettre en œuvre la communication et le contrôle de l'Internet des objets. Grâce au protocole MQTT, la communication et le contrôle entre les appareils peuvent être réalisés dans des environnements réseau à faible bande passante et peu fiables, ce qui constitue la base des applications IoT.

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!