Compare commits
3 Commits
CigaretteS
...
main
| Author | SHA1 | Date |
|---|---|---|
 Jinhuan
|
a8d4a359c4 | 7 months ago |
|
Jinhuan
|
c10ad02d1a | 7 months ago |
|
Jinhuan
|
cc8ce53abc | 1 year ago |
@ -0,0 +1,68 @@
|
|||||||
|
{
|
||||||
|
"files.associations": {
|
||||||
|
"string": "cpp",
|
||||||
|
"array": "cpp",
|
||||||
|
"atomic": "cpp",
|
||||||
|
"bit": "cpp",
|
||||||
|
"*.tcc": "cpp",
|
||||||
|
"cctype": "cpp",
|
||||||
|
"chrono": "cpp",
|
||||||
|
"clocale": "cpp",
|
||||||
|
"cmath": "cpp",
|
||||||
|
"compare": "cpp",
|
||||||
|
"complex": "cpp",
|
||||||
|
"concepts": "cpp",
|
||||||
|
"condition_variable": "cpp",
|
||||||
|
"cstdarg": "cpp",
|
||||||
|
"cstddef": "cpp",
|
||||||
|
"cstdint": "cpp",
|
||||||
|
"cstdio": "cpp",
|
||||||
|
"cstdlib": "cpp",
|
||||||
|
"cstring": "cpp",
|
||||||
|
"ctime": "cpp",
|
||||||
|
"cwchar": "cpp",
|
||||||
|
"cwctype": "cpp",
|
||||||
|
"deque": "cpp",
|
||||||
|
"list": "cpp",
|
||||||
|
"map": "cpp",
|
||||||
|
"set": "cpp",
|
||||||
|
"unordered_map": "cpp",
|
||||||
|
"unordered_set": "cpp",
|
||||||
|
"vector": "cpp",
|
||||||
|
"exception": "cpp",
|
||||||
|
"algorithm": "cpp",
|
||||||
|
"functional": "cpp",
|
||||||
|
"iterator": "cpp",
|
||||||
|
"memory": "cpp",
|
||||||
|
"memory_resource": "cpp",
|
||||||
|
"numeric": "cpp",
|
||||||
|
"random": "cpp",
|
||||||
|
"ratio": "cpp",
|
||||||
|
"string_view": "cpp",
|
||||||
|
"system_error": "cpp",
|
||||||
|
"tuple": "cpp",
|
||||||
|
"type_traits": "cpp",
|
||||||
|
"utility": "cpp",
|
||||||
|
"fstream": "cpp",
|
||||||
|
"future": "cpp",
|
||||||
|
"initializer_list": "cpp",
|
||||||
|
"iomanip": "cpp",
|
||||||
|
"iosfwd": "cpp",
|
||||||
|
"iostream": "cpp",
|
||||||
|
"istream": "cpp",
|
||||||
|
"limits": "cpp",
|
||||||
|
"mutex": "cpp",
|
||||||
|
"new": "cpp",
|
||||||
|
"numbers": "cpp",
|
||||||
|
"ostream": "cpp",
|
||||||
|
"semaphore": "cpp",
|
||||||
|
"sstream": "cpp",
|
||||||
|
"stdexcept": "cpp",
|
||||||
|
"stop_token": "cpp",
|
||||||
|
"streambuf": "cpp",
|
||||||
|
"thread": "cpp",
|
||||||
|
"cinttypes": "cpp",
|
||||||
|
"typeindex": "cpp",
|
||||||
|
"typeinfo": "cpp"
|
||||||
|
}
|
||||||
|
}
|
||||||
@ -0,0 +1,5 @@
|
|||||||
|
/* This file was generated by qmake with the info from <root>/src/mqtt/mqtt.pro. */
|
||||||
|
#ifdef __cplusplus /* create empty PCH in C mode */
|
||||||
|
#include <QtCore/QtCore>
|
||||||
|
#include <QtNetwork/QtNetwork>
|
||||||
|
#endif
|
||||||
Binary file not shown.
Binary file not shown.
File diff suppressed because one or more lines are too long
File diff suppressed because it is too large
Load Diff
@ -0,0 +1,97 @@
|
|||||||
|
#include "threadSendMqtt.h"
|
||||||
|
#include <WinSock2.h>
|
||||||
|
#include <WS2tcpip.h>
|
||||||
|
#include <stdio.h>
|
||||||
|
#include <qtcpsocket.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();
|
||||||
|
delete m_client;
|
||||||
|
}
|
||||||
|
|
||||||
|
bool threadSendMqtt::connectTCP() {
|
||||||
|
|
||||||
|
m_client = new QMqttClient(this);
|
||||||
|
m_client->setHostname(ip);
|
||||||
|
m_client->setPort(port);
|
||||||
|
//m_client->setUsername(userName);
|
||||||
|
//m_client->setPassword(userPassword);
|
||||||
|
m_client->connectToHost();
|
||||||
|
//connect(m_client, &QMqttClient::stateChanged, this, &MainWindow::updateLogStateChange);
|
||||||
|
|
||||||
|
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, SIGNAL(messageSent(qint32)), this, SLOT(MQTT_DATASEND_SUCCESS(qint32)));//消息发送成功提示的槽函数绑定
|
||||||
|
|
||||||
|
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);
|
||||||
|
});
|
||||||
|
|
||||||
|
//connect(ui->lineEditHost, &QLineEdit::textChanged, m_client, &QMqttClient::setHostname);
|
||||||
|
//connect(ui->spinBoxPort, QOverload<int>::of(&QSpinBox::valueChanged), this, &MainWindow::setClientPort);
|
||||||
|
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
|
||||||
|
void threadSendMqtt::run()
|
||||||
|
{
|
||||||
|
if (!connectTCP())
|
||||||
|
qDebug() << "Mqtt connect error!";
|
||||||
|
|
||||||
|
while (isLoop) {
|
||||||
|
_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);
|
||||||
|
}
|
||||||
|
}
|
||||||
@ -0,0 +1,56 @@
|
|||||||
|
#pragma once
|
||||||
|
#include <QDebug>
|
||||||
|
#include <QDateTime>
|
||||||
|
#include <iostream>
|
||||||
|
#include <QThread>
|
||||||
|
#include <QtMqtt/qmqttclient.h>
|
||||||
|
#include "common.h"
|
||||||
|
#include "SyncQueue.h"
|
||||||
|
|
||||||
|
class _MqttSendInfo
|
||||||
|
{
|
||||||
|
public:
|
||||||
|
int MsgID;
|
||||||
|
QString timecost;
|
||||||
|
|
||||||
|
_MqttSendInfo()
|
||||||
|
{
|
||||||
|
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
class threadSendMqtt : public QThread {
|
||||||
|
public:
|
||||||
|
QString ip;
|
||||||
|
int port;
|
||||||
|
int num = 0;
|
||||||
|
|
||||||
|
threadSendMqtt(QObject* o = nullptr) :QThread(o)
|
||||||
|
{
|
||||||
|
isLoop = true;
|
||||||
|
}
|
||||||
|
|
||||||
|
~threadSendMqtt()
|
||||||
|
{
|
||||||
|
stop();
|
||||||
|
_MqttSendInfo TCPSendInfo;
|
||||||
|
Local_MQTT_Info_queue->put(TCPSendInfo);
|
||||||
|
quit();
|
||||||
|
wait();
|
||||||
|
}
|
||||||
|
void stop();
|
||||||
|
bool connectTCP();
|
||||||
|
|
||||||
|
protected:
|
||||||
|
void run();
|
||||||
|
|
||||||
|
public:
|
||||||
|
void init(SyncQueue<_MqttSendInfo>* p_MQTT_Info_queue, std::string ip_, int port_);
|
||||||
|
void start_work();
|
||||||
|
void sendData(_MqttSendInfo* TCPSendInfo, int Num);
|
||||||
|
|
||||||
|
public:
|
||||||
|
SyncQueue<_MqttSendInfo>* Local_MQTT_Info_queue;
|
||||||
|
std::atomic_bool isLoop = { 0 };
|
||||||
|
QMqttClient* m_client = NULL;
|
||||||
|
};
|
||||||
Loading…
Reference in New Issue