Qt - QMQTT订阅者和发布者

2021-07-05 11:02:34 阅读：229 来源： 互联网

标签：Publisher Qt QMQTT Subscriber connect 发布者 include public

简介

使用Qt官方提供的QMQTT源代码编译为QMQTT模块，来编写简单的订阅者和发布者。

订阅者

 1 #ifndef SUBSCRIBER_H
 2 #define SUBSCRIBER_H
 3 
 4 #include <QObject>
 5 
 6 #include <QDebug>
 7 #include <qmqtt.h>
 8 #include <QTimer>
 9 
10 
11 //订阅
12 class Subscriber : public QMQTT::Client {
13     Q_OBJECT
14   public:
15     explicit Subscriber(const QHostAddress& host,
16                         const quint16 port,
17                         QObject* parent = NULL)
18         : QMQTT::Client(host, port, parent)
19         , _qout(stdout) {
20         connect(this, &Subscriber::connected, this, &Subscriber::onConnected);
21         connect(this, &Subscriber::subscribed, this, &Subscriber::onSubscribed);
22         connect(this, &Subscriber::received, this, &Subscriber::onReceived);
23     }
24     virtual ~Subscriber() {}
25 
26     QTextStream _qout;
27 
28   public slots:
29     void onConnected() {
30         qDebug() << "connected" << endl;
31         subscribe("qmqtt/exampletopic", 0);
32     }
33 
34     void onSubscribed(const QString& topic) {
35         qDebug() << "subscribed " << topic << endl;
36     }
37 
38     void onReceived(const QMQTT::Message& message) {
39         qDebug() << "publish received: \""
40                  << QString::fromUtf8(message.payload())
41                  << "\"" << endl;
42     }
43 };
44 
45 
46 #endif // SUBSCRIBER_H

发布者

 1 #ifndef PUBLISHER_H
 2 #define PUBLISHER_H
 3 
 4 #include <QObject>
 5 
 6 #include <QDebug>
 7 #include <qmqtt.h>
 8 #include <QTimer>
 9 
10 //发布
11 class Publisher : public QMQTT::Client {
12     Q_OBJECT
13   public:
14     explicit Publisher(const QHostAddress& host,
15                        const quint16 port,
16                        QObject* parent = NULL)
17         : QMQTT::Client(host, port, parent), _number(0) {
18 
19         connect(this, &Publisher::connected, this, &Publisher::onConnected);
20         connect(&_timer, &QTimer::timeout, this, &Publisher::onTimeout);
21         connect(this, &Publisher::disconnected, this, &Publisher::onDisconnected);
22     }
23     virtual ~Publisher() {}
24 
25     QTimer _timer;
26     quint16 _number;
27 
28   public slots:
29     void onConnected() {
30         subscribe("qmqtt/exampletopic", 0);
31         _timer.start(1000);
32     }
33 
34     void onTimeout() {
35         QMQTT::Message message(_number, "qmqtt/exampletopic",
36                                QString("Number is %1").arg(_number).toUtf8());
37         publish(message);
38         _number++;
39 //        if(_number >= 10) {
40 //            _timer.stop();
41 //            disconnectFromHost();
42 //        }
43     }
44 
45     void onDisconnected() {}
46 };
47 
48 #endif // PUBLISHER_H

标签：Publisher,Qt,QMQTT,Subscriber,connect,发布者,include,public
来源： https://www.cnblogs.com/citrus/p/14971440.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

Qt - QMQTT订阅者和发布者