MQTT在PHP開發的消息訂閱與發布實戰-php教程-PHP中文網

首頁

後端開發

php教程

MQTT在PHP開發的消息訂閱與發布實戰

WBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWB

Jul 08, 2023 pm 02:02 PM

mqtt訊息發布訊息訂閱

MQTT在PHP開發中的消息訂閱與發布實戰

引言：
隨著物聯網的發展，訊息佇列遙測傳輸協定（MQTT）在感測器設備和後端應用之間的通信中起著重要的作用。作為一種輕量級的協議，MQTT具有低能耗、高可靠性和可擴展性的特性。在PHP開發中，利用MQTT實現訊息的訂閱和發布，可以方便地與感測器設備進行通信，並將資料傳輸到後端應用程式中進行處理和展示。本文將介紹MQTT在PHP開發的實戰應用，並提供相關的程式碼範例。

一、MQTT簡介：
MQTT是一種基於發布/訂閱模式的訊息佇列傳輸協定。它採用輕量級的二進位訊息格式，適用於各種硬體設備，如感測器和嵌入式系統。 MQTT協議中主要包含兩個角色：訊息發布者和訊息訂閱者。發布者將訊息發佈到一個特定的主題上，而訂閱者則對感興趣的主題進行訂閱，從而接收相關的訊息。 MQTT協定也支援訊息的QoS（Quality of Service）等級設置，從而確保資料的可靠性。

二、安裝MQTT伺服器：
在開始進行PHP開發中的MQTT實戰前，我們需要先搭建一個MQTT伺服器。以下是搭建MQTT伺服器的簡要步驟：

下載並安裝MQTT伺服器，如Mosquitto。
運行MQTT伺服器，預設監聽連接埠為1883。

三、PHP中使用MQTT：
在PHP中使用MQTT進行訊息訂閱和發布的過程如下：

##引入MQTT客戶端程式庫：
首先需要引進MQTT客戶端函式庫，PHP常用的MQTT客戶端函式庫有phpMQTT和mosquitto-php等。本文以phpMQTT為例，可以透過composer進行安裝：
```
composer require bluerhinos/phpmqttclient
```

MQTT客戶端設定：

在PHP程式碼中進行MQTT操作之前，需要先進行連線配置，包括伺服器位址、連接埠號碼、QoS等級等。以下是一個範例的配置：

$mqttServer = 'localhost'; // MQTT服务器地址
$mqttPort = 1883; // MQTT服务器端口
$mqttClientId = 'php_script'; // 客户端ID
$mqttUsername = ''; //用户名
$mqttPassword = ''; // 密码

MQTT訊息的訂閱：

在PHP中訂閱一個主題，可以使用
subscribe方法。以下是一個範例：

require('phpMQTT.php');
$mqtt = new phpMQTT($mqttServer, $mqttPort, $mqttClientId);
if($mqtt->connect(true, NULL, $mqttUsername, $mqttPassword)) {
  $topics['topic_name'] = array('qos' => 0, 'function' => 'dataCallback');
  $mqtt->subscribe($topics, 0);
  while($mqtt->proc()){
  }
  $mqtt->close();
} else {
  echo "连接MQTT服务器失败！";
  exit(1);
}
function dataCallback($topic, $payload) {
  echo "收到消息：$payload";
}

MQTT訊息的發布：

在PHP中發布一個訊息，可以使用
publish方法。以下是一個範例：

require('phpMQTT.php');
$mqtt = new phpMQTT($mqttServer, $mqttPort, $mqttClientId);
if($mqtt->connect(true, NULL, $mqttUsername, $mqttPassword)) {
  $mqtt->publish('topic_name', '消息内容', 0);
  $mqtt->close();
} else {
  echo "连接MQTT服务器失败！";
  exit(1);
}

四、實戰應用程式：

以下以一個簡單的實景應用程式為例，示範在PHP中使用MQTT進行訊息訂閱與發布的實際應用。

假設我們有一個溫度感測器設備，其將即時溫度透過MQTT協定發佈到主題為
temperature的頻道上。我們的PHP應用程式需要即時接收並處理該溫度數據，為此，我們將訂閱該主題，並透過Web介面展示即時溫度。
訂閱溫度資料並顯示在Web介面上：

require('phpMQTT.php');

$mqttServer = 'localhost'; // MQTT服务器地址
$mqttPort = 1883; // MQTT服务器端口
$mqttClientId = 'php_script'; // 客户端ID

$mqtt = new phpMQTT($mqttServer, $mqttPort, $mqttClientId);

