[威廉希尔官方网站 ]

【飞凌RK3568开发板试用体验】QT 移植mqtt + 收发测试

2022-12-7 21:25:58 1167 RK3568 飞凌嵌入式深度学习飞凌

MQTT协议是轻量、简单、开放和易于实现的，这些特点使它适用范围非常广泛。在很多情况下，包括受限的环境中，如：机器与机器（M2M）通信和物联网（IoT）。其在，通过卫星链路通信传感器、偶尔拨号的医疗设备、智能家居、及一些小型化设备中已广泛使用。找了很久资料，在arm中可以运行的QT比较少，结合在linux的上的一些例子，经过两天的调试，把整个QT mqtt调试出来了，这里记录下来，分享给有需要的人。

下载qmqtt源码

1、很多介绍去https://github.com/emqx/qmqtt下载，但是我就是打不开这个网址。后面找到其的地方下载了了源码
我这里把他上传上来：*附件：qmqtt-master.zip
2、把这个源代码下载到ubuntu虚拟机中（需要安装好飞凌源码编译的机子里）并解压出来：
目录如下：

├── CMakeLists.txt
├── edl-v10
├── epl-v10
├── examples
│   ├── examples.pro
│   ├── examples.qbs
│   └── qmqtt
│       ├── client
│       │   ├── client.pro
│       │   ├── client.qbs
│       │   └── example.cpp
│       ├── qmqtt.pro
│       └── qmqtt.qbs
├── LICENSE
├── qmqtt-API.md
├── qmqtt.pri
├── qmqtt.pro
├── qmqtt.qbs
├── README.md
├── src
│   ├── mqtt
│   │   ├── qmqtt_client.cpp
│   │   ├── qmqtt_client.h
│   │   ├── qmqtt_client_p.cpp
│   │   ├── qmqtt_client_p.h
│   │   ├── qmqtt_frame.cpp
│   │   ├── qmqtt_frame.h
│   │   ├── qmqtt_global.h
│   │   ├── qmqtt.h
│   │   ├── qmqtt_message.cpp
│   │   ├── qmqtt_message.h
│   │   ├── qmqtt_message_p.h
│   │   ├── qmqtt_network.cpp
│   │   ├── qmqtt_networkinterface.h
│   │   ├── qmqtt_network_p.h
│   │   ├── qmqtt.pri
│   │   ├── qmqtt.pro
│   │   ├── qmqtt.qbs
│   │   ├── qmqtt_routedmessage.h
│   │   ├── qmqtt_router.cpp
│   │   ├── qmqtt_router.h
│   │   ├── qmqtt_routesubscription.cpp
│   │   ├── qmqtt_routesubscription.h
│   │   ├── qmqtt_socket.cpp
│   │   ├── qmqtt_socketinterface.h
│   │   ├── qmqtt_socket_p.h
│   │   ├── qmqtt_ssl_socket.cpp
│   │   ├── qmqtt_ssl_socket_p.h
│   │   ├── qmqtt_timer.cpp
│   │   ├── qmqtt_timerinterface.h
│   │   ├── qmqtt_timer_p.h
│   │   ├── qmqtt_websocket.cpp
│   │   ├── qmqtt_websocketiodevice.cpp
│   │   ├── qmqtt_websocketiodevice_p.h
│   │   └── qmqtt_websocket_p.h
│   ├── src.pro
│   └── src.qbs
├── sync.profile

用原先安装的的QT打开目录下的qmqtt.pro工程

在打开的项目中，先右键qmakeSRC项目，再右键构建SRC项目

显示如下就是构建成功了：

创建lib文件夹

在其他的目录中创建lib文件夹用于存入编译出来的文件，以备后用。
编译好后，会在mqtt_build目录下生成一个build输出文件夹：

1、把lib下面生成的lib文件复制到新建的文件中。

2、然后把原来解压出来的目录里的mqtt文件夹里拷到与lib同目录里来备用：

这样源码编译到这里就结束了。

把lib下面的文件拷到开发板的/lib/下面：

要不估生成的代码到开发板下面运行时，会提示头文件找不到。

虚拟机创建QT项目：

新建项目大家可以自行去创建，这里不详细说。
1、添加好新建工程后把原来准备的lib、mqtt两个文件拷到项目目录里面：

2、在.pro文件里面右键，选择库：

3、选择外部库

找到lib下面的库

再选择头文件路径：

钩选linux然后下一步

点击完成，会自动添加代码：

到此QT项目创建就完成了，下面进行界面设计

界面

代码

mqtt_pro.pro:

#-------------------------------------------------
#
# Project created by QtCreator 2022-12-07T13:06:03
#
#-------------------------------------------------

QT       += core gui widgets network

TARGET = mqtt_pro
TEMPLATE = app

# The following define makes your compiler emit warnings if you use
# any feature of Qt which has been marked as deprecated (the exact warnings
# depend on your compiler). Please consult the documentation of the
# deprecated API in order to know how to port your code away from it.
DEFINES += QT_DEPRECATED_WARNINGS

