PHP et MQTT : Communication de données pour construire un système de gestion d'entrepôt intelligent
Résumé : Avec le développement continu de la technologie de l'Internet des objets, les systèmes de gestion d'entrepôt intelligents sont progressivement devenus un outil clé pour la gestion et la production d'entreprise. Cet article explique comment utiliser les protocoles PHP et MQTT pour créer la fonction de communication de données d'un système de gestion d'entrepôt intelligent et fournit quelques exemples de code simples.
Introduction
Le système de gestion d'entrepôt intelligent est un système qui réalise la gestion et la surveillance des entrepôts grâce à la technologie Internet des objets. Il peut suivre l'état et la capacité de stockage des équipements d'entreposage en temps réel et rappeler aux gestionnaires d'effectuer une planification et une planification raisonnables grâce à divers mécanismes d'alarme.
La communication des données est un élément essentiel du système de gestion d'entrepôt intelligent. Elle est chargée de transmettre les données de divers capteurs et appareils au serveur du système pour une analyse plus approfondie et une prise de décision. Le protocole MQTT est un protocole de messagerie de publication/abonnement léger qui convient parfaitement à la communication entre appareils IoT.
Étape 1 : Installer MQTT Broker
Tout d'abord, nous devons installer un MQTT Broker sur le serveur, qui est responsable de la réception et de la distribution des messages MQTT. Ici, nous utilisons Mosquitto comme courtier MQTT. Vous pouvez installer Mosquitto via la commande suivante :
sudo apt-get update sudo apt-get install -y mosquitto mosquitto-clients
Une fois l'installation terminée, vous pouvez exécuter la commande suivante pour démarrer le service Mosquitto :
mosquitto
Étape 2 : Configurer la connexion au serveur MQTT
Pour utiliser le protocole MQTT en PHP, nous besoin d'utiliser une bibliothèque tierce. Ici, nous choisissons d'utiliser la bibliothèque phpMQTT, qui est un client PHP MQTT simple et facile à utiliser.
Vous pouvez télécharger et importer la bibliothèque depuis le référentiel GitHub de phpMQTT. Ajoutez ensuite le code suivant à votre code :
require("phpMQTT.php"); $mqtt = new phpMQTT("localhost", 1883, "clientId");
Ici, nous créons une instance du client MQTT, nous nous connectons au port par défaut 1883 du serveur local et spécifions un ID client.
Étape 3 : Connectez-vous au serveur MQTT
Ensuite, nous devons nous connecter au serveur MQTT. Ajoutez le code suivant pour vous connecter à Mosquitto Broker :
if ($mqtt->connect(true, null, "username", "password")) { echo "Connected to MQTT Broker"; // 进行其他操作 $mqtt->close(); } else { echo "Failed to connect MQTT Broker"; }
Ici, nous utilisons la fonction connect()
pour nous connecter au serveur MQTT. Le nom d'utilisateur et le mot de passe peuvent éventuellement être transmis pour l'authentification. connect()
函数来连接到MQTT服务器。可以可选地传递用户名和密码进行认证。
步骤4:发布消息
要在MQTT中发布消息,我们可以使用publish()
函数。添加以下代码来发布一条消息:
$mqtt->publish("topic", "Hello, MQTT!");
这里,我们将消息“Hello, MQTT!”发布到名为“topic”的主题上。
步骤5:订阅消息
要订阅MQTT信息,我们需要使用subscribe()
Pour publier un message dans MQTT, nous pouvons utiliser la fonction publish()
. Ajoutez le code suivant pour publier un message :
$topics = array("topic1", "topic2"); $mqtt->subscribe($topics, 0); while ($mqtt->proc()) { // 持续接收和处理消息 }
Ici, nous publions le message "Bonjour, MQTT !" dans le sujet nommé "topic".
Pour vous abonner aux messages MQTT, nous devons utiliser la fonction subscribe()
et spécifier une fonction de rappel pour chaque sujet. Ajoutez le code suivant pour vous abonner aux messages :
Ici, nous nous abonnerons aux sujets nommés "topic1" et "topic2" en précisant une QoS (Quality of Service) de 0.
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!