PHP 및 MQTT: 원격 센서 데이터의 실시간 모니터링
소개:
사물 인터넷의 급속한 발전으로 원격 센서를 통해 장비와 환경을 모니터링하고 제어할 수 있습니다. MQTT(Message Queuing Telemetry Transport)는 IoT 애플리케이션에서 센서 데이터를 전송하는 데 널리 사용되는 경량 메시지 전송 프로토콜입니다. 이 기사에서는 PHP와 MQTT를 사용하여 원격 센서 데이터의 실시간 모니터링을 구현하는 방법을 소개합니다.
phpMQTT 라이브러리 설치:
composer require bluerhinos/phpmqtt
MQTT 서버에 연결하기 위한 샘플 코드는 다음과 같습니다.
<?php require("phpMQTT.php"); $mqtt = new phpMQTT("mqtt.example.com", 1883, "ClientID"); if(!$mqtt->connect()){ exit(1); } // MQTT订阅主题 $topics['sensors/data'] = array("qos" => 0, "function" => "handleSensorData"); $mqtt->subscribe($topics, 0); while($mqtt->proc()){ } $mqtt->close(); function handleSensorData($topic, $message){ echo "Received message: $message from topic: $topic "; } ?>
위 샘플 코드에서는 먼저 require 문을 통해 phpMQTT 라이브러리를 소개합니다. 그런 다음 mqtt 객체를 생성하고 mqtt 서버의 주소(mqtt.example.com)와 포트 번호(1883)를 사용하여 연결합니다. 연결이 성공하면 하나 이상의 주제를 구독할 수 있습니다. 이 예에서는 "sensors/data"라는 주제를 구독하고 수신된 데이터를 처리하기 위한 콜백 함수 handlerSensorData를 지정합니다. 마지막으로, 루프에서 데이터를 읽어 실시간 모니터링이 이루어지며, 새로운 센서 데이터가 수신되면 처리를 위해 handlerSensorData 함수가 호출됩니다.
센서 데이터 게시:
다음으로 센서를 시뮬레이션하고 센서 데이터를 PHP를 통해 MQTT 서버에 게시하겠습니다. 간단한 예제 코드는 다음과 같습니다.
<?php require("phpMQTT.php"); $mqtt = new phpMQTT("mqtt.example.com", 1883, "ClientID"); if(!$mqtt->connect()){ exit(1); } // MQTT发布主题 $topic = "sensors/data"; $message = "Sensor data: " . rand(1, 100); $mqtt->publish($topic, $message, 0); $mqtt->close(); ?>
위 코드에서는 mqtt 객체를 생성하고 mqtt 서버의 주소(mqtt.example.com)와 포트 번호(1883)를 사용하여 연결합니다. 그런 다음 게시할 주제 이름(센서/데이터)과 센서 데이터를 지정했습니다. 마지막으로 mqtt 객체의 게시 메서드를 호출하여 센서 데이터가 MQTT 서버에 게시됩니다.
그러나 이는 단지 예일 뿐이며 실제 애플리케이션에는 더 많은 논리와 처리가 필요합니다. 이 기사가 독자들에게 IoT 애플리케이션에서 PHP와 MQTT의 잠재력을 더 자세히 탐구할 수 있는 기본 아이디어와 코드 예제를 제공할 수 있기를 바랍니다.
참조:
위 내용은 PHP 및 MQTT: 원격 센서 데이터의 실시간 모니터링의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!