# You can also make your code fail to compile if you use deprecated APIs.
# In order to do so, uncomment the following line.
# You can also select to disable deprecated APIs only up to a certain version of Qt.
#DEFINES += QT_DISABLE_DEPRECATED_BEFORE=0x060000    # disables all the APIs deprecated before Qt 6.0.0

CONFIG += c++11

SOURCES += \
        main.cpp \
        mainwindow.cpp

HEADERS += \
        mainwindow.h

FORMS += \
        mainwindow.ui

# Default rules for deployment.
qnx: target.path = /tmp/$${TARGET}/bin
else: unix:!android: target.path = /opt/$${TARGET}/bin
!isEmpty(target.path): INSTALLS += target

unix:!macx: LIBS += -L$$PWD/../test/mqtt_pro/lib/ -lQt5Qmqtt

INCLUDEPATH += $$PWD/../test/mqtt_pro/mqtt
DEPENDPATH += $$PWD/../test/mqtt_pro/mqtt

unix:!macx: LIBS += -L$$PWD/lib/ -lQt5Qmqtt

INCLUDEPATH += $$PWD/mqtt
DEPENDPATH += $$PWD/mqtt

mainwindow.h:

#ifndef MAINWINDOW_H
#define MAINWINDOW_H

#include <QMainWindow>
#include "qmqtt.h"

namespace Ui {
class MainWindow;
}

class MainWindow : public QMainWindow
{
    Q_OBJECT

public:
    explicit MainWindow(QWidget *parent = nullptr);
    ~MainWindow();



private slots:
    void on_connectBt_clicked();

    void on_pubBt_clicked();

    void mqtt_connect_success();

    void mqtt_disconnect();

    void mqtt_sub_success(QString topic, quint8 qos = 0);

    void mqtt_recv_msg(QMQTT::Message msg);


    void on_subBt_clicked();


private:
    Ui::MainWindow *ui;
    QMQTT::Client *mqtt;

};

#endif // MAINWINDOW_H

main.cpp:

#include "mainwindow.h"
#include <QApplication>

int main(int argc, char *argv[])
{
    QApplication a(argc, argv);
    MainWindow w;
    w.show();

    return a.exec();
}

mainwindow.cpp

#include "mainwindow.h"
#include "ui_mainwindow.h"
#include "qmqtt.h"


MainWindow::MainWindow(QWidget *parent) :
    QMainWindow(parent),
    ui(new Ui::MainWindow)
{
    ui->setupUi(this);
}

MainWindow::~MainWindow()
{
    delete ui;
}


void MainWindow::on_connectBt_clicked()
{
   mqtt = new QMQTT::Client(QHostAddress(QString(ui->hostLe->text())),ui->portLe->text().toInt());
        connect(mqtt, SIGNAL(connected()), this, SLOT(mqtt_connect_success()));
        connect(mqtt, SIGNAL(disconnected()), this, SLOT(mqtt_disconnect()));
        connect(mqtt, SIGNAL(subscribed(QString,quint8)), this, SLOT(mqtt_sub_success(QString,quint8)));
        connect(mqtt, SIGNAL(received(QMQTT::Message)), this, SLOT(mqtt_recv_msg(QMQTT::Message)));

        mqtt->setClientId("Qt-test0x10");
        mqtt->setUsername("admin1");
        mqtt->setPassword("public1");

        mqtt->setCleanSession(true);
        mqtt->connectToHost(); //连接mqtt
}


void MainWindow::mqtt_connect_success() //连接成功
{
    ui->textBrowser->append(QObject::tr("连接成功"));
}

void MainWindow::mqtt_disconnect() //连接断开
{
    ui->textBrowser->append("连接断开");
}

void MainWindow::mqtt_sub_success(QString topic,quint8 qos) //订阅成功
{
    QString msg = "订阅主题 ";
    msg += ui->subthemeLe->text();
    msg += " 成功";
    ui->textBrowser->append(msg);
}

void MainWindow::mqtt_recv_msg(QMQTT::Message msg) //接收消息处理
{
    QString recv_msg = "Topic:";
    QString data = msg.payload();
    recv_msg += msg.topic();
    recv_msg += "    Payload:";
    recv_msg += data;
    ui->textBrowser->append(recv_msg);
}


void MainWindow::on_pubBt_clicked()
{
    QMQTT::Message msg;
    msg.setTopic(ui->pubthemeLe->text());
    msg.setPayload(ui->pubMsgLe->text().toLocal8Bit());
    mqtt->publish(msg);
}

void MainWindow::on_subBt_clicked()
{
    mqtt->subscribe(ui->subthemeLe->text(),1);
}

mainwindow.ui:

