9. 一个高性能的开源mqtt客户端¶
在github上有很多开源的项目，比如本章要介绍的这个MQTT客户端，它是 一个高性能、高稳定性的跨平台MQTT客户端 ，项目地址是：https://github.com/jiejieTop/mqttclient。
9.1. mqttclient简介¶
一个高性能、高稳定性的跨平台MQTT客户端，基于socket API之上开发，可以在嵌入式设备（FreeRTOS/LiteOS/RT-Thread/TencentOS tiny）、Linux、Windows、Mac上使用，拥有非常简洁的API接口，以极少的资源实现QOS2的服务质量，并且无缝衔接了mbedtls加密库。
9.2. mqttclient的优势：¶
具有极高的稳定性：无论是 掉线重连，丢包重发 ，都是 严格遵循MQTT协议标准 执行，除此之外对 大数据量 的测试无论是收是发，都是非常稳定，高频 测试也是非常稳定。
轻量级：整个代码工程极其简单，不使用mbedtls情况下，占用资源极少，作者曾使用esp8266模组与云端通信，整个工程代码消耗的RAM不足15k。
支持mbedtls加密传输，让网络传输更加安全，而且接口层完全不需要用户理会，无论是否加密，mqttclient对用户提供的API接口是 固定 的，这就很好的兼容了一套代应用层的码可以加密传输也可以不加密传输。
支持多客户端，同时兼容多个客户端运行工作，一个设备连接多个的服务器。
支持同步异步处理，应用程序无需阻塞等待浪费CPU资源。
支持拦截器配置，在某些平台中，客户端会默认自动订阅系统主题，而且每次来自服务器的主题都是变动的，此时需要使用拦截器进行拦截，分离主题与数据信息，并递交给用户，极大提高灵活性。
拥有在线代码生成工具，极其简单配置就可以生成对应的代码，地址：[https://jiejietop.gitee.io/mqtt/index.html](https://jiejietop.gitee.io/mqtt/index.html)
拥有极简的API接口，总的来说，mqttclient的配置都有默认值，基本无需配置都能使用的，也可以随意配置，对配置都有健壮性检测，这样子设计的API接口也是非常简单。
多功能参数可配置可裁剪，重连时间间隔、心跳周期、最大订阅数量、命令超时、读写缓冲区大小、拦截器处理等等参数功能可裁剪可配置，满足开发者再复杂、简单等各种开发环境下的使用需求。
支持自动重新订阅主题，在自动重连后保证主题不会丢失。
支持主题通配符`“#”、“+”`。
订阅的主题与消息处理完全分离，让编程逻辑更加简单易用，用户无需理会错综复杂的逻辑关系。
mqttclient内部已实现保活处理机制，无需用户过多关心理会，用户只需专心处理应用功能即可。
拥有非常好的设计，以极少的资源设计了 记录机制 ，当报文在丢失的时候进行重发操作，确保qos1、qos2服务质量等级的报文保证其服务质量。
有非常好的代码风格与思想：整个代码采用分层式设计，代码实现采用异步处理的思想，降低耦合，提高性能。
基于标准BSD socket之上开发，只要是兼容BSD socket的系统均可使用。
无缝衔接salof：它是一个同步异步日志输出框架，在空闲时候输出对应的日志信息，也可以将信息写入flash中保存，方便调试。
使用著名的 paho mqtt 库封包。
无其他依赖。
9.3. 在线代码生成工具¶
本项目拥有代码生成工具，只需要在线配置即可生成代码，极其简单易用，代码生成工具地址：[https://jiejietop.gitee.io/mqtt/index.html](https://jiejietop.gitee.io/mqtt/index.html)
在线代码生成工具¶
9.4. mqttclient整体架构¶
拥有非常明确的分层架构。
整体架构¶
在架构的最上方是API函数接口，实现了客户端的初始化、释放、连接服务器、断开连接、订阅主题、取消订阅主题、发布消息等函数接口。
mqtt client使用了著名的paho mqtt库。
采用异步处理的机制去管理所有的ack，它在发送报文的时候不用等待服务器的应答，只是记录下来，在收到服务器的ack后，取消这个记录，效率极高；而在发送mqtt报文（QoS1/QoS2）的时候没有收到服务器的应答时，将重发该报文。
内部实现了一个mqtt yield线程，统一处理所有的内容，比如超时的处理、ack报文的处理、收到来自服务器的publish报文，此时会去调用回调函数告知用户收到的数据，发布释放、发布完成报文的处理、心跳报文（保持活性），当与服务器断开连接时需要尝试重连、重新订阅主题，重新发送报文或者应答等。
报文的处理，读写报文、解码mqtt报文、设置报文（dup）、销毁报文等操作。
network是网络组件，它可以自动选择数据通道，如果是加密方式则通过tls进行数据传输，而tls可以选择mbedtls作为加密后端；也可以是tcp直连方式，最终都是通过tcp传输的。
platform是平台抽象层，封装了不同系统的东西，比如socke或者AT，线程、时间、互斥锁、内存管理，这些是与系统打交道的，也是跨平台必要的封装。
最右边的则是通用的内容，list的处理、日志库、错误处理、软件随机数发生器等。
9.5. 占用资源大小¶
总计占 10857字节 的ROM，而RAM的开销则几乎只依赖动态内存，在不使用TLS加密传输的情况下，维持QOS0服务质量等级的通信动态内存大约仅需要 3694 字节，这包括1024读缓冲区 + 1024写缓冲区 + 1024内部线程栈大小，相对于其他MQTT客户端来说，mqttclient需要的RAM资源开销极少。
Code |
RO Data |
RW Data |
ZI Data |
Object Name |
|---|---|---|---|---|
7118 |
791 |
0 |
0 |
mqttclient.o |
546 |
0 |
0 |
0 |
mqttconnectclient.o |
212 |
0 |
0 |
0 |
mqttdeserializepublish.o |
476 |
0 |
4 |
0 |
mqttpacket.o |
236 |
0 |
0 |
0 |
mqttserializepublish.o |
310 |
0 |
0 |
0 |
mqttsubscribeclient.o |
38 |
0 |
0 |
0 |
mqttunsubscribeclient.o |
56 |
0 |
0 |
0 |
nettype_tcp.o |
62 |
0 |
0 |
0 |
network.o |
24 |
0 |
0 |
0 |
platform_memory.o |
40 |
0 |
0 |
0 |
platform_mutex.o |
344 |
0 |
0 |
0 |
platform_net_socket.o |
94 |
0 |
0 |
0 |
platform_thread.o |
70 |
0 |
0 |
0 |
platform_timer.o |
246 |
0 |
4 |
0 |
random.o |
62 |
0 |
0 |
0 |
mqtt_list.o |
10066 |
791 |
8 |
0 |
total |
9.6. 支持的平台¶
目前已实现了Linux、TencentOS tiny、FreeRTOS、RT-Thread平台（已做成软件包，名字为 kawaii-mqtt ），除此之外TencentOS tiny的AT框架亦可以使用，并且稳定性极好！
平台 |
代码位置 |
|---|---|
Linux |
|
TencentOS tiny |
https://github.com/Tencent/TencentOS-tiny/tree/master/board/Fire_STM32F429 |
TencentOS tiny AT 框架 |
|
RT-Thread |
|
FreeRTOS |
9.7. 发布的版本信息¶
发布版本 |
描述 |
|---|---|
[v1.0.0] |
初次发布，完成基本框架及其稳定性验证 |
[v1.0.1] |
修复主动与服务器断开连接时的逻辑处理 |
[v1.0.2] |
添加新特性——拦截器，修复一些小bug |
[v1.0.3] |
避免造成全局污染修改了log、list相关函数的命名 |
[v1.0.4] |
重新调整了network结构与mbedtls数据通道 |
[v1.1.0] |
一个较大版本的更新，重构部分代码，优化MQTT处理的逻辑，提升整体的稳定性，支持多客户端，支持设置遗嘱，优化API接口，增加多个云平台的测试代码与说明文档，增加在线代码生成工具、在线裁剪配置工具 |
9.8. 版权和许可¶
mqttclient 遵循 Apache License v2.0 开源协议。鼓励代码共享和尊重原作者的著作权，可以自由的使用、修改源代码，也可以将修改后的代码作为开源或闭源软件发布。
在接下来的文章我们将使用该库去连接百度云、阿里云、onenet等云平台。