程序员经验分享-hwhale

一个高性能、高稳定性的跨平台MQTT客户端——mqttclient简介与使用

2023-05-16

文章目录

  • mqttclient简介与使用
  • 优势：
  • 在线代码生成工具
  • 占用资源大小
  • 整体框架
  • 支持的平台
  • 版本
  • 问题
  • 版权和许可
  • linux平台下测试使用
    • 安装cmake：
    • 测试程序
    • 编译 & 运行
    • 编译成动态库libmqttclient.so

mqttclient简介与使用

一个高性能、高稳定性的跨平台MQTT客户端

一个高性能、高稳定性的跨平台MQTT客户端，基于socket API之上开发，可以在嵌入式设备（FreeRTOS/LiteOS/RT-Thread/TencentOS tiny）、Linux、Windows、Mac上使用，拥有非常简洁的API接口，以极少的资源实现QOS2的服务质量，并且无缝衔接了mbedtls加密库。

优势：

  • 具有极高的稳定性：无论是掉线重连，丢包重发，都是严格遵循MQTT协议标准执行，除此之外对大数据量的测试无论是收是发，都是非常稳定，高频测试也是非常稳定。

  • 轻量级：整个代码工程极其简单，不使用mbedtls情况下，占用资源极少，作者曾使用esp8266模组与云端通信，整个工程代码消耗的RAM不足15k。

  • 支持mbedtls加密传输，让网络传输更加安全，而且接口层完全不需要用户理会，无论是否加密，mqttclient对用户提供的API接口是固定的，这就很好的兼容了一套代应用层的码可以加密传输也可以不加密传输。

  • 支持多客户端，同时兼容多个客户端运行工作，一个设备连接多个的服务器。

  • 支持同步异步处理，应用程序无需阻塞等待浪费CPU资源。

  • 支持拦截器配置，在某些平台中，客户端会默认自动订阅系统主题，而且每次来自服务器的主题都是变动的，此时需要使用拦截器进行拦截，分离主题与数据信息，并递交给用户，极大提高灵活性。

  • 拥有在线代码生成工具，及其简单配置就可以生成对应的代码，地址：https://jiejietop.gitee.io/mqtt/index.html

  • 拥有极简的API接口，总的来说，mqttclient的配置都有默认值，基本无需配置都能使用的，也可以随意配置，对配置都有健壮性检测，这样子设计的API接口也是非常简单。

  • 多功能参数可配置可裁剪，重连时间间隔、心跳周期、最大订阅数量、命令超时、读写缓冲区大小、拦截器处理等等参数功能可裁剪可配置，满足开发者再复杂、简单等各种开发环境下的使用需求。

  • 支持自动重新订阅主题，在自动重连后保证主题不会丢失。

  • 支持主题通配符“#”、“+”。

  • 订阅的主题与消息处理完全分离，让编程逻辑更加简单易用，用户无需理会错综复杂的逻辑关系。

  • mqttclient内部已实现保活处理机制，无需用户过多关心理会，用户只需专心处理应用功能即可。

  • 拥有非常好的设计，以极少的资源设计了记录机制，当报文在丢失的时候进行重发操作，确保qos1、qos2服务质量等级的报文保证其服务质量。

  • 有非常好的代码风格与思想：整个代码采用分层式设计，代码实现采用异步处理的思想，降低耦合，提高性能。

  • 基于标准BSD socket之上开发，只要是兼容BSD socket的系统均可使用。

  • 无缝衔接salof：它是一个同步异步日志输出框架，在空闲时候输出对应的日志信息，也可以将信息写入flash中保存，方便调试。

  • 使用著名的 paho mqtt 库封包。

  • 无其他依赖。

在线代码生成工具

本项目拥有代码生成工具，只需要在线配置即可生成代码，及其简单易用，代码生成工具地址：https://jiejietop.gitee.io/mqtt/index.html

在线代码生成工具

占用资源大小

总计占11042字节的ROM，而RAM的开销则几乎只依赖动态内存（这依然是极少的）。

