<?php

namespace Home\Controller;

use Think\Controller;
use PhpMqtt\Client\MqttClient;
use PhpMqtt\Client\Exceptions\MqttClientException;
use PhpMqtt\Client\ConnectionSettings;

class IndexController extends Controller
{
    public function index()
    {
        //$this->display();
        $server   = 'www.szdot.top'; // MQTT 代理地址
        $port     = 1883;                    // MQTT 代理端口
        $clientId = 'php-mqtt-client';       // 客户端 ID
        $username = 'admin';                 // 用户名（如果需要）
        $password = '123456';                // 密码（如果需要）

        try {
            // 创建连接设置对象
            $settings = (new ConnectionSettings)
                ->setUsername($username)
                ->setPassword($password);

            // 实例化 MQTT 客户端
            $mqtt = new MqttClient($server, $port, $clientId);

            // 连接到 MQTT 代理
            $mqtt->connect($settings);

            // 检查是否连接成功
            if ($mqtt->isConnected()) {
                echo "Connected to MQTT broker successfully\n";

                // 发布消息到指定的主题
                $mqtt->publish('demo', 'Hello MQTT', 0);

                echo "Message published successfully\n";

                // 断开连接
                $mqtt->disconnect();
                echo "Disconnected from MQTT broker\n";
            } else {
                echo "Could not connect to MQTT broker\n";
            }
        } catch (MqttClientException $e) {
            echo "Could not connect to MQTT broker: " . $e->getMessage();
        }
    }
}