p 如果你要開發一個實時的 IoT 應用程序，那么你一定需要一個 MQTT（Message Queuing Telemetry Transport）代理服務器來處理消息通信。而 EMQ X 則是目前市場上最知名的 MQTT 代理服務器之一。再加上 PHP 是最流行的 Web 開發語言，那么使用 EMQ X 結合 PHP 開發 IoT 應用則會變得非常簡單。在本文中，我們將介紹如何使用 PHP 連接、發布和訂閱 EMQ X 代理服務器。 p 首先，我們需要安裝 EMQ X ，并且啟動 EMQ X Web 界面來檢查是否都已正確安裝。其中，EMQ X 的 Web 界面使我們可以方便地在 Web 上管理 EMQ X 代理服務器。 pre # 安裝 EMQ X brew install emqx # 訪問 EMQ X Web 界面 http://localhost:18083/ p 第二步，我們將使用 PHP 連接 EMQ X 代理服務器。EMQ X 支持 MQTT 3.1.1 和 5.0 協議。在這里，我們將使用 MQTT PHP 客戶端庫 Mosquitto PHP 擴展來連接 EMQ X 代理服務器。Mosquitto PHP 擴展是一個基于 libmosquitto MQTT 庫的 PHP 連接器。 pre # 安裝 Mosquitto PHP 擴展 sudo pecl install Mosquitto-alpha p 連接 EMQ X 代理服務器的 PHP 示例代碼如下所示。 preclient = new Mosquitto\Client($client_id, $clean_session); $this->client->onConnect([$this, 'onConnect']); $this->client->onDisconnect([$this, 'onDisconnect']); } public function onConnect($code, $message) { echo("Connected: $code $message\n"); } public function onDisconnect() { echo("Disconnected\n"); } public function publish($topic, $message, $qos = 0, $retain = false) { $this->client->publish($topic, $message, $qos, $retain); } public function subscribe($topic, $qos = 0) { $this->client->subscribe($topic, $qos); } public function loop() { $this->client->loop(); } public function connect() { $this->client->connect(MQTT_SERVER_HOST, MQTT_SERVER_PORT); } } // 使用 Mosquitto PHP 連接 EMQ X 代理服務器 $client = new MQTTClient('php-client', true); $client->connect(); p 在以上示例代碼中，$client = new MQTTClient('php-client', true); 創建了一個新的 Mosquitto PHP 對象，‘php-client’ 為客戶端 ID。定義了 onConnect 和 onDisconnect 兩個方法，在連接和斷開連接時被調用。最后，connect() 方法建立了一個到 EMQ X 代理服務器的連接。 p 現在，我們已經成功地連接了 EMQ X 代理服務器。接下來，讓我們來看一下如何在 PHP 中發布和訂閱 MQTT 主題。 p 發布 MQTT 主題時，我們需要指定要發布的主題、消息內容、QoS 和保留標志。以下代碼展示了如何使用 publish() 方法來發布主題。 pre // 發布主題 $client->publish('test', 'Hello, world!'); p 訂閱 MQTT 主題時，我們則需要指定需要訂閱的主題、QoS 和回調函數。以下代碼展示了如何使用 subscribe() 方法來訂閱 MQTT 主題。 pre // 訂閱主題 $client->subscribe('test', 0); $client->client->onMessage(function ($message) { echo("Topic: $message->topic\n"); echo("Message: $message->payload\n"); }); p 在以上代碼中，subscribe() 方法用于訂閱主題并指定了回調函數 onMessage。當有消息到達主題 test 時，onMessage 函數將被調用，從而輸出該消息的內容和對應的主題名稱。 p 最后的總結是，EMQ X 是一個強大的 MQTT 代理服務器，可以處理大量的 IoT 設備消息。而 PHP 則是一個非常流行的 Web 開發語言，如今已經廣泛應用于企業應用程序中。通過使用 EMQ X 和 PHP 開發 IoT 應用程序，我們可以處理數以百萬計的 IoT 設備的消息通信。希望這篇文章幫助你在使用 PHP 和 EMQ X 開發 IoT 應用程序時加快速度和效率。