You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
100 lines
3.1 KiB
C++
100 lines
3.1 KiB
C++
#include "threadSendMqtt.h"
|
|
|
|
#ifdef __MQTTSend
|
|
#include <stdio.h>
|
|
// 相关头文件
|
|
#include <QFile> // 文件操作
|
|
#include <QJsonObject> // JSON对象
|
|
#include <QJsonArray> // JSON数组
|
|
#include <QJsonDocument> // JSON文档
|
|
#include <QJsonParseError> // JSON异常捕捉
|
|
|
|
void threadSendMqtt::init(SyncQueue<_MqttSendInfo>* p_MQTT_Info_queue, std::string ip_, int port_) {
|
|
ip = QString::fromStdString(ip_);
|
|
port = port_;
|
|
qDebug() << "Mqtt ip:" << ip << "| Mqtt port:" << port;
|
|
Local_MQTT_Info_queue = p_MQTT_Info_queue;
|
|
}
|
|
void threadSendMqtt::start_work()
|
|
{
|
|
//start(HighestPriority);
|
|
start();
|
|
}
|
|
|
|
void threadSendMqtt::stop()
|
|
{
|
|
isLoop = false;
|
|
wait();
|
|
}
|
|
|
|
bool threadSendMqtt::connectMqtt() {
|
|
connect(&m_client, &QMqttClient::connected, this, [this](void) {
|
|
qDebug() << "Mqtt connected";
|
|
});
|
|
connect(&m_client, &QMqttClient::disconnected, this, [this](void) {
|
|
qDebug() << "Mqtt disconnected";
|
|
});
|
|
connect(&m_client, &QMqttClient::errorChanged, this, [this](QMqttClient::ClientError error) {
|
|
qDebug() << error;
|
|
});
|
|
connect(&m_client, &QMqttClient::messageReceived, this, [this](const QByteArray &message, const QMqttTopicName &topic) {
|
|
const QString content = QDateTime::currentDateTime().toString()
|
|
+ QLatin1String(" Received Topic: ")
|
|
+ topic.name()
|
|
+ QLatin1String(" Message: ")
|
|
+ message
|
|
+ QLatin1Char('\n');
|
|
//ui->editLog->insertPlainText(content);
|
|
});
|
|
connect(&m_client, &QMqttClient::pingResponseReceived, this, [this]() {
|
|
const QString content = QDateTime::currentDateTime().toString()
|
|
+ QLatin1String(" PingResponse")
|
|
+ QLatin1Char('\n');
|
|
//ui->editLog->insertPlainText(content);
|
|
});
|
|
qDebug() << m_client.state();
|
|
if (m_client.state() == QMqttClient::Disconnected)
|
|
{
|
|
m_client.setHostname("192.168.3.6");
|
|
m_client.setClientId("123");
|
|
m_client.setPort(1883);
|
|
//m_client.setUsername(userName);
|
|
//m_client.setPassword(userPassword);
|
|
m_client.connectToHost();
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
void threadSendMqtt::run()
|
|
{
|
|
qDebug() << m_client.state();
|
|
if (!connectMqtt())
|
|
qDebug() << "Mqtt connect error!";
|
|
|
|
while (isLoop) {
|
|
qDebug() << m_client.error();
|
|
qDebug() << m_client.state();
|
|
std::this_thread::sleep_for(std::chrono::milliseconds(1000));
|
|
/*_MqttSendInfo TCPSendInfo;
|
|
Local_MQTT_Info_queue->take(TCPSendInfo);
|
|
num++;
|
|
sendData(&TCPSendInfo, num);*/
|
|
}
|
|
}
|
|
|
|
void threadSendMqtt::sendData(_MqttSendInfo* TCPSendInfo, int Num) {
|
|
QJsonObject addressObject;
|
|
// 方式二：赋值
|
|
addressObject["street"] = "123 Main St.";
|
|
addressObject["city"] = "Anytown";
|
|
addressObject["country"] = "USA";
|
|
|
|
|
|
if (m_client.state() == QMqttClient::Connected) {
|
|
QJsonDocument jsonDoc(addressObject);
|
|
QByteArray jsonBytes = jsonDoc.toJson();
|
|
auto result = m_client.publish(QMqttTopicName("topic"), jsonBytes, 0, true);
|
|
}
|
|
}
|
|
#endif |