PhpMQTTClient: 使用PHP轻松连接MQTT服务器

<?php
require('phpMQTT.php');
 
$server = 'broker.hivemq.com';    // MQTT服务器的地址
$port = 1883;                     // MQTT服务器端口
$username = '';                   // MQTT用户名（如果需要）
$password = '';                   // MQTT密码（如果需要）
$client_id = 'phpMQTT-publisher';  // 客户端ID，应该是唯一的
$topic = 'test_topic';             // 发布消息的主题
 
$mqtt = new phpMQTT($server, $port, $client_id);
 
if ($mqtt->connect(true, NULL, $username, $password)) {
    $mqtt->publish($topic, 'Hello MQTT', 0, false); // 发布消息
    $mqtt->close(); // 关闭连接
    echo "Message published successfully\n";
} else {
    echo "Could not connect to MQTT server\n";
}
?>

这段代码展示了如何使用phpMQTTClient库连接到一个MQTT服务器，并发布一条消息到指定的主题。首先，需要引入phpMQTT.php文件，然后设置服务器地址和端口，接着创建一个phpMQTT实例并尝试连接。如果连接成功，它将发布一条消息，然后关闭连接。如果连接失败，它会输出错误信息。这是一个简单的例子，展示了如何在PHP中使用MQTT协议。