1.Windows下QT编译和使用MQTT
2.统信UOS系统开发笔记（八）：在统信UOS上编译搭建mqtt基础环境(版本使用QMQTT::Clinet)
3.EMQX-简介、源码安装部署、安装基础功能、源码python代码测试
4.windows下paho.mqtt安装教程（C/C++）
5.浅谈mqtt源码（二）Client详解
6.5-Openwrt MQTT client使用

Windows下QT编译和使用MQTT

       前言：本文将介绍在Windows环境下使用QT进行MQTT服务器的安装连接。相较于其他库，源码QT自身并不提供MQTT库，安装Android源码编译root因此需要从其官方网站下载并自行编译MQTT源码。源码

       一.源码下载

       前往QT的安装源码地址，切换分支下载适用于当前QT版本的源码MQTT源码。

       二.源码编译

       2. 编译目录配置

       首先，安装找出自己的源码QT安装目录中的编译器路径，并将其填入配置文件中。安装具体步骤包括找到编译器路径和填入路径。源码

       3. 编译QtMQTT准备

       将`src/mqtt`（例如：`qtmqtt-5../src/mqtt`）目录下的安装所有头文件复制到QT安装目录中的`QT/Qt5_/5../mingw_/include/QtMqtt`。若不存在`QtMqtt`文件夹，源码则需自行创建。

       4.点击构建

       三.测试使用QtMQTT

       3. 运行程序

       确保正确配置后，执行程序进行测试。注意，可能需要对`#include`进行修改，将原始路径改为适用于当前环境的路径。

       关注我，后台私信：MQTT测试账号

       相关文章链接：开发路上坑多，关注我，陪你一起填坑！喜欢本文章，记得点赞，收藏哦！

       后续还会分享MQTT的使用案例，包括在QT上的应用以及在微信小程序上的使用，欢迎与我交流。

统信UOS系统开发笔记（八）：在统信UOS上编译搭建mqtt基础环境(版本使用QMQTT::Clinet)

       MQTT协议介绍

       MQTT（Message Queuing Telemetry Transport，消息队列遥测传输协议）是基于发布/订阅模式的轻量级通讯协议，由IBM于年发布。其最大优点在于，能以极少的代码和有限的带宽，为连接远程设备提供实时可靠的消息服务。MQTT广泛应用于物联网、小型设备、移动应用等领域。

       MQTT设计原则

       MQTT具有以下特点：

       1. 使用发布/订阅模式，实现一对多的消息发布，解除应用程序耦合。

       2. 提供对负载内容的屏蔽，进行消息传输。

       3. 使用TCP/IP提供网络连接。日付源码

       4. 支持三种消息发布服务质量。

       5. 具有小型传输、开销小的特性，协议交换最小化。

       6. 为客户端异常中断提供机制。

       发布/订阅者模式

       MQTT支持发布/订阅模式，使MQTT协议在物联网、机器与机器（M2M）通信、智能家居等领域得到广泛应用。

       统信UOS系统MQTT编译与环境搭建

       统信UOS系统版本：系统版本为统信UOS 。

       Qt编译MQTT

       Qt5版本开始支持MQTT，但并未集成至安装包，需自行下载编译。Qt提供的qtmqtt库不支持点对点方式，仅支持订阅/发布者模式。

       编译步骤

       下载并解压MQTT源码至目标系统。

       使用QtQCreator打开pro工程编译，切换至release模式。

       在解压的源码路径手动创建Qt5Mqtt文件，编译成功。

       部署MQTT模块至qt

       将MQTT源码融入qt工程中，实现模块化部署。新建mqttClientDemo工程，提取源码中的mqtt模块，将其加入新工程的modules，引入qmqtt.pri文件。

       解决编译报错

       编译报错时，添加缺失的网络模块（QT += network），并调整私有头文件宏至头文件宏。

       源码融入编译成功

       源码成功融入，后续无需重新编译即可替换系统或版本。

       模块化部署优化

       创建mqttClientManager管理模块，用于包含MQTT源码，实现模块化部署。

