PHP和MQTT：构建基于物联网的智能能源管理系统

$ pecl install Mosquitto-alpha

<?php

$mqtt = new MosquittoClient();
$mqtt->connect('mqtt.example.com', 1883, 60);

// 订阅主题
$mqtt->subscribe('energy/usage', 0);

// 处理收到的消息
$mqtt->onMessage(function ($msg) {
    // 消息处理逻辑
    echo $msg->topic . ' => ' . $msg->payload . PHP_EOL;
});

// 循环处理消息
while (true) {
    $mqtt->loop();
}

// 断开连接
$mqtt->disconnect();

<?php

// 发布能源数据
function publish($topic, $message) {
    global $mqtt;
    
    $mqtt->publish($topic, $message, 0, false);
}

// 订阅能源数据
function subscribe($topic) {
    global $mqtt;
    
    $mqtt->subscribe($topic, 0);
}

// 处理收到的能源数据
$mqtt->onMessage(function ($msg) {
    $topic = $msg->topic;
    $data = json_decode($msg->payload, true);
    
    // 处理能源数据逻辑
    switch ($topic) {
        case 'energy/usage':
            // 处理能源使用数据
            break;
        case 'energy/control':
            // 处理控制指令
            break;
    }
});

// 连接MQTT代理服务器
$mqtt = new MosquittoClient();
$mqtt->connect('mqtt.example.com', 1883, 60);

// 订阅能源数据
subscribe('energy/usage');

// 发布能源数据
publish('energy/usage', '{"value": 100}');

// 循环处理消息
while (true) {
    $mqtt->loop();
}

// 断开连接
$mqtt->disconnect();