123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263 |
- #ifndef MQTTBase_H
- #define MQTTBase_H
- #include <QObject>
- #include <QMap>
- #include "qmqtt.h"
- class MQTTBase : public QObject
- {
- Q_OBJECT
- public:
- MQTTBase(QObject* parent = nullptr);
-
- void setIPAndPort(const QString& IP, int port = 1883);
-
- void addSubcribe(const QString& topic,int qos = 0);
-
- void setAutoReconnect(bool isAuto = true);
-
- void connectToServer();
-
- void sendMessage(const QString& topic, const QByteArray& message, int qos = 0);
-
- signals:
-
- void signal_recvMessage(const QString& message);
- protected:
-
- virtual void recvMessage(const QMQTT::Message& message) = 0;
- protected slots:
- void do_connected();
- void do_disconnect();
- void do_error(const QMQTT::ClientError error);
- void do_subscribed(const QString& topic, const quint8 qos);
- void do_received(const QMQTT::Message& message);
- protected:
-
- bool m_isConnected = false;
- QString m_mqttIP;
- int m_mqttPort;
- QMap<QString, int> m_mapTopic;
- QMQTT::Client m_client;
- };
- #endif
|