EMQX-简介、安装部署、基础功能、python代码测试

       MQTT属于是物联网的通信协议，在MQTT协议中有两大角色：客户端（发布者/订阅者），服务端（Mqtt broker）；针对客户端和服务端需要有遵循该协议的的具体实现，EMQ/EMQX就是MQTT Broker的一种实现。

       EMQX是基于 Erlang/OTP 平台开发的 MQTT 消息服务器，是开源社区中最流行的 MQTT 消息服务器。EMQ X 是开源百万级分布式 MQTT 消息服务器（MQTT Messaging Broker），用于支持各种接入标准 MQTT协议的远程下载源码设备，实现从设备端到服务器端的消息传递，以及从服务器端到设备端的设备控制消息转发。从而实现物联网设备的数据采集，和对设备的操作和控制。

       到目前为止，比较流行的 MQTT Broker 有几个：使用 C 语言实现的 MQTT Broker，使用 Erlang 语言开发的 MQTT Broker，使用 Node.JS 开发的 MQTT Broker，同样使用 Erlang 开发的 MQTT Broker。从支持 MQTT5.0、稳定性、扩展性、集群能力等方面考虑，EMQX 的表现应该是最好的。

       与别的MQTT服务器相比EMQ X 主要有以下的特点：经过+版本的迭代，EMQ X 目前为开源社区中最流行的 MQTT 消息中间件，在各种客户严格的生产环境上经受了严苛的考验；支持丰富的物联网协议，包括 MQTT、MQTT-SN、CoAP、 LwM2M、LoRaWAN 和 WebSocket等；优化的架构设计，支持超大规模的设备连接。企业版单机能支持百万的 MQTT 连接；集群能支持千万级别的 MQTT 连接；易于安装和使用；灵活的扩展性，支持企业的一些定制场景；中国本地的技术支持服务，通过微信、QQ等线上渠道快速响应客户需求；基于 Apache 2.0 协议许可，完全开源。EMQ X 的代码都放在 Github 中，用户可以查看所有源代码；EMQ X 3.0 支持 MQTT 5.0 协议，是开源社区中第一个支持 5.0协议规范的消息服务器，并且完全兼容 MQTT V3.1 和 V3.1.1 协议。除了 MQTT 协议之外，EMQ X 还支持别的一些物联网协议；单机支持百万连接，集群支持千万级连接；毫秒级消息转发。EMQ X 中应用了多种技术以实现上述功能；利用 Erlang/OTP 平台的软实时、高并发和容错（电信领域久经考验的语言）；全异步架构；连接、会话、路由、集群的分层设计；消息平面和控制平面的分离等；扩展模块和插件，EMQ X 提供了灵活的扩展机制，可以实现私有协议、认证鉴权、数据持久化、桥接发和管理控制台等的手机sns 源码扩展；桥接：EMQ X 可以跟别的消息系统进行对接，比如 EMQ X Enterprise 版本中可以支持将消息转发到 Kafka、RabbitMQ 或者别的 EMQ 节点等；共享订阅：共享订阅支持通过负载均衡的方式在多个订阅者之间来分发 MQTT 消息。比如针对物联网等 数据采集场景，会有比较多的设备在发送数据，通过共享订阅的方式可以在订阅端设置多个订阅者来实现这几个订阅者之间的工作负载均衡。

       典型的物联网平台包括设备硬件、数据采集、数据存储、分析、Web / 移动应用等。EMQX 位于数据采集这一层，分别与硬件和数据存储、分析进行交互，是物联网平台的核心：前端的硬件通过 MQTT 协议与位于数据采集层的 EMQX 交互，通过 EMQX 将数据采集后，通过 EMQX 提供的数据接口，将数据保存到后台的持久化平台中（各种关系型数据库和 NOSQL 数据库），或者流式数据处理框架等，上层应用通过这些数据分析后得到的结果呈现给最终用户。

       EMQX 公司主要提供三个产品，可在官网首页产品导航查看每一种产品；主要体现在支持的连接数量、产品功能和商业服务等方面的区别。

       完整的 MQTT V3.1/V3.1.1 及 V5.0 协议规范支持；QoS0, QoS1, QoS2 消息支持；持久会话与离线消息支持；Retained 消息支持；Last Will 消息支持；TCP/SSL 连接支持；MQTT/WebSocket/SSL 支持；HTTP 消息发布接口支持；$SYS/# 系统主题支持；客户端在线状态查询与订阅支持；客户端 ID 或 IP 地址认证支持；用户名密码认证支持；LDAP 认证；Redis、MySQL、PostgreSQL、MongoDB、HTTP 认证集成；浏览器 Cookie 认证；基于客户端 ID、IP 地址、用户名的访问控制 (ACL)；多服务器节点集群 (Cluster)；支持 manual、mcast、dns、etcd、k8s 等多种集群发现方式；网络分区自动愈合；消息速率限制；连接速率限制；按分区配置节点；多服务器节点桥接 (Bridge)；MQTT Broker 桥接支持；Stomp 协议支持；MQTT-SN 协议支持；CoAP 协议支持；Stomp/SockJS 支持；延时 Publish ($delay/topic)；Flapping 检测；黑名单支持；共享订阅 ($share/:group/topic)；TLS/PSK 支持；规则引擎；空动作 (调试)；消息重新发布；桥接数据到 MQTT Broker；检查 (调试)；发送数据到 Web 服务。

       EMQ X 目前支持的操作系统：Centos6、Centos7、OpenSUSE tumbleweed、Debian 8、Debian 9、Debian 、Ubuntu .、Ubuntu .、Ubuntu .、macOS .、macOS .、macOS .、源码安装libcurlWindows Server 。产品部署建议 Linux 服务器，不推荐 Windows 服务器。安装的方式有很多种，可供自由选择：Shell脚本安装、包管理器安装、二进制包安装、ZIP压缩包安装、Homebrew安装、Docker运行安装、Helm安装、源码编译安装。

       Dashboard界面查看基本信息。

       身份认证是大多数应用的重要组成部分，MQTT 协议支持用户名密码认证，启用身份认证能有效阻止非法客户端的连接。EMQ X 中的认证指的是当一个客户端连接到 EMQ X 的时候，通过服务器端的配置来控制客户端连接服务器的权限。EMQ X 的认证支持包括两个层面：MQTT 协议本身在 CONNECT 报文中指定用户名和密码，EMQ X 以插件形式支持基于 Username、ClientID、HTTP、JWT、LDAP 及各类数据库如 MongoDB、MySQL、PostgreSQL、Redis 等多种形式的认证；在传输层上，TLS 可以保证使用客户端证书的客户端到服务器的身份验证，并确保服务器向客户端验证服务器证书。也支持基于 PSK 的 TLS/DTLS 认证。

       EMQ X 支持使用内置数据源（文件、内置数据库）、JWT、外部主流数据库和自定义 HTTP API 作为身份认证数据源。连接数据源、进行认证逻辑通过插件实现的，每个插件对应一种认证方式，使用前需要启用相应的插件。客户端连接时插件通过检查其 username/clientid 和 password 是否与指定数据源的信息一致来实现对客户端的身份认证。（v5.0以上默认集成）EMQ X 支持的认证方式：内置数据源、外部数据库、其他。认证结果：认证成功、认证失败、忽略认证（ignore）。

       EMQ X 默认配置中启用了匿名认证，任何客户端都能接入 EMQ X。没有启用认证插件或认证插件没有显式允许/拒绝（ignore）连接请求时，EMQ X 将根据匿名认证启用情况决定是否允许客户端连接。

       可以订阅多个主题。

       安装 paho-mqtt：导入 Paho MQTT 客户端。

       通过TCP连接：设置 broker、port、topic、client_id，连接 MQTT Broker。

       通过SSL/TLS连接：设置 broker、port、topic、client_id，连接 MQTT Broker，使用 CA certificate，设置用户名密码。

       订阅主题：设置 on_message 回调函数，当收到消息时执行。

       取消订阅：通过以下代码取消订阅，此时应指定取消订阅的主题。

       发布消息：通过以下代码发布消息，设置消息内容、主题，调用 publish 方法。

       接收消息：通过以下代码指定客户端对消息事件进行监听，并在收到消息后执行回调函数，将接收到的消息及其主题打印到控制台。

       断开连接：如客户端希望主动断开连接，可以通过如下代码实现。

       完整代码：导入 random、time、paho.mqtt.client as mqtt_client，设置 broker、port、topic、client_id，连接 MQTT Broker，设置 on_connect 回调函数，设置 publish 回调函数，运行客户端。

