Best practices for real-time data monitoring and visualization using PHP and MQTT

Best practices for real-time data monitoring and visualization using PHP and MQTT

Abstract:
This article will introduce how to use PHP and MQTT protocols to implement real-time data monitoring and visualization. We will use MQTT for messaging and PHP to handle messages and render data. Through the guide in this article, you will learn how to build a simple real-time data monitoring system and how to display the data visually.

Introduction:
With the popularization of the Internet, we can obtain a large amount of real-time data through various sensors and devices. How to monitor and visualize these data so that we can better understand the data and make decisions has become a key issue. This article will focus on best practices for real-time data monitoring and visualization using PHP and MQTT.

1. What is the MQTT protocol?
MQTT (Message Queuing Telemetry Transport) is a lightweight, open, and easy-to-implement messaging protocol. It is suitable for transmission across networks, low bandwidth and unstable network environments, and is very suitable for IoT scenarios. MQTT uses a publish-subscribe model to deliver messages, which has the characteristics of low resource consumption and low latency.

2. Build MQTT server
Before using the MQTT protocol, we need to build an MQTT server. There are many open source MQTT servers to choose from, such as Mosquitto, EMQ X, etc. Here we take Mosquitto as an example to introduce.

First, install the Mosquitto server. You can install it through the command line or graphical interface. For specific methods, please refer to Mosquitto's official documentation. After the installation is complete, start the Mosquitto server.

3. Use PHP to connect to the MQTT server
To use the MQTT protocol in PHP, we need to use PHP's MQTT client library. Here we use the phpmqtt/phpmqtt library. You can install this library through Composer:

composer require phpmqtt/phpmqtt

After the installation is complete, we can connect and subscribe to the topic of the MQTT server through the following code:

<?php
require("vendor/autoload.php");

use PhpMqttClientMqttClient;

$client = new MqttClient("mqtt://localhost:1883");
$client->connect();

$client->subscribe("topic_name", function (string $topic, string $message){
    // 处理接收到的消息
    // 在这里可以对接收到的消息进行处理，如存储到数据库等
});

while (true) {
    $client->loop(true);
}

In the code, we first create an MqttClient object , and then use the connect method to connect to the Mosquitto server. Next, we subscribe to a topic using the subscribe method. In the callback function that receives the message, we can process the received message. Finally, continue to listen to MQTT messages by calling the loop method in a loop.

4. Data Visualization
Once we successfully connect to the MQTT server and subscribe to the relevant topics, we can start visualizing the data. Here we use Chart.js library to render charts.

First, introduce the Chart.js library file:

<script src="https://cdn.jsdelivr.net/npm/chart.js"></script>

Then, create a canvas element in HTML to display the chart:

<canvas id="myChart" width="400" height="400"></canvas>

Next, we can Use the following code to obtain data and present the chart:

var ctx = document.getElementById('myChart').getContext('2d');
var myChart = new Chart(ctx, {
    type: 'line',
    data: {
        labels: [], // x轴上的标签
        datasets: [{
            label: '实时数据', // 数据集的标签
            data: [], // 数据值
            fill: false, // 是否填充
            borderColor: 'rgb(75, 192, 192)',
            tension: 0.1 // 曲线的张力
        }]
    },
    options: {
        responsive: true,
        animation: false,
        scales: {
            x: {
                display: true
                // 其他相关配置
            },
            y: {
                display: true
                // 其他相关配置
            }
        }
    }
});

// 定义一个数组，用于存储接收到的数据
var dataArr = [];

// 在消息回调函数中更新图表数据
client.subscribe("topic_name", function (topic, message) {
    var data = parseFloat(message);
    dataArr.push(data.toFixed(2));
    if (dataArr.length > 10) {
        dataArr.shift();
    }

    // 更新图表数据
    myChart.data.labels = Array.from({length: dataArr.length}, (_, i) => i + 1);
    myChart.data.datasets[0].data = dataArr;
    myChart.update();
});

In the above code, we first create a Chart object and set the type of chart to a line chart. Then, we define an array dataArr to store the received data. In the message callback function, we add the received data to the dataArr array and update the chart data. Finally, we update the display of the chart by calling the update method.

Conclusion:
Through this article, we introduced the best practices on how to use PHP and MQTT protocols to achieve real-time data monitoring and visualization. By building an MQTT server, using the PHP library to connect to the server and subscribe to topics, and using the Chart.js library to draw charts, we can quickly build a simple real-time data monitoring system and display the data visually. I hope this article will be helpful for the development of real-time data monitoring and visualization.

The above is the detailed content of Best practices for real-time data monitoring and visualization using PHP and MQTT. For more information, please follow other related articles on the PHP Chinese website!