Code(inc. data)RO DataRW DataZI DataObject Name
6086168440400mqttclient.o
54618000mqttconnectclient.o
2120000mqttdeserializepublish.o
47622040mqttpacket.o
2360000mqttserializepublish.o
3100000mqttsubscribeclient.o
380000mqttunsubscribeclient.o
560000nettype_tcp.o
620000network.o
240000platform_memory.o
400000platform_mutex.o
3460000platform_net_socket.o
940000platform_thread.o
700000platform_timer.o
24610040random.o
620000mqtt_list.o
------
8904173440480total

整体框架

拥有非常明确的分层框架。

整体架构

  • 在框架的最上方是API函数接口，实现了客户端的申请、释放、设置参数、连接服务器、断开连接、订阅主题、取消订阅主题、发布消息等函数接口。

  • 使用了著名的paho mqtt库作为MQTT报文封包库。

  • 采用异步处理的机制去管理所有的ack，它在发送报文的时候不用等待服务器的应答，只是记录下来，在收到服务器的ack后，取消这个记录，效率极高；而在发送mqtt报文（QoS1/QoS2）的时候没有收到服务器的应答时，将重发该报文。

  • 内部实现了一个mqtt yield线程，统一处理所有的内容，比如超时的处理、ack报文的处理、收到来自服务器的publish报文，此时会去调用回调函数告知用户收到的数据，发布释放、发布完成报文的处理、心跳报文（保持活性），当与服务器断开连接时需要尝试重连、重新订阅主题，重新发送报文或者应答等。

  • 报文的处理，如读写报文、解码mqtt报文、设置报文（dup标记）、销毁报文等操作。

  • network是网络组件，它可以自动选择数据通道，如果是加密方式则通过tls加密进行数据传输，而tls可以选择mbedtls作为加密后端；也可以是tcp直连方式，最终都是通过tcp传输的。

  • platform是平台抽象层，封装了不同系统的东西，比如socke或者AT，线程、时间、互斥锁、内存管理，这些是与系统打交道的，也是跨平台必要的封装。

  • 最右边的则是通用的内容，list的处理、日志库、错误处理、软件随机数发生器等。

支持的平台

目前已实现了Linux、TencentOS tiny、FreeRTOS、RT-Thread平台（已做成软件包，名字为kawaii-mqtt），除此之外TencentOS tiny的AT框架亦可以使用（RAM消耗不足15K），并且稳定性极好！

平台代码位置
Linuxhttps://github.com/jiejieTop/mqttclient
TencentOS tinyhttps://github.com/Tencent/TencentOS-tiny/tree/master/board/Fire_STM32F429
TencentOS tiny AT 框架https://github.com/jiejieTop/gokit3-board-mqttclient
RT-Threadhttps://github.com/jiejieTop/kawaii-mqtt
FreeRTOShttps://github.com/jiejieTop/freertos-mqttclient

版本

发布版本描述
[v1.0.0]初次发布，完成基本框架及其稳定性验证
[v1.0.1]修复主动与服务器断开连接时的逻辑处理
[v1.0.2]添加新特性——拦截器，修复一些小bug
[v1.0.3]避免造成全局污染修改了log、list相关函数的命名
[v1.0.4]重新调整了network结构与mbedtls数据通道

问题

欢迎以 GitHub Issues 的形式提交问题和bug报告

版权和许可

mqttclient 遵循 Apache License v2.0 开源协议。鼓励代码共享和尊重原作者的著作权，可以自由的使用、修改源代码，也可以将修改后的代码作为开源或闭源软件发布。

linux平台下测试使用

安装cmake：

    sudo apt-get install cmake g++

测试程序

测试平台位置
emqx（我私人部署的服务器）./test/emqx/test.c
百度天工./test/baidu/test.c
onenet./test/onenet/test.c

编译 & 运行

    ./build.sh

运行build.sh脚本后会在 ./build/bin/目录下生成可执行文件emqx、baidu、onenet等多个平台的可执行程序，直接运行即可。

    ./build/bin/emqx

编译成动态库libmqttclient.so

    ./make-libmqttclient.sh

运行make-libmqttclient.sh脚本后会在 ./libmqttclient/lib目录下生成一个动态库文件libmqttclient.so，并安装到系统的/usr/lib目录下，相关头文件已经拷贝到./libmqttclient/include目录下,将其拷贝到你的工程中即可，编译应用程序的时候只需要链接动态库即可-lmqttclient -lpthread，动态库的配置文件是根据./test/mqtt_config.h配置的。