windows下paho.mqtt安装教程（C/C++）

       （1）Github仓库地址：

       C库：

       C++库：

       （2）Visual Studio （社区版即可）

       （3）CMake

       选择最新版本的Installer即可：

       安装过程比较简单，一路next，注意把CMake加到系统路径里即可：

       2、编译C库

       这里的主要步骤均来自于仓库的readme。

       首先clone源码到本地文件夹，例如MQTT\paho.mqtt.c ，它包含几个文件夹：

       然后打开CMake客户端，需要依次完成以下步骤：

       （1）选择源代码路径，也就是source code：

       这个路径就是上面clone的路径。

       （2）选择输出路径，CMake会将生成的vs工程保存在这个路径下，这里为了方便，可以直接在源码路径下新建一个文件夹，例如build:

       （3）配置configure，点开后如下：

       第一个是选择VS的版本，一般选择比较高的即可，这里是。然后选择输出平台，可根据情况选择x或win。这里没有特殊参数，就可以忽略Optional toolset...，然后选择下面的工具链为跨平台：

       整体的选择如下：

       然后点击Next，选择cmke文件夹下的toolchain：

       这里根据前面选择的输出平台选择win或者，然后点击完成。

       CMake界面如下，显示配置完成：

       然后可以看到一大片红色区域，它是CMake的编译选项，这里主要关注一下PAHO即可，点击展开后，有如下选项：

       这些选项都很好理解，可以看仓库的介绍，这里截取一部分如下：

       这里注意，选择的PAHO_BUILD_SHARED或者 PAHO_BUILD_STATIC最好是和后面编译C++版本的选项要一致。我这里选择SHARED。

       这里要注意一点，记住这个路径，后面编译C++库会用到：

       （4）点击生成（Generate），产生VS工程目录，位置在第（2）步选择的那个路径。

       然后就可以通过VS编译了，完成后，可以看到

       这些是编译C++库需要的一些文件。

       最后一步：安装生成的这些库文件，方便后续编译C++库文件。

       首先在源码路径打开命令行窗口或者powershell，输入如下命令，并执行：

       这一步的意义是把编译出的文件安装到指定的目录，这个目录就是第（3）步末尾提示的那个CMAKE_INSTALL_PREFIX路径，后面编译C++库文件时会用到，当然也可以在CMake中指定别的目录，如果默认的这个目录需要管理员权限才能创建，可以选择一个普通的目录（当然也可以管理员权限运行这条命令）。

       这个目录下的文件如图：

       后面会用到\lib\cmake\eclipse-paho-mqtt-c路径下的几个文件。

       3、编译C++库

       同样先把源码clone下来，然后打开CMake，按照上面编译C库的方式设置那些选项，但不需要设置工具链，直接默认即可。

       点击完成后会报错：

       原因是没找到eclipse-paho-mqtt-c，它就是刚刚要设置的C库安装目录，找到设置这个路径的CMake的选项如下，填上C库的安装目录：

       然后重新配置，就成功了。

       下一步点击生成，会报新的错误：

       原因是CMakeList里行报错：

       这里是要编译静态库版本，这与C库生成的不符合，直接把这个if编译选项去掉即可。

       再次尝试又会报错：

       原因是CMakeList选择的是security版本，这里在git仓库也有描述：

       所以，我们看C库的安装目录下是哪个，就把CMakeList里替换掉：

       将eclipse-paho-mqtt-c::paho-mqtt3as替换为eclipse-paho-mqtt-c::paho-mqtt3a 就大功告成，点击生成，就全部完成了，打开生成的VS工程，编译。

       整个过程要注意的是：C库的编译选项和C++库的编译选项最好保持一致。

