MQTT (Message Qeuing Telemetry Transport) ialah protokol penghantaran mesej ringan yang biasa digunakan untuk komunikasi antara peranti IoT. PHP ialah bahasa pengaturcaraan sebelah pelayan yang biasa digunakan yang boleh digunakan untuk membangunkan klien MQTT. Artikel ini akan memperkenalkan cara menggunakan PHP untuk membangunkan klien MQTT dan memasukkan kandungan berikut:
Protokol MQTT adalah berdasarkan model publish-subscribe, yang mengandungi komponen asas berikut:
Dalam protokol MQTT, Pelanggan menghantar dan menerima mesej dengan mewujudkan sambungan dengan Broker. Setiap mesej terdiri daripada Topik dan Muatan (kandungan mesej Muatan boleh menjadi sebarang jenis data, seperti teks, nombor, JSON dan format lain). Pelanggan boleh menerima mesej yang dihantar oleh penerbit dengan melanggan Topik tertentu dan penerbit boleh menerbitkan mesej kepada Topik tertentu dan semua pelanggan yang melanggan Topik akan menerima mesej tersebut.
Dalam PHP, anda boleh menggunakan Perpustakaan Mosquitto untuk membangunkan pelanggan MQTT. Perpustakaan Mosquitto ialah perpustakaan klien MQTT ringan yang menyokong versi protokol MQTT 3.1 dan 3.1.1.
Membangunkan klien MQTT menggunakan Perpustakaan Mosquitto memerlukan langkah-langkah berikut:
<?php // 1. 安装Mosquitto Library // 安装Mosquitto Library需要使用系统自带的包管理工具,如apt-get、yum等 // 例如,在Ubuntu下可以使用以下命令安装:sudo apt-get install mosquitto mosquitto-clients php-mosquitto // 2. 创建Mosquitto Client $mqtt = new MosquittoClient(); // 3. 连接到MQTT Broker $mqtt->connect('localhost', 1883); // 4. 发布和订阅消息 // 发布消息 $mqtt->publish('test_topic', 'hello world', 0); // 订阅消息 $mqtt->subscribe('test_topic', 0); $mqtt->loop(); // 5. 断开与Broker的连接 $mqtt->disconnect(); unset($mqtt); ?>
untuk memutuskan sambungan daripada Broker.
Contoh: Terbitkan dan langgan mesej menggunakan klien PHP MQTTconnect
方法连接到本地的MQTT Broker。然后,我们使用publish
方法发布了一条名为“test_topic”的消息。接着,我们使用subscribe
方法订阅了同样的话题,并使用loop
方法开始循环接收消息。最后,我们使用disconnect
<?php // 1. 安装Mosquitto Library // 2. 创建Mosquitto Client $mqtt = new MosquittoClient(); // 3. 连接到MQTT Broker $mqtt->connect('localhost', 1883); // 4. 发布和订阅消息 // 发布消息 $mqtt->publish('test_topic', 'hello world', 0); // 订阅消息 $mqtt->subscribe('test_topic', 0); $mqtt->loop(function ($message) { echo 'Received message: ' . $message->payload . PHP_EOL; }); // 5. 断开与Broker的连接 $mqtt->disconnect(); unset($mqtt); ?>
Atas ialah kandungan terperinci Panduan Pembangunan Klien PHP MQTT. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!