PHP 및 MQTT를 사용한 실시간 데이터 모니터링 및 시각화 모범 사례

PHP 및 MQTT를 사용한 실시간 데이터 모니터링 및 시각화 모범 사례

요약:
이 문서에서는 PHP 및 MQTT 프로토콜을 사용하여 실시간 데이터 모니터링 및 시각화를 구현하는 방법을 소개합니다. 메시징에는 MQTT를 사용하고 메시지를 처리하고 데이터를 렌더링하려면 PHP를 사용합니다. 이 글의 가이드를 통해 간단한 실시간 데이터 모니터링 시스템을 구축하는 방법과 데이터를 시각적으로 표시하는 방법을 배우게 됩니다.

소개:
인터넷의 대중화로 인해 우리는 다양한 센서와 장치를 통해 대량의 실시간 데이터를 얻을 수 있습니다. 데이터를 더 잘 이해하고 의사결정을 내릴 수 있도록 이러한 데이터를 모니터링하고 시각화하는 방법이 중요한 문제가 되었습니다. 이 기사에서는 PHP 및 MQTT를 사용한 실시간 데이터 모니터링 및 시각화에 대한 모범 사례에 중점을 둘 것입니다.

1. MQTT 프로토콜이란 무엇입니까?
MQTT(Message Queuing Telemetry Transport)는 가볍고 개방적이며 구현하기 쉬운 메시징 프로토콜입니다. 네트워크 간 전송, 낮은 대역폭 및 불안정한 네트워크 환경에 적합하며 IoT 시나리오에 매우 적합합니다. MQTT는 게시-구독 모델을 사용하여 메시지를 전달하는데, 이는 리소스 소비가 적고 대기 시간이 짧은 특성을 갖습니다.

2. MQTT 서버 구축
MQTT 프로토콜을 사용하기 전에 MQTT 서버를 구축해야 합니다. Mosquitto, EMQ X 등과 같이 선택할 수 있는 오픈 소스 MQTT 서버가 많이 있습니다. 여기서는 모기를 예로 들어 소개하겠습니다.

먼저 Mosquitto 서버를 설치하세요. 명령줄이나 그래픽 인터페이스를 통해 설치할 수 있으며 구체적인 방법은 Mosquitto 공식 문서를 참조하세요. 설치가 완료되면 Mosquitto 서버를 시작합니다.

3. PHP를 사용하여 MQTT 서버에 연결
PHP에서 MQTT 프로토콜을 사용하려면 PHP의 MQTT 클라이언트 라이브러리를 사용해야 합니다. 여기서는 phpmqtt/phpmqtt 라이브러리를 사용합니다. Composer를 통해 이 라이브러리를 설치할 수 있습니다.

composer require phpmqtt/phpmqtt

설치가 완료된 후 다음 코드를 통해 MQTT 서버의 주제에 연결하고 구독할 수 있습니다.

<?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);
}

코드에서 먼저 MqttClient 객체를 생성한 다음 Mosquitto 서버에 연결하려면 연결 방법을 사용하십시오. 다음으로, subscribe 메소드를 사용하여 주제를 구독합니다. 메시지를 수신하는 콜백 함수에서는 수신된 메시지를 처리할 수 있습니다. 마지막으로 루프에서 루프 메서드를 호출하여 MQTT 메시지를 계속 수신합니다.

4. 데이터 시각화
MQTT 서버에 성공적으로 연결하고 관련 주제를 구독하면 데이터 시각화를 시작할 수 있습니다. 여기서는 Chart.js 라이브러리를 사용하여 차트를 렌더링합니다.

먼저 Chart.js 라이브러리 파일을 소개합니다.

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

그런 다음 HTML에서 캔버스 요소를 만들어 차트를 표시합니다.

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

다음으로 다음 코드를 사용하여 데이터를 가져오고 차트를 표시할 수 있습니다.

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();
});

위 코드에서는 먼저 Chart 객체를 생성하고 차트 유형을 꺾은선형 차트로 설정했습니다. 그런 다음 수신된 데이터를 저장하기 위해 dataArr 배열을 정의합니다. 메시지 콜백 함수에서는 수신된 데이터를 dataArr 배열에 추가하고 차트 데이터를 업데이트합니다. 마지막으로 update 메소드를 호출하여 차트 표시를 업데이트합니다.

결론:
이 기사를 통해 우리는 PHP 및 MQTT 프로토콜을 사용하여 실시간 데이터 모니터링 및 시각화를 달성하는 방법에 대한 모범 사례를 소개했습니다. MQTT 서버를 구축하고, PHP 라이브러리를 사용하여 서버에 연결하고 주제를 구독하고, Chart.js 라이브러리를 사용하여 차트를 그리는 방식으로 간단한 실시간 데이터 모니터링 시스템을 빠르게 구축하고 데이터를 시각적으로 표시할 수 있습니다. 본 글이 실시간 데이터 모니터링 및 시각화 개발에 도움이 되기를 바랍니다.

위 내용은 PHP 및 MQTT를 사용한 실시간 데이터 모니터링 및 시각화 모범 사례의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!