Tutoriel d'introduction et d'utilisation de la bibliothèque d'extensions MQTT de PHP-tutoriel php-php.cn

Tutoriel d'introduction et d'utilisation de la bibliothèque d'extensions MQTT de PHP

王林

Libérer： 2023-07-08 11:34:02

original

1968 Les gens l'ont consulté

Introduction et tutoriel d'utilisation de la bibliothèque d'extensions MQTT de PHP

Introduction :
Avec le développement rapide de l'Internet des objets, MQTT (Message Queuing Telemetry Transport), en tant que protocole de communication léger, a reçu une attention et une application généralisées. Dans le développement de PHP, en utilisant la bibliothèque d'extensions MQTT, nous pouvons facilement communiquer avec le serveur MQTT. Cet article présentera les concepts de base et l'utilisation de la bibliothèque d'extensions MQTT et montrera comment utiliser MQTT pour la publication et l'abonnement de messages via du code. exemples.

1. Introduction à la bibliothèque d'extensions MQTT
La bibliothèque d'extensions MQTT est une extension PHP utilisée pour communiquer avec le serveur MQTT. Elle fournit une série de fonctions et de classes qui nous permettent d'implémenter facilement les fonctions MQTT. Avant de commencer, nous devons installer la bibliothèque d'extensions. Selon la version de PHP et le type de système d'exploitation que vous utilisez, vous pouvez l'installer de différentes manières.

2. Utilisation de la bibliothèque d'extensions MQTT

Connexion au serveur MQTT
La première étape pour utiliser la bibliothèque d'extensions MQTT consiste à créer un client MQTT et à établir une connexion avec le serveur MQTT. Pendant le processus de connexion, nous devons spécifier le nom d'hôte, le numéro de port et l'ID client du serveur.

<?php
$host = 'mqtt.example.com';
$port = 1883;
$clientID = 'php-mqtt-client';

$mqtt = new MosquittoClient($clientID);
$mqtt->connect($host, $port);

Copier après la connexion

Publier un message
Pour publier un message sur le serveur MQTT, nous devons spécifier le sujet (Topic) et le contenu du message. Le message peut être envoyé au sujet correspondant en appelant la fonction publier. publish函数即可将消息发送到相应的主题上。

<?php
$topic = 'example/topic';
$message = 'Hello, MQTT!';

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

Copier après la connexion

其中，第三个参数指定了QoS级别，0表示最多一次的传输，1表示至少一次的传输，2表示仅有一次的传输。第四个参数用于指定是否在消息中保留自己的Client ID。

订阅消息
订阅消息是MQTT中最重要的功能之一。通过调用subscribe函数，可以让客户端订阅一个或多个主题，并指定相应的回调函数来处理收到的消息。

<?php
$topic = 'example/topic';

// 定义回调函数
$mqtt->onMessage(function($message) {
    echo 'Received message: ' . $message->payload . PHP_EOL;
});

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

Copier après la connexion

在上面的例子中，我们定义了一个匿名回调函数用于处理收到的消息。回调函数将会在收到相应的消息时被调用，并输出收到的消息内容。