Bagaimana untuk melaksanakan klien berasaskan MQTT menggunakan PHP (contoh kod)

MQTT ialah protokol pemindahan mesej ringan berdasarkan model terbitkan/langgan. MQTT menyediakan sambungan kependaman rendah dan boleh dipercayai yang amat sesuai untuk komunikasi dengan peranti perkakasan seperti penderia kecil dan mikropengawal. Dalam artikel ini, kami akan memperkenalkan cara melaksanakan kod klien berasaskan MQTT menggunakan PHP.

Pengenalan kepada protokol MQTT

Sebelum kita mula menulis kod, kita perlu memahami spesifikasi protokol MQTT. Spesifikasi protokol MQTT mentakrifkan dua peranan: penerbit dan pelanggan. Penerbit menerbitkan mesej kepada topik, manakala pelanggan melanggan mesej pada topik tertentu.

Dalam MQTT, proses menghantar mesej merangkumi tiga langkah: mewujudkan sambungan, menerbitkan mesej dan melanggan topik. Protokol TCP digunakan untuk mewujudkan sambungan, dan penghantaran mesej MQTT dilakukan pada sambungan TCP. Mesej MQTT dibahagikan kepada dua bahagian: pengepala tetap dan pengepala berubah. Pengepala tetap mengandungi maklumat seperti jenis mesej dan QoS, manakala pengepala pembolehubah mengandungi maklumat pembolehubah seperti nama topik dan ID mesej.

Protokol MQTT menyokong tiga tahap kualiti perkhidmatan (QoS): QoS0, QoS1 dan QoS2. QoS0 ialah tahap paling rendah Penerbit hanya menghantar mesej sekali sahaja dan tidak memastikan mesej itu dihantar kepada pelanggan. QoS1 dan QoS2 memastikan bahawa mesej dihantar kepada pelanggan.

Pelaksanaan kod klien MQTT

Dalam PHP, kami boleh menggunakan sambungan Mosquitto-PHP untuk melaksanakan pembangunan klien MQTT. Mosquitto-PHP ialah sambungan PHP untuk berkomunikasi dengan broker MQTT, yang menyediakan satu set fungsi untuk melaksanakan protokol MQTT. Mula-mula, anda perlu memastikan anda telah memasang sambungan Mosquitto broker dan Mosquitto-PHP. Ia boleh dipasang melalui arahan berikut:

sudo apt-get install mosquitto mosquitto-clients

sudo pecl install Mosquitto-alpha

Selepas pemasangan, kita boleh menulis kod klien PHP berdasarkan MQTT.

Pertama, kita perlu menyambung kepada broker MQTT. Apabila menyambung, anda perlu menentukan alamat, port dan ID pelanggan broker MQTT. Kod khusus adalah seperti berikut:

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

Seterusnya, kami boleh menerbitkan mesej kepada topik tertentu. Apabila menerbitkan mesej, anda perlu menentukan nama topik, kandungan mesej dan tahap kualiti perkhidmatan. Berikut ialah contoh kod:

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

Akhir sekali, kami boleh melanggan satu atau lebih topik untuk menerima mesej daripada pelayan. Apabila melanggan topik, anda perlu menentukan nama topik dan tahap kualiti perkhidmatan. Berikut ialah contoh melanggan topik:

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

Contoh penuh kod klien MQTT

Berikut ialah contoh lengkap kod klien MQTT:

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

Di atas Kod akan menyambung kepada broker MQTT, menerbitkan mesej dan melanggan mesej pada topik tertentu.

Ringkasan

Dalam artikel ini, kami memperkenalkan cara melaksanakan kod pelanggan berasaskan MQTT menggunakan PHP. Kami mempelajari asas spesifikasi protokol MQTT dan menggunakan sambungan Mosquitto-PHP untuk mengakses broker MQTT. Dalam pembangunan sebenar, kita boleh menggunakan pengetahuan ini untuk membangunkan aplikasi yang berkomunikasi dengan peranti perkakasan. Kami berharap artikel ini dapat membantu pembangun yang berkomunikasi melalui protokol MQTT.

Atas ialah kandungan terperinci Bagaimana untuk melaksanakan klien berasaskan MQTT menggunakan PHP (contoh kod). Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!