<?php
/**
 * MQTT 客户端 - PHP
 * 需要安装 phpMQTT 库: https://github.com/bluerhinos/phpMQTT
 */

require('phpMQTT.php');

// MQTT 配置
$server = 'broker.emqx.io';
$port = 1883;
$client_id = 'mqtt_client_69d7daa9aa86b';
$username = '';
$password = '';
$topic = 'test/topic';
$message = 'Hello MQTT!';
$qos = 0;

// 创建 MQTT 客户端
$mqtt = new Bluerhinos\phpMQTT($server, $port, $client_id);

// 连接到 MQTT 服务器
if ($mqtt->connect(true, NULL, $username, $password)) {
    echo "已连接到 MQTT 服务器\n";

    // 发布消息
    $mqtt->publish($topic, $message, $qos);
    echo "消息已发布: $message\n";

    // 订阅主题
    $mqtt->subscribe($topic, $qos);
    echo "已订阅主题: $topic\n";

    // 接收消息
    $mqtt->proc();

    // 断开连接
    $mqtt->close();
    echo "已断开连接\n";
} else {
    echo "连接失败！\n";
}
?>