如何在PHP中實現MQTT協議通信：完整指南與代碼示例

M66 2025-07-27

引言

隨著物聯網技術的不斷發展，MQTT（Message Queue Telemetry Transport）協議作為一種輕量級的通信協議，廣泛應用於低帶寬和不穩定網絡環境中。本文將為您詳細介紹如何在PHP中實現MQTT協議的通信功能，並提供相關的代碼示例，幫助您快速搭建物聯網應用。

安裝MQTT庫

首先，我們需要安裝一個支持MQTT協議的PHP庫。本文選用的是"phpMQTT" 庫，它是一個非常適合與MQTT服務器進行通信的工具。

可以通過Composer命令行工具來安裝該庫。在終端中運行以下命令：

 <span class="fun">composer require bluerhinos/phpmqttclient</span>

連接與發布消息

接下來，我們來看一下如何連接MQTT服務器並發布消息。以下是一個簡單的代碼示例，展示瞭如何通過PHP客戶端連接MQTT服務器並發送消息。

 require("phpMQTT.php");

$server = "mqtt.example.com";  // MQTT服務器地址
$port = 1883;  // MQTT服務器端口
$username = "your_username";  // 使用者名稱
$password = "your_password";  // 密碼
$client_id = "client_id";  // 客戶端ID
$topic = "your_topic";  // 發布主題
$message = "Hello, MQTT!";  // 消息內容

$mqtt = new phpMQTT($server, $port, $client_id);

if($mqtt->connect(true, NULL, $username, $password)) {
    $mqtt->publish($topic, $message, 0);
    $mqtt->close();
} else {
    echo "連接失敗!";
}

訂閱消息

除了發布消息，我們還可以通過PHP客戶端訂閱MQTT服務器上的主題，並接收相應的消息。以下示例展示瞭如何訂閱一個主題並處理接收到的消息。

 require("phpMQTT.php");

$server = "mqtt.example.com";  // MQTT服務器地址
$port = 1883;  // MQTT服務器端口
$username = "your_username";  // 使用者名稱
$password = "your_password";  // 密碼
$client_id = "client_id";  // 客戶端ID
$topic = "your_topic";  // 訂閱主題

$mqtt = new phpMQTT($server, $port, $client_id);

if($mqtt->connect(true, NULL, $username, $password)) {
    $mqtt->subscribe($topic, 0);
    while($mqtt->proc()) {
        // 處理接收到的消息
    }
    $mqtt->close();
} else {
    echo "連接失敗!";
}

處理接收到的消息

在上面的代碼中，我們使用了一個回調函數來處理訂閱到的消息。以下是一個簡單的函數示例，用於處理並輸出接收到的消息。

 function processMessage($topic, $message) {
    echo "接收到的消息: " . $message . "\n";
}

require("phpMQTT.php");

$server = "mqtt.example.com";  // MQTT服務器地址
$port = 1883;  // MQTT服務器端口
$username = "your_username";  // 使用者名稱
$password = "your_password";  // 密碼
$client_id = "client_id";  // 客戶端ID
$topic = "your_topic";  // 訂閱主題

$mqtt = new phpMQTT($server, $port, $client_id);
$mqtt->onMessage = "processMessage";  // 設置回調函數

if($mqtt->connect(true, NULL, $username, $password)) {
    $mqtt->subscribe($topic, 0);
    while($mqtt->proc()) { }
    $mqtt->close();
} else {
    echo "連接失敗!";
}

總結

本文通過實際的代碼示例，展示瞭如何在PHP中使用"phpMQTT"庫實現MQTT協議通信功能。您可以根據這些示例，快速搭建自己的物聯網應用，進行數據傳輸和消息管理。希望本文能幫助您更好地理解和應用MQTT協議。