if($mqtt->connect(true, NULL, NULL, NULL)) {
    $topics['temperature'] = array('qos' => 0, 'function' => 'temperatureCallback');
    $mqtt->subscribe($topics, 0);

    echo "开始订阅温度数据...
";

    while($mqtt->proc()){
    }

    $mqtt->close();
} else {
    echo "连接MQTT服务器失败！";
    exit(1);
}

function temperatureCallback($topic, $payload) {
    echo "收到温度消息：$payload
";
    // 在这里进行温度数据的处理，如存储到数据库或展示在Web界面上
}

透過Web介面即時展示溫度數據的範例程式碼如下：

<!DOCTYPE html>
<html>
<head>
    <title>温度监控</title>
</head>
<body>
    <h1 id="温度监控">温度监控</h1>
    <div id="temperature"></div>

    <script src="https://code.jquery.com/jquery-3.6.0.min.js"></script>
    <script>
        $(document).ready(function() {
            var mqttServer = 'mqtt://localhost:1883';
            var clientId = 'web_client';
            var temperatureTopic = 'temperature';

            var client = mqtt.connect(mqttServer, { clientId: clientId });

            client.on('connect', function() {
                client.subscribe(temperatureTopic);
            });

            client.on('message', function(topic, message) {
                if (topic === temperatureTopic) {
                    var temperature = message.toString();
                    $('#temperature').text('当前温度：' + temperature + '℃');
                }
            });
        });
    </script>
</body>
</html>

以上範例程式碼示範了在PHP中使用MQTT進行訊息訂閱和發布的實戰應用程式。透過訂閱溫度數據，我們可以即時接收溫度數據並進行處理和展示，而透過發布訊息，我們可以向感測器設備發送控制指令。在實際開發中，可以根據具體需求擴展和調整程式碼。

結論：

本文介紹了MQTT在PHP開發中的訊息訂閱與發布實戰，並提供了相關的程式碼範例。透過使用MQTT協議，PHP應用可以方便地與感測器設備進行通信，並實現即時數據的傳輸和處理。在物聯網應用開發中，利用MQTT進行訊息傳遞可以提高通訊效率和可靠性，為應用開發帶來便利。

以上是MQTT在PHP開發的消息訂閱與發布實戰的詳細內容。更多資訊請關注PHP中文網其他相關文章！

陳述

本文內容由網友自願投稿，版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容，請聯絡admin@php.cn

超越炒作：評估當今PHP的角色Apr 12, 2025 am 12:17 AM

PHP在現代編程中仍然是一個強大且廣泛使用的工具，尤其在web開發領域。 1)PHP易用且與數據庫集成無縫，是許多開發者的首選。 2)它支持動態內容生成和麵向對象編程，適合快速創建和維護網站。 3)PHP的性能可以通過緩存和優化數據庫查詢來提升，其廣泛的社區和豐富生態系統使其在當今技術棧中仍具重要地位。

PHP中的弱參考是什麼？什麼時候有用？Apr 12, 2025 am 12:13 AM

在PHP中，弱引用是通過WeakReference類實現的，不會阻止垃圾回收器回收對象。弱引用適用於緩存系統和事件監聽器等場景，需注意其不能保證對象存活，且垃圾回收可能延遲。

解釋PHP中的__ Invoke Magic方法。Apr 12, 2025 am 12:07 AM

\_\_invoke方法允許對象像函數一樣被調用。 1.定義\_\_invoke方法使對象可被調用。 2.使用$obj(...)語法時，PHP會執行\_\_invoke方法。 3.適用於日誌記錄和計算器等場景，提高代碼靈活性和可讀性。

解釋PHP 8.1中的纖維以進行並發。Apr 12, 2025 am 12:05 AM

Fibers在PHP8.1中引入，提升了並發處理能力。 1)Fibers是一種輕量級的並發模型，類似於協程。 2)它們允許開發者手動控制任務的執行流，適合處理I/O密集型任務。 3)使用Fibers可以編寫更高效、響應性更強的代碼。

PHP社區：資源，支持和發展Apr 12, 2025 am 12:04 AM

PHP社區提供了豐富的資源和支持，幫助開發者成長。 1)資源包括官方文檔、教程、博客和開源項目如Laravel和Symfony。 2)支持可以通過StackOverflow、Reddit和Slack頻道獲得。 3)開發動態可以通過關注RFC了解。 4)融入社區可以通過積極參與、貢獻代碼和學習分享來實現。