基于socket API开发一个高性能高稳定性的跨平台MQTT客户端

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资源。

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

拥有在线代码生成工具，极其简单配置就可以生成对应的代码，

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

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

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

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

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

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

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

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

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

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

使用著名的 paho mqtt 库封包。

无其他依赖。

在线代码生成工具

本项目拥有代码生成工具，只需要在线配置即可生成代码，极其简单易用，

占用资源大小

总计占 10857字节 的ROM，而RAM的开销则几乎只依赖动态内存，在不使用TLS加密传输的情况下，维持QOS0服务质量等级的通信动态内存大约仅需要3694字节，这包括1024读缓冲区 + 1024写缓冲区 + 1024内部线程栈大小，相对于其他MQTT客户端来说，mqttclient需要的RAM资源开销极少。

整体框架

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

在框架的最上方是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框架亦可以使用，并且稳定性极好！

版本

问题

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

版权和许可

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

linux平台下测试使用

安装cmake：

sudo apt-get install cmake g++

测试程序

编译 & 运行

./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

整体框架

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

原作者：qiyongzhong0