如果你是用交叉编译器的话，则应该根据你使用的编译器导出对应的环境变量（此处使用的交叉编译器是arm-linux-gnueabihf-gcc），同时你也必须将动态库文件libmqttclient.so拷贝到你的嵌入式系统的/usr/lib目录下：

    export CROSS_COMPILE=arm-linux-gnueabihf-

如若需要卸载libmqttclient.so，执行以下命令即可：

    ./make-libmqttclient.sh remove
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)

一个高性能、高稳定性的跨平台MQTT客户端——mqttclient简介与使用 的相关文章

  • 面试 | 推荐几个程序员刷题的网站！面试必备！！！

    经常有朋友问我 xff0c 有没有在线刷题的网站推荐 为什么要用线上刷题呢 xff1f 确实有一定好处 xff0c 线上的笔试题有自动更新 xff0c 可以记录你刷题的记录 xff0c 更好的来统计你的错误率和错误题型 最主要的是方便 xf

  • Docker镜像构建过程记录

    Docker镜像构建过程记录 为公司一个java工程 xff0c 构建一个docker镜像 xff0c 并将镜像存入私有库中 记录一下操作过程 1 打包 这是一个spring boot的maven工程 xff0c 打包命令就很简单了 spa

  • 直流可调稳压电源的Proteus仿真设计（附仿真+论文等资料）

    注意 xff1a 全套资源获取 xff0c 请见文末说明 设计要求 1 输出电压在1 25V 37V可调 xff1b 2 最大输出电流为1 5A xff1b 3 电压调整精度达0 1 xff1b 摘要 直流稳压电源由电源变换器 桥式整流滤波

  • GPT PMBR size mismatch 解决方法

    https blog csdn net agave7 article details 83177858 root 64 debian home liyezhen src sbk debian 32bit build product tool

  • react router路由传参三种方式

    react router路由传参三种方式 xff1a 通过通配符传参 query传参和state传参 1 通配符传参 Route定义方式 xff1a lt Route path 61 39 path name 39 component 61

  • ROS与GAZEBO实时硬件仿真（4）——深入理解与总结

    声明 xff1a 本博客是对博主无人的回忆所写的ROS与GAZEBO实时硬件仿真系列文章的自我理解与总结 xff0c 所写内容是基于该博主的三篇博文的 xff0c 如果有幸被人参考 xff0c 建议先看完该博主的三篇文章再来看这篇文章 三篇

  • 最短路径算法之AStar算法(二) A Star算法需要注意的问题

    上篇文章中证明了A Star算法 xff0c 下面 xff0c 我们来看看该算法中需要注意的几个问题 1 xff0c 在扩展节点M时 xff0c 计算了其后继节点N的F值 xff0c 发现N节点已经在open链表中 xff0c 并且新的F值

  • yolo论文中IOU/AP/MAP/NMS概念详解

    之前在只看了一遍吴恩达神经网络下写了一篇Darknet yolov2的综述 xff0c 最近接着往下学时发现很多基础的概念不是很懂 xff0c 所以这篇解决一下寸疑问题 1 卷积滑动窗口 滑动窗口大家都了解的 xff0c 从图片的左上角开始

  • ANO匿名飞控STM32代码解读（一）任务调度——Ano_Scheduler.c

    我所学习的代码是匿名飞控使用STM32芯片ANO PioneerPro 20190825的版本 匿名飞控的整体代码是跑裸机的 xff0c 任务调度是用STM32F4芯片中的系统时钟计时 xff0c 做了一个任务调度系统 xff0c 举个例子

  • 地面坐标系与机体坐标系的转换和欧拉角

    大家在入门四旋翼飞行器数学模型时第一个遇到的就是坐标系的转换 这篇文章用尽量浅显的语言为大家讲解坐标系的转换的欧拉角 机体坐标系 原点O取在飞机质心处 Xb轴指向机头 Yb轴指向机身右方 Zb指向机身下方 地面坐标系 在地面上选一点Og x

  • 飞桨AIStudio基础操作

    目录 执行和调试 多文件代码编辑 上传Notebook Notebook快捷键 Notebook中使用Shell命令 查看文件夹目录 使用pip来安装自己需要的package 但不支持apt get 查看当前环境中安装的package 持久

  • VSCode与CMake搭配使用之基本配置

    1 首先安装VSCode插件CMake和CMake Tools CMake插件主要功能是CMake语法高亮 自动补全CMake Tools的功能主要是结合VSCode IDE使用CMake这个工具 xff0c 比如生成CMake项目 构建C

  • 九、设置元素等待

    转载于 xff1a http www testclass net selenium python element wait WebDriver提供了两种类型的等待 xff1a 显式等待和隐式等待 显式等待 显式等待使WebdDriver等待

  • Unity Tweak Tool使用

    这年头 xff0c 都讲究个性 Unity刚出来的时候 xff0c 就觉着新奇 xff0c 其他也没啥 xff0c 就是有些小不顺手 最开始使用的Ubuntu Tweak到后来的Gnome Tweak Tool都有点偏 xff0c ubun

  • MYSQL–my.cnf配置中文详解

    basedir 61 path 使用给定目录作为根目录 安装目录 character sets dir 61 path 给出存放着字符集的目录 datadir 61 path 从给定目录读取数据库文件 pid file 61 filenam

  • vscode中C/C++的Clang-format的使用

    一 介绍 Clang format是一个功能强大的格式化工具 在vs code通过C C 43 43 扩展后即可使用Clang format工具进行代码的格式化 其自带的排版格式主要有 xff1a LLVM Google Chromium

  • ShardingJDBC核心概念与快速实战

    目录 ShardingSphere介绍 ShardingSphere特点 ShardingSphere简述 ShardingSphere产品区分 ShardingJDBC实战 核心概念 实战 ShardingJDBC的分片算法 Shardi

  • 野火嵌入式学习笔记：第47讲 按键检测输入

    野火 第一期 Linux系列教学视频之 零基础入门 篇 xff0c 手把手教学 xff0c 从0开始 xff0c 基于野火i MX6ULL Pro MINI开发板 第47讲 检测按键输入 哔哩哔哩 bilibili 检测用户按键3 key按

  • 学习野火嵌入式笔记 第48讲：进程的由来

    野火 第二期 Linux系列教学视频之 内核编程 篇 xff0c 手把手教学 xff0c 硬件基于野火i MX6ULL Pro MINI开发板 野火 第二期 Linux系列教学视频之 内核编程 篇 xff0c 手把手教学 xff0c 硬件基

  • 学习野火嵌入式笔记：第68讲 I.MX^ULL 启动方式

    野火 第三期 Linux系列教学视频之 裸机开发 篇 xff0c 手把手教学 xff0c 基于野火i MX6ULL Pro MINI开发板 哔哩哔哩 bilibili 先了解其芯片手册以及linux开发板的原理图 全篇就在讲启动方式的引脚设