浅谈mqtt源码（二）Client详解

       深入探索MQTT源码：客户端剖析

       启动MQTT客户端程序时，一般有三个关键模块：Client、Connect、Store。判断程序是否由Node.js直接执行用require.main === module。

       在客户端模块中，核心是封装一个MQTT客户端实例。实例底层通过pipe建立管道连接，此管道用于传输数据。

       当有数据写入流中，即触发_write方法，消息队列packets中的消息开始被处理。如果队列还有消息，会执行_handlePacket和nextTickWork。nextTickWork通过process.nextTick确保数据不会丢失，使得连接保持活跃。

       消息队列的数据不丢失的关键在于process.nextTick机制。

       MQTT客户端实例继承了events.EventEmitter方法，所有的异步操作完成后，会发送事件到事件队列，用于后续事件处理。

       客户端的基本操作如连接、订阅主题、发送与接收消息，具体如下：

       订阅主题时，会调用subscribe方法，该方法先验证topic格式，构造packet并发送至服务器。订阅完成后，会调用回调函数，告知已成功订阅。

       发送消息使用publish方法，构造packet，包含主题和消息内容，通过_storePacket或_sendPacket发送。

       接收消息时，通过emit和message方法将数据传递给业务代码。数据为buffer数组，需进行序列化处理。

       在_sendPacket方法中，使用mqtt-packet生成可传输的buffer，并将packet写入client的stream。stream是初始化MQTT客户端实例时传入的对象，通常包含WebSocket等相关方法。

       客户端内部还包含了unsubscribe、resubscribe及end方法，用于取消订阅、重新订阅及断开连接，具体细节不在本文深入讨论。

       总体而言，MQTT客户端的实现涉及Node.js的多个知识点，包括异步操作、事件监听、流处理等，构建了一个高效、灵活的消息传输框架。

