PHP 및 MQTT: 원격 에너지 모니터링 및 관리 시스템 구축-PHP 튜토리얼-php.cn

PHP 및 MQTT: 원격 에너지 모니터링 및 관리 시스템 구축

WBOY

풀어 주다： 2023-07-08 14:06:01

원래의

1586명이 탐색했습니다.

PHP 및 MQTT: 원격 에너지 모니터링 및 관리 시스템 구축

소개
에너지 수요 증가와 환경 인식 제고로 인해 원격 에너지 모니터링 및 관리 시스템 구축이 점점 더 중요해지고 있습니다. 이러한 시스템은 에너지 사용량을 실시간으로 모니터링하여 에너지 절약 관리를 할 수 있고, 원격제어를 통해 에너지 사용량을 조절할 수 있어 에너지 낭비와 탄소발자국을 줄일 수 있습니다. 이 기사에서는 PHP 및 MQTT 프로토콜을 사용하여 원격 에너지 모니터링 및 관리 시스템을 구축하는 방법을 살펴보고 참조할 수 있는 몇 가지 코드 예제를 제공합니다.

MQTT 소개
MQTT(Message Queuing Telemetry Transport)는 네트워크 대역폭과 컴퓨팅 리소스가 제한된 장치에 적합한 경량 게시/구독 메시지 전송 프로토콜입니다. 통신에 TCP/IP 프로토콜을 사용하고 푸시 모드를 지원하며 대기 시간이 짧고 안정성이 높습니다.
MQTT 서버 구축
먼저, 기기와 애플리케이션 간의 통신을 처리하기 위해 MQTT 서버를 구축해야 합니다. 이는 Mosquitto와 같은 오픈 소스 MQTT 서버를 사용하여 달성할 수 있습니다. 다음은 기본적인 Mosquitto 서버 구성 예입니다.

sudo apt-get install mosquitto
sudo systemctl enable mosquitto
sudo systemctl start mosquitto

로그인 후 복사

PHP MQTT 확장
PHP에서 MQTT 프로토콜을 사용하려면 MQTT 확장을 설치해야 합니다. mosquitto 또는 phpMQTT 확장 프로그램을 사용하도록 선택할 수 있습니다. 다음은 phpMQTT 확장을 사용하는 샘플 코드입니다. mosquitto或者phpMQTT扩展。下面是使用phpMQTT扩展的示例代码。

require("phpMQTT.php");

$server = "mqtt.example.com";
$port = 1883;
$client_id = "phpMQTT-subscriber";

$mqtt = new phpMQTT($server, $port, $client_id);

if ($mqtt->connect(true, NULL, "username", "password")) {
    $topics = array("energy/usage/#" => array("qos" => 0, "function" => "processMessage"));
    $mqtt->subscribe($topics, 0);
    while ($mqtt->proc()) {
    }
    $mqtt->close();
} else {
    echo "Failed to connect to MQTT server.";
}

function processMessage($topic, $message) {
    echo "Received message on topic: $topic
";
    echo "Message: $message
";
    // 在这里可以编写处理MQTT消息的代码逻辑
}

로그인 후 복사

在上面的示例中，我们首先创建了一个phpMQTT对象并连接到MQTT服务器。然后，我们订阅了一个或多个主题，并定义了一个用于处理消息的回调函数processMessage。通过调用proc方法，我们可以持续接收和处理来自MQTT服务器的消息。

设备端
在远程能源监控与管理系统中，设备端是指能源使用设备，例如传感器、智能电表等。设备端需要实时发送能源使用数据到MQTT服务器，并接收来自服务器的控制指令。

require("phpMQTT.php");

$server = "mqtt.example.com";
$port = 1883;
$client_id = "phpMQTT-publisher";
$topic = "energy/usage";

$mqtt = new phpMQTT($server, $port, $client_id);

if ($mqtt->connect(true, NULL, "username", "password")) {
    $usage_data = "100"; // 从能源使用设备中获取实时能源使用数据
    $mqtt->publish($topic, $usage_data, 0);
    $mqtt->close();
} else {
    echo "Failed to connect to MQTT server.";
}

로그인 후 복사

在上面的示例中，我们创建了一个phpMQTT对象并连接到MQTT服务器。然后，我们使用publish方法将实时能源使用数据发送到主题energy/usage。

Web应用程序
Web应用程序是远程能源监控与管理系统的核心。它可以通过订阅MQTT服务器上的主题来实时接收能源使用数据，并通过发布主题来发送控制指令。

require("phpMQTT.php");

$server = "mqtt.example.com";
$port = 1883;
$client_id = "phpMQTT-subscriber";
$topic = "energy/usage";

$mqtt = new phpMQTT($server, $port, $client_id);

if ($mqtt->connect(true, NULL, "username", "password")) {
    $mqtt->subscribe(array($topic => array("qos" => 0, "function" => "processMessage")), 0);
    while ($mqtt->proc()) {
        // 处理其他业务逻辑
    }
    $mqtt->close();
} else {
    echo "Failed to connect to MQTT server.";
}

function processMessage($topic, $message) {
    echo "Received message on topic: $topic
";
    echo "Message: $message
";
    // 在这里可以编写处理MQTT消息的代码逻辑
}

로그인 후 복사

在上面的示例中，我们创建了一个phpMQTT对象并连接到MQTT服务器。然后，我们订阅了主题energy/usage并定义了一个用于处理消息的回调函数processMessage。通过调用proc

rrreee

위의 예에서는 먼저 phpMQTT 객체를 생성하고 MQTT 서버에 연결했습니다. 그런 다음 하나 이상의 주제를 구독하고 메시지 처리를 위한 콜백 함수 processMessage를 정의합니다. proc 메서드를 호출하면 MQTT 서버에서 계속해서 메시지를 수신하고 처리할 수 있습니다.

원격 에너지 모니터링 및 관리 시스템에서 장비측은 센서, 스마트 미터 등 에너지 사용 장비를 말합니다. 장치는 MQTT 서버에 에너지 사용량 데이터를 실시간으로 전송하고 서버로부터 제어 명령을 받아야 합니다.