<?xml version="1.0" encoding="UTF-8"?>
<ui version="4.0">
 <class>MainWindow</class>
 <widget class="QMainWindow" name="MainWindow">
  <property name="geometry">
   <rect>
    <x>0</x>
    <y>0</y>
    <width>1103</width>
    <height>822</height>
   </rect>
  </property>
  <property name="windowTitle">
   <string>飞凌OK3568MQTT</string>
  </property>
  <widget class="QWidget" name="centralWidget">
   <widget class="QLabel" name="label">
    <property name="geometry">
     <rect>
      <x>60</x>
      <y>70</y>
      <width>129</width>
      <height>34</height>
     </rect>
    </property>
    <property name="text">
     <string>主机：</string>
    </property>
   </widget>
   <widget class="QLabel" name="label_2">
    <property name="geometry">
     <rect>
      <x>490</x>
      <y>70</y>
      <width>129</width>
      <height>34</height>
     </rect>
    </property>
    <property name="text">
     <string>端口：</string>
    </property>
   </widget>
   <widget class="QLabel" name="label_3">
    <property name="geometry">
     <rect>
      <x>10</x>
      <y>150</y>
      <width>129</width>
      <height>34</height>
     </rect>
    </property>
    <property name="text">
     <string>发布主题：</string>
    </property>
   </widget>
   <widget class="QLabel" name="label_4">
    <property name="geometry">
     <rect>
      <x>440</x>
      <y>150</y>
      <width>129</width>
      <height>34</height>
     </rect>
    </property>
    <property name="text">
     <string>订阅主题：</string>
    </property>
   </widget>
   <widget class="QLineEdit" name="hostLe">
    <property name="geometry">
     <rect>
      <x>150</x>
      <y>60</y>
      <width>261</width>
      <height>42</height>
     </rect>
    </property>
    <property name="text">
     <string>192.168.3.192</string>
    </property>
   </widget>
   <widget class="QLineEdit" name="pubthemeLe">
    <property name="geometry">
     <rect>
      <x>150</x>
      <y>150</y>
      <width>261</width>
      <height>42</height>
     </rect>
    </property>
   </widget>
   <widget class="QLineEdit" name="portLe">
    <property name="geometry">
     <rect>
      <x>570</x>
      <y>60</y>
      <width>261</width>
      <height>42</height>
     </rect>
    </property>
    <property name="text">
     <string>1883</string>
    </property>
   </widget>
   <widget class="QLineEdit" name="subthemeLe">
    <property name="geometry">
     <rect>
      <x>570</x>
      <y>140</y>
      <width>261</width>
      <height>42</height>
     </rect>
    </property>
   </widget>
   <widget class="QTextBrowser" name="textBrowser">
    <property name="geometry">
     <rect>
      <x>70</x>
      <y>270</y>
      <width>941</width>
      <height>341</height>
     </rect>
    </property>
   </widget>
   <widget class="QPushButton" name="connectBt">
    <property name="geometry">
     <rect>
      <x>860</x>
      <y>50</y>
      <width>170</width>
      <height>48</height>
     </rect>
    </property>
    <property name="text">
     <string>连接</string>
    </property>
   </widget>
   <widget class="QPushButton" name="subBt">
    <property name="geometry">
     <rect>
      <x>860</x>
      <y>130</y>
      <width>170</width>
      <height>48</height>
     </rect>
    </property>
    <property name="text">
     <string>订阅</string>
    </property>
   </widget>
   <widget class="QPushButton" name="pubBt">
    <property name="geometry">
     <rect>
      <x>860</x>
      <y>210</y>
      <width>170</width>
      <height>48</height>
     </rect>
    </property>
    <property name="text">
     <string>发布</string>
    </property>
   </widget>
   <widget class="QLineEdit" name="pubMsgLe">
    <property name="geometry">
     <rect>
      <x>120</x>
      <y>210</y>
      <width>661</width>
      <height>42</height>
     </rect>
    </property>
   </widget>
   <widget class="QLabel" name="label_5">
    <property name="geometry">
     <rect>
      <x>290</x>
      <y>630</y>
      <width>451</width>
      <height>51</height>
     </rect>
    </property>
    <property name="text">
     <string>电子发烧友  OK3568试用</string>
    </property>
   </widget>
  </widget>
  <widget class="QMenuBar" name="menuBar">
   <property name="geometry">
    <rect>
     <x>0</x>
     <y>0</y>
     <width>1103</width>
     <height>48</height>
    </rect>
   </property>
  </widget>
  <widget class="QToolBar" name="mainToolBar">
   <attribute name="toolBarArea">
    <enum>TopToolBarArea</enum>
   </attribute>
   <attribute name="toolBarBreak">
    <bool>false</bool>
   </attribute>
  </widget>
  <widget class="QStatusBar" name="statusBar"/>
 </widget>
 <layoutdefault spacing="6" margin="11"/>
 <resources/>
 <connections/>
</ui>

编译

点击构建项目，就可以在目录下面生成mqtt_pro文件，把这个文件拷到开发板。

运行后显示界面如下：

#创建测试服务器：
1、下载emqtx服务器,或者用期的也可以创建mqtt服务端。
下载 EMQX下载后解压，执行./bin/emqx start就可以了。
打开127.0.0.1:18083(或者本机地址：18083就可以进入管理端，第一次进管理端用户名是admin 密码为：public。
2、查看接入情况：打开subscriptions菜单可以看到客户端接入情况：

3、按装一个MQTTx调试助手，建立一个连接：