首頁 > 文章 > 後端開發 > MQTT在PHP開發的消息訂閱與發布實戰

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

WBOY原創: 2023-07-08 14:02:512381瀏覽

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>温度监控</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中文網其他相關文章！

php composer 物联网嵌入式系统传感器

陳述：

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

上一篇：小程式開發中的PHP介面安全與防護技巧下一篇：小程式開發中的PHP介面安全與防護技巧

看更多