5-Openwrt MQTT client使用

       åœ¨mosquitto里面有个client目录，里面就是使用libmosquitto实现的客户端程序，封装成mosquitto_sub和mosquitto_pub命令行。

        所以新建一个跟client同一级，自己的client，添加对应的文件

        Makefile的内容

        main.c的内容

        myclient.h的内容

        外层的mosquitto/src/Makefile里面添加myclient文件的编译

        编译测试一切正常，接下去添加mqtt的内容

        mqtt client里面最主要的就是几个回调函数，先调用lib_init,正常后，就这只各个callback，然后在callback里面做逻辑。

        各回调函数的内容

        逻辑应该也比较直观，当connect成功后，在回调函数里面订阅test1主题的内容，然后发布test2主题的内容。

        收到内容就在 myclient_message_callback 回调里面打印处理。

        正常情况我们都会让客户端的连接做一些账号密码的设置，避免别人攻击。

        将allow_anonymous改成不允许匿名登陆，并制定pwfile。

        vim /etc/mosquittoConf/mosquitto.conf

        在ubuntu上面使用mosquitto_passwd生成密码

        就会在pwfile文件下生成账号和加密的密码root/admin

        这是后登陆的时候就需要-u root -P admin进行登陆

        mosquitto提供了mosquitto_passwd命令来生成账号密码等，不过这个方式不喜欢，因为没办法定制化自己想要的账号密码加密方式，所以做了一些小改动。

        在myclient里面加我们想要的加密方式，然后在mosquitto broker的源码里面添加对应的解密方式即可。

        如下，账号为client_name，然后通过rsa和base生成密码，myclient的试下调用 mosquitto_username_pw_set 函数。

        然后在mosquitto broker里面添加解密，位于mosquitto/src/security.c文件的 mosquitto_unpwd_check 函数里面。

        另一个加密方式就是SSL认证，给客户端提供相应的证书，和配置协议(mqtt or websockets)一样，在配置文件监听的端口下面可以添加ssl的配置选项，每个port都可以单独配置ssl的证书内同容。

        如下：从端口连接进来的设备需要下面的证书要求

        设备的认证有单向认证和双向认证两种：

        单向认证，只需要提供ca证书

        双向认证，需要ca,pem,key三个

        按步骤一步一步执行，生成证书（里面也可以指定各参数，有效时间）：

        按上面的步骤可以生成如下文件

        在服务器端需要放三个文件

        如果是单向认证，客户端只需要一个文件

        如果是双向认证，客户端只需要三个文件

        查看证书的有效时间

黑群晖怎样搭建mqtt服务器

       黑群晖搭建MQTT服务器的方法如下：

       1. 安装MQTT服务软件：首先，你需要在黑群晖上安装MQTT服务软件。你可以选择一些流行的MQTT服务器软件，如Eclipse Mosquitto或VerneMQ等。你可以通过黑群晖的软件包管理器或者从官方渠道下载并安装这些软件。

       2. 配置MQTT服务器：安装完成后，你需要对MQTT服务器进行配置。这包括设置服务器监听端口、配置用户名和密码、设置允许的连接数等。具体配置方式会根据你选择的MQTT软件有所不同，但通常都会在软件的配置文件中进行设置。

       3. 启动并测试MQTT服务器：配置完成后，启动MQTT服务器，并使用测试工具或客户端程序测试服务器的连通性和功能。确保服务器可以接收和发送消息，并且根据你的配置进行相应的响应。

       详细解释：

       安装MQTT服务软件：黑群晖作为一个基于Linux的操作系统，可以通过多种途径安装软件。你可以选择通过黑群晖自带的软件包管理器进行安装，或者从MQTT软件的官方网站下载源代码进行编译安装。安装过程需要注意依赖项的满足和配置。

       配置MQTT服务器：安装完MQTT软件后，需要根据实际需求对服务器进行配置。这包括设置服务器的监听端口，通常默认为；设置用户名和密码以增加安全性；调整最大连接数等参数以满足系统要求。这些配置通常在软件的配置文件中进行。

       启动并测试MQTT服务器：完成配置后，启动MQTT服务器，并确保其正常运行。你可以使用MQTT客户端程序连接到服务器，发送和接收消息以测试服务器的功能。确保服务器能够按照你的配置进行响应，并且网络连接正常。

       通过以上步骤，你应该可以在黑群晖上成功搭建一个MQTT服务器。请注意，具体的操作步骤可能会根据你选择的MQTT软件和黑群晖版本有所不同，建议参考相关软件的官方文档进行操作。