随机推荐

  • C语言 字符串-字符串的匹配

    字符串匹配函数 const char strstr const char str1 const char str2 搜索字符串在另一个字符串中首次出现的位置 const char p 61 strstr 34 how are you 34

  • Lambda表达式

    什么是Lambda表达式 Lambda 表达式是 Java8 新增的重要特性 xff0c Lambda 使 Java 具有了函数式编程的思想 xff0c 它的实质也是由编译器根据表达式推断最终生成原始语法的字节码方式 函数式编程思想是 强调

  • MPU6050多次发送数据，但第一次读取的数据为0

    实际现象并不是第一次数据为0 xff0c 一直读取数据 xff0c 中间也会出现数据为0的现象 xff0c 原因是 xff1a 跟采样频率有关 xff0c 如果采样频率为50Hz xff0c 那么读取数据间隔时间必须大于20ms xff0c

  • gazebo多机仿真时出现的问题解决方法

    多机仿真过程中出现的飞机不动的情况是 xff1a 下面几个步骤要严格执行 xff1a cd PX4 span class token operator span Autopilot git submodule update span cla

  • Linux c多线程与c++多线程的基础写法

    最近工作需要 xff0c 对多线程做了一点了解 xff0c 现在将多线程的创建 xff0c 函数传参做个小结 一 linux c多线程 1 头文件 xff1a include lt pthread h gt 2 创建线程 xff1a pth

  • 姿态误差问题

    前段同学问了一个关于飞机姿态误差的问题 xff0c 将飞机姿态直接做差与px4里面先z轴对齐然后将过渡矩阵的姿态量赋值给滚转俯仰姿态误差对比 xff0c 发现直接做差后在飞机做大的机动时误差量会变大 xff0c 曲线的拟合非常不好 xff0

  • px4 avoidance笔记

    最近在用px4官方的avoidance代码跑硬件避障 xff0c 官方介绍了只要生成符合sensor msgs PointCloud2点云信息就能使用 xff0c 因此为了应用长基线双目 xff0c 没有使用realsense的相机 xff

  • PX4源代码下载编译

    sudo git clone https github com PX4 PX4 Autopilot git recursivegit submodule update init recursivegit submodule update r

  • 踩坑记录

    ERROR Session line number was not unique in database History logging moved to new session 66 在生成tfrecord时 总报如下错误 找了很长时间

  • git强制覆盖本地代码

    git强制覆盖本地 xff1a git fetch all 拉取所有更新 git reset hard origin master 本地代码同步线上最新版本 会覆盖本地所有与远程仓库上同名的文件 git pull git强制覆盖本地命令 x

  • 【毕业设计】基于STM32及OpenMV的云台追踪装置

    目录 修改记录1 摘 要2 整体功能分析3 硬件选型3 1 OpenMV4 Cam H73 2 STM32F103ZET63 3 DS3120舵机3 4 LED补光板3 5 供电及稳压3 6 硬件连接 4 软件功能实现4 1 OpenMV部

  • firewall-cmd 使用总结

    firewalld的简要说明 firewalld firewall cmd firewall offline cmd它们Python脚本 xff0c 通过定义的在 usr lib firewalld下面的xml配置信息 xff0c 在启动时

  • 机架与机柜

    随着计算机网络的发展 xff0c 数据中心的服务器以及网络通信设备等IT设施 xff0c 正逐步向着网络化 机架化的方向发展 机架是用于综合布线 xff0c 安装配线架和理线架 xff0c 实现对电缆和光缆布线系统的管理 在网络机柜中不具备

  • cmake和makefile区别和cmake指定编译器（cmake -G）

    一 cmake和makefile区别 要说明区别 xff0c 我们先要区分下面三类工具 xff1a 1 项目构建生成工具 首先cmake是项目构建生成工具 xff0c cmake的代码可以与平台系统和编译器无关 类似cmake的工具还有au

  • Gazebo使用过程中的问题

    1 运行命令gazebo没有反应 在虚拟机安装好gazebo后 xff0c 使用ALT 43 F2打开命令行运行命令gazebo没有反应 首先尝试内存不够的情况 xff0c 给虚拟机加到了4g内存 没有用 xff0c 运行gazebo还是没

  • 一张图理解板卡硬件调试流程

    最近在调试从焊板厂打样回来的板卡 xff0c 简单总结了下板卡的硬件测试流程 xff0c 如下图 xff1a 写在后面的话 xff1a 我之所以选择做技术这一行 xff0c 是觉得做技术的人简单 直接 xff0c 当你面对一个技术问题 xf

  • 关于Linux进程你所需要知道的一切都在这里！！

    文章目录 进程简单了解进程查看进程进程ID父进程ID父进程与子进程 程序与进程程序进程程序变成进程总结 进程状态进程状态转换启动新进程system fork exce系列函数 终止进程等待进程wait waitpid 进程 说明 xff1a

  • MQTT协议简介及协议原理

    文章目录 MQTT协议MQTT协议简介MQTT通信模型MQTT客户端的功能 xff1a MQTT客户服务器功能 xff1a 消息主题与服务质量MQTT控制报文固定报头可变报头CONNECT报文CONNACK报文 有效载荷 MQTT协议 MQ

  • 你不得不看的图文并茂的MQTT协议通信过程！！！

    文章目录 MQTT连接服务器MQTT订阅主题MQTT发布消息服务质量等级 QoSQoS0的PUBLISH控制报文QoS1的PUBLISH控制报文QoS2的PUBLISH控制报文 取消订阅断开连接 MQTT连接服务器 客户端到服务器的网络连接

  • 一个高性能、高稳定性的跨平台MQTT客户端——mqttclient简介与使用

    文章目录 mqttclient简介与使用优势 xff1a 在线代码生成工具占用资源大小整体框架支持的平台版本问题版权和许可linux平台下测试使用安装cmake xff1a 测试程序编译 amp 运行编译成动态库libmqttclient

热门标签