php mqtt

<?php

// 引入MQTT客户端库，这里假设使用的是PHP MQTT Client库
require 'vendor/autoload.php';

use PhpMqtt\Client\MqttClient;
use PhpMqtt\Client\ConnectionSettings;

// 创建MQTT客户端实例
$mqtt = new MqttClient('mqtt.example.com', 1883, 'unique-client-id');

// 设置连接参数
$connectionSettings = (new ConnectionSettings)
    ->setUsername('your-username')
    ->setPassword('your-password');

// 连接到MQTT服务器
$mqtt->connect($connectionSettings, true);

// 订阅一个主题
$mqtt->subscribe('test/topic', function ($topic, $message) {
    echo sprintf("Received message on topic [%s]: %s\n", $topic, $message);
}, QOS_LEVEL_1);

// 发布一条消息到指定主题
$mqtt->publish('test/topic', 'Hello, MQTT!', QOS_LEVEL_1);

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

?>

解释说明：

1. 引入库：首先需要引入PHP MQTT客户端库，这里假设使用的是PhpMqtt\Client库。
2. 创建客户端实例：通过MqttClient类创建一个新的MQTT客户端实例，并指定MQTT服务器的地址、端口和客户端ID。
3. 设置连接参数：使用ConnectionSettings类设置连接所需的用户名和密码。
4. 连接到服务器：调用connect方法连接到MQTT服务器。
5. 订阅主题：使用subscribe方法订阅一个主题，并定义当收到消息时的回调函数。
6. 发布消息：使用publish方法向指定的主题发布一条消息。
7. 断开连接：完成操作后，调用disconnect方法断开与MQTT服务器的连接。

如果你没有安装PhpMqtt\Client库，可以通过Composer安装：

composer require php-mqtt/client