<前言>現(xiàn)在，物聯(lián)網(wǎng)（IoT）已經(jīng)成為了不可撼動(dòng)的趨勢(shì)。MQTT（Message Queuing Telemetry Transport）協(xié)議則成為了連接物聯(lián)網(wǎng)設(shè)備和應(yīng)用云的極好的協(xié)議之一。而使用PHP處理MQTT通信則是常見(jiàn)的需求。本文將講述MQTT協(xié)議PHP應(yīng)用，從MQTT協(xié)議基礎(chǔ)、MQTT原理、MQTT在PHP中的應(yīng)用等方面進(jìn)行探究。<一>MQTT協(xié)議基礎(chǔ)
MQTT協(xié)議是用于輕量級(jí)的互聯(lián)/物聯(lián)網(wǎng)的連接協(xié)議，不同于HTTP，它更加輕巧、迅捷。此協(xié)議偏重于網(wǎng)絡(luò)方面的連接，而不是安全方面，因此可以稱作一種“最小連接建立”協(xié)議。下面拿生活常見(jiàn)的一個(gè)例子來(lái)說(shuō)明MQTT協(xié)議是如何工作的。
比如，我們?cè)诠臼褂肊lectric Imp系統(tǒng)，通過(guò)MQTT協(xié)議將打印機(jī)數(shù)據(jù)與實(shí)時(shí)監(jiān)控系統(tǒng)進(jìn)行連接。開(kāi)始時(shí)，該數(shù)據(jù)只會(huì)通過(guò)現(xiàn)有WIFI訪問(wèn)點(diǎn)傳輸。然而當(dāng)訪問(wèn)點(diǎn)脫離服務(wù)停機(jī)后，打印機(jī)數(shù)據(jù)就有可能會(huì)被大量丟失。Electric Imp系統(tǒng)不僅對(duì)數(shù)據(jù)進(jìn)行了緩存，同時(shí)也可以進(jìn)行該數(shù)據(jù)的安全轉(zhuǎn)移處理。這一連串的操作是依靠MQTT協(xié)議來(lái)實(shí)現(xiàn)的。<二>MQTT原理
MQTT的工作原理分為三個(gè)部分：發(fā)布主題、訂閱主題和消息傳遞。
1. 發(fā)布主題
發(fā)布主題的過(guò)程類似于將信息寫入發(fā)布源，并且給該信息分配一個(gè)可以接收該源消息的主題。這是MQTT協(xié)議用于區(qū)分信息的主要方式。例如，在以“廚房計(jì)劃投影儀”為主題的物聯(lián)網(wǎng)系統(tǒng)中，發(fā)布源是一個(gè)帶有投影儀設(shè)備的電視，該設(shè)備會(huì)發(fā)布該主題。
2. 訂閱主題
訂閱主題是指將一個(gè)已知的發(fā)布主題分配給一個(gè)接收消息的客戶端。MQTT協(xié)議的“訂閱”和“發(fā)布”實(shí)際上是一種點(diǎn)對(duì)點(diǎn)通信，并且訂閱主題的首要目的是將設(shè)備或客戶端與主題綁定，確保可以實(shí)時(shí)獲取消息。
3. 消息傳遞
消息傳遞是指引領(lǐng)訂閱和發(fā)布主題的基礎(chǔ)。當(dāng)發(fā)布主題提供信息時(shí)，相關(guān)訂閱用戶將能夠接收該信息。訂閱用戶還可以通過(guò)支持QoS的機(jī)制，確保主題在網(wǎng)絡(luò)中的可用性和可達(dá)性。<三>MQTT在PHP中的應(yīng)用
PHP有多種MQTT協(xié)議的庫(kù)，下面使用積木塊為例說(shuō)明如何在PHP應(yīng)用中實(shí)現(xiàn)MQTT協(xié)議使用。積木塊是國(guó)內(nèi)的一個(gè)在線工具，用戶可以通過(guò)搭建邏輯積木來(lái)設(shè)計(jì)所需的程序，可支持Java和MQTT等多種使用。
1. 庫(kù)中包含電子郵件weixin.php和mqtt.php文件，開(kāi)發(fā)者所需的地方將兩個(gè)文件都include進(jìn)來(lái)，使用方式便與平常的文件無(wú)異。
2. 在編碼的時(shí)候，需要根據(jù)具體的訂閱主題，編寫實(shí)現(xiàn)MQTT協(xié)議的PHP代碼。通過(guò)該代碼，PHP開(kāi)發(fā)者可以在任何設(shè)備上操作和調(diào)用設(shè)備和消息的相關(guān)信息。
具體代碼見(jiàn)下：
<?php inet stream_socket_client("localhost", "mqtt") $client_id="testphp"; $topics['foo'] = array("qos" =>0, "function" => "procmsg"); $mqtt = new Bluerhinos\phpMQTT("localhost", 1883, $client_id); if ($mqtt->connect(true,NULL,$username,$password)) { $mqtt->subscribe($topics); while($mqtt->proc()){ } $mqtt->close(); function procmsg($topic,$msg){ echo "Received: Topic: {$topic} Message: {$msg}\n
"; } } else { echo "Time out!\n"; } ?>