安装MQTT客户端库
使用Composer安装MQTT客户端库,可以通过以下命令进行安装:
composer require php-mqtt/client
连接MQTT服务器
在PHP文件中,使用以下代码连接到MQTT服务器:
use PhpMqttClientMqttClient;
$mqtt = new MqttClient('mqtt://localhost:1883');
$mqtt->connect();
需要将'localhost'替换为MQTT服务器的IP地址,'1883'为MQTT服务器默认端口号。
发布消息
使用以下代码发布消息到指定的MQTT主题:
$topic = '/devices/device1/temperature';
$payload = '25°C';
$qosLevel = 0; // 可选,默认为0
$mqtt->publish($topic, $payload, $qosLevel);
可以根据实际需求修改$topic和$payload的值。
订阅消息
使用以下代码订阅指定的MQTT主题:
$topic = '/devices/device1/temperature';
$qosLevel = 0; // 可选,默认为0
$mqtt->subscribe($topic, function ($topic, $message) {
// 在此处处理接收到的消息
}, $qosLevel);
可以在回调函数中处理接收到的消息,如将消息存储到数据库中或实时呈现到前端界面上。