1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
#include "qmqtt.h"//没有引入第三方库是不能使用的
#include "QHostAddress"
#include "QMessageBox"
QMQTT::Client *client;//定义结构体指针
client = new QMQTT::Client(QHostAddress::LocalHost,1883);
client->setHostName("iot-060a06sa.mqtt.iothub.aliyuncs.com");
client->setPort(1883);
client->setUsername("DeviceName&ProductKey");
client->setPassword("password");
//由于我使用的是华东2 也就是地区是上海 若是与我不一致的地区需要修改signmethod
client->setClientId("Clientld|securemode=2,signmethod=hmacsha1|");//未填写timestamp
/*client->setClientId("Clientld|securemode=2,signmethod=hmacsha1,timestamp=数值|");//填写timestamp*/
client->connectToHost();
//订阅
// /a1W0uRZgqlY/Appx/user/get
client->subscribe("/ProductKey/DeviceName/user/get");
connect(client,&QMQTT::Client::received,this,&MainWindow::mqttSetData);
void MainWindow::mqttSetData(QMQTT::Message mess){
qDebug()<<"::"<<mess.payload();
}
void MainWindow::sendTopic(QString data){
//调用此函数可以发送数据到云端
client->publish(QMQTT::Message(0,"/ProductKey/DeviceName/user/update",data.toLocal8Bit()));
}