qt的mqtt代码编写

以下是一个简单的 Qt 的 MQTT 客户端的例子：

首先，需要在项目中添加一个 MQTT 库，比如 Eclipse Paho MQTT C++ Library。

然后，在代码中包含 MQTT 头文件：

#include <mqtt/async_client.h>

接下来，在需要连接 MQTT 服务器的地方创建一个 MQTT 客户端对象：

mqtt::async_client client("tcp://localhost:1883", "qt-mqtt-client");

其中，第一个参数是 MQTT 服务器的地址和端口号，第二个参数是客户端的 ID。

然后，可以设置连接选项```cpp
mqtt::connect_options conn_opts;
conn_opts.set_keep_alive_interval(10);
conn_opts.set_clean_session(true);

这里设置了 keep-alive 时间为 10 秒，并且使用了 clean session。

接下来，连接到 MQTT 服务器：

mqtt::token_ptr conntok = client.connect(conn_opts);
conntok->wait();

如果连接成功，就可以订阅某个主题：

mqtt::token_ptr subtok = client.subscribe("test/topic", 0);
subtok->wait();

其中，第一个参数是要订阅的主题，第二个参数是 QoS 等级。

然后，可以发送消息到某个主题：

std::string payload = "Hello, MQTT!";
mqtt::message_ptr pubmsg = mqtt::make_message("test/topic", payload);
pubmsg->set_qos(0);
client.publish(pubmsg)->wait();

其中，第一个参数是要发布消息的主题，第二个参数是消息内容，第三个参数是 QoS 等级。

最后，断开连接：

mqtt::token_ptr disconn_tok = client.disconnect();
disconn_tok->wait();

完整代码如下：

#include <mqtt/async_client.h>

int main(int argc, char *argv[])
{
QCoreApplication a(argc, argv);

mqtt::async_client client("tcp://localhost:1883", "qt-mqtt-client");

mqtt::connect_options conn_opts;
conn_opts.set_keep_alive_interval(10);
conn_opts.set_clean_session(true);

mqtt::token_ptr conntok = client.connect(conn_opts);
conntok->wait();

mqtt::token_ptr subtok = client.subscribe("test/topic", 0);
subtok->wait();

std::string payload = "Hello, MQTT!";
mqtt::message_ptr pubmsg = mqtt::make_message("test/topic", payload);
pubmsg->set_qos(0);
client.publish(pubmsg)->wait();

mqtt::token_ptr disconn_tok = client.disconnect();
disconn_tok->wait();

return a.exec();
}

需要注意的是，这里使用了阻塞式 API，实际应用中应该使用异步 API。同时，还需要处理 MQTT 客户端的回调函数，比如连接成功、收到消息等事件。