Maison  >  Article  >  développement back-end  >  Comment implémenter un client basé sur MQTT en utilisant PHP (exemple de code)

Comment implémenter un client basé sur MQTT en utilisant PHP (exemple de code)

PHPz
PHPzoriginal
2023-04-12 13:58:281453parcourir

MQTT est un protocole léger de transfert de messages basé sur le modèle de publication/abonnement. MQTT fournit une connexion fiable et à faible latence, particulièrement adaptée à la communication avec des périphériques matériels tels que de petits capteurs et microcontrôleurs. Dans cet article, nous présenterons comment implémenter du code client basé sur MQTT à l'aide de PHP.

Introduction au protocole MQTT

Avant de commencer à écrire du code, nous devons comprendre la spécification du protocole MQTT. La spécification du protocole MQTT définit deux rôles : éditeur et abonné. Un éditeur publie des messages sur un sujet, tandis qu'un abonné s'abonne aux messages sur un sujet spécifique.

Dans MQTT, le processus d'envoi de messages comprend trois étapes : établir une connexion, publier des messages et s'abonner à des sujets. Le protocole TCP est utilisé pour établir la connexion et la transmission des messages MQTT est effectuée sur la connexion TCP. Les messages MQTT sont divisés en deux parties : en-tête fixe et en-tête variable. L'en-tête fixe contient des informations telles que le type de message et la qualité de service, tandis que l'en-tête variable contient des informations variables telles que le nom du sujet et l'ID du message.

Le protocole MQTT prend en charge trois niveaux de qualité de service (QoS) : QoS0, QoS1 et QoS2. QoS0 est le niveau le plus bas. L'éditeur n'envoie le message qu'une seule fois et ne garantit pas que le message soit remis à l'abonné. QoS1 et QoS2 garantissent que les messages sont transmis aux abonnés.

Implémentation du code client MQTT

En PHP, nous pouvons utiliser l'extension Mosquitto-PHP pour implémenter le développement du client MQTT. Mosquitto-PHP est une extension PHP pour communiquer avec les courtiers MQTT. Elle fournit un ensemble de fonctions pour implémenter le protocole MQTT. Tout d’abord, vous devez vous assurer que les extensions Mosquitto Broker et Mosquitto-PHP sont installées. Il peut être installé via la commande suivante : Mosquitto-PHP扩展来实现MQTT客户端的开发。Mosquitto-PHP是一个用于与MQTT代理进行通信的PHP扩展,它提供了一组函数来实现MQTT协议。首先,需要确保已经安装了Mosquitto brokerMosquitto-PHP扩展。可以通过以下命令进行安装:

sudo apt-get install mosquitto mosquitto-clients

sudo pecl install Mosquitto-alpha

安装之后,我们就可以编写基于MQTT的PHP客户端代码了。

首先,我们需要连接到MQTT代理。连接时需要指定MQTT代理的地址、端口和客户端ID。具体代码如下:

$mqtt = new Mosquitto\Client('client_id');
$mqtt->connect('127.0.0.1', 1883, 60);

接下来,我们可以发布一条消息到特定主题。在发布消息时,需要指定主题名称、消息内容和服务质量等级。下面是一个示例代码:

$mqtt->publish('topic', 'message', 0);

最后,我们可以订阅一个或多个主题接收来自服务器的消息。在订阅主题时,需要指定主题名称和服务质量等级。以下是一个订阅主题的示例:

$mqtt->subscribe('topic', 0);

MQTT客户端代码完整示例

下面是一个完整的MQTT客户端代码示例:

connect('127.0.0.1', 1883, 60);
$mqtt->publish('topic', 'message', 0);
$mqtt->subscribe('topic', 0);
$mqtt->loopForever();
?>

以上代码将连接到MQTT代理,发布一条消息并订阅特定主题的消息。

总结

在本文中,我们介绍了如何使用PHP实现基于MQTT的客户端代码。我们学习了MQTT协议规范和使用Mosquitto-PHPrrreee

Après l'installation, nous pouvons écrire du code client PHP basé sur MQTT. 🎜🎜Tout d'abord, nous devons nous connecter au courtier MQTT. Lors de la connexion, vous devez spécifier l'adresse, le port et l'ID client du courtier MQTT. Le code spécifique est le suivant : 🎜rrreee🎜Ensuite, nous pouvons publier un message sur un sujet spécifique. Lors de la publication d'un message, vous devez spécifier le nom du sujet, le contenu du message et le niveau de qualité du service. Voici un exemple de code : 🎜rrreee🎜Enfin, on peut s'abonner à un ou plusieurs sujets pour recevoir les messages du serveur. Lorsque vous vous abonnez à un sujet, vous devez spécifier le nom du sujet et le niveau de qualité du service. Voici un exemple d'abonnement à un sujet : 🎜rrreee🎜 Exemple complet de code client MQTT 🎜🎜 Voici un exemple de code client MQTT complet : 🎜rrreee🎜 Le code ci-dessus se connectera au courtier MQTT, publiera un message et s'abonnera à messages sur un sujet précis. 🎜🎜Résumé🎜🎜Dans cet article, nous avons présenté comment implémenter du code client basé sur MQTT à l'aide de PHP. Nous avons appris la spécification du protocole MQTT et les bases de l'utilisation de l'extension Mosquitto-PHP pour accéder au courtier MQTT. Dans le développement réel, nous pouvons utiliser ces connaissances pour développer des applications qui communiquent avec des périphériques matériels. Nous espérons que cet article sera utile aux développeurs communiquant via le protocole MQTT. 🎜

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!

Déclaration:
Le contenu de cet article est volontairement contribué par les internautes et les droits d'auteur appartiennent à l'auteur original. Ce site n'assume aucune responsabilité légale correspondante. Si vous trouvez un contenu suspecté de plagiat ou de contrefaçon, veuillez contacter admin@php.cn