ryan-cw-code / ryanmqtt Goto Github PK

View Code? Open in Web Editor NEW

10.0 2.0 2.0 2.72 MB

RyanMqtt实现了c语言MQTT3.1.1协议的客户端。此库针对资源受限的嵌入式设备进行了优化，具有高稳定性、高性能

Home Page: https://ryan-cw-code.github.io/RyanDocs/

License: Apache License 2.0

Python 0.20% C 99.39% Makefile 0.19% Lua 0.21%

ryanmqtt's Introduction

RyanMqtt

使用遇到问题可以提 issue / RT-Thread 社区提问，谢谢。

[RyanMqtt使用介绍和示例代码（一）](RT-Thread-RyanMqtt使用介绍和示例代码（一）RT-Thread问答社区 - RT-Thread)

[RyanMqtt QOS质量测试（二）](RT-Thread-RyanMqtt QOS质量测试（二）RT-Thread问答社区 - RT-Thread)

[RyanMqtt 移植指南（三）](RT-Thread-RyanMqtt 移植指南（三）RT-Thread问答社区 - RT-Thread)

1、介绍

RyanMqtt 实现了 MQTT3.1.1 协议的客户端。此库针对资源受限的嵌入式设备进行了优化。

初衷：在使用RT-Thread时，没有非常合适的 mqtt 客户端。项目中 mqtt 又是非常核心的功能。参考 MQTT3.1.1 标准和项目需求设计的 mqtt 客户端，它拥有以下特点。

严格遵循 MQTT3.1.1 协议标准实现
稳定的全 QOS 等级实现消息实现。用户可控的消息丢弃机制，避免 RyanMqttQos2 / RyanMqttQos1 消息无限堆积重发消耗的内存空间
支持多客户端
弱网环境依然可以稳定运行
完整的 MQTT 主题通配符支持，“/”、“#”、“+”、“$”
可选择的 keepalive、reconnet、lwt、session 等
客户端多功能参数配置，丰富的用户可选的事件回调，满足实际项目的绝大部分需求
优化过的并发能力，无等待的连续 20000 条 RyanMqttQos2 消息稳定发送和接收无一丢包(测试环境为linux，实际情况会收到单片机内存大小和网络硬件的收发能力的影响)
资源占用少，依赖少
跨平台，只需实现少量的平台接口即可
没有内置 TLS 支持，用户可以在platform层实现 TLS（使用 TLS 的项目也不会只有 mqtt 使用，用户自己实现可以防止 TLS 模块间冲突）
不支持裸机平台，裸机想要稳定的 MQTT3.1.1 实现可以参考coreMQTT

2、设计

RyanMqtt 设计时参考了mqttclient、esp-mqtt、coreMQTT。

平台兼容层封装不同操作系统内核接口，方便实现跨平台
核心库使用著名的 paho mqtt 库作为 mqtt 封包库
核心线程是每个客户端必须创建的线程，统一处理客户端所有的操作，比如 mqtt 状态机、事件回调、心跳保活、消息解析、消息超时处理、消息重发等
系统服务管理模块提供 RyanMqtt 实现功能的工具，包含 session 状态、事件处理、通配符匹配、消息链表等
用户应用模块提供给用户调用的丰富的接口，包含 RyanMqtt 客户端申请 / 销毁、mqtt 多参数配置、事件注册 / 注销、QOS 消息丢弃、 mqtt 连接 / 停止 / 重连 / 发布 / 订阅 / 取消订阅等

3、平台接口

RyanMqtt 库希望应用程序为以下接口提供实现：

system 接口

RyanMqtt 需要 RTOS 支持，必须实现如下接口才可以保证 mqtt 客户端的正常运行

函数名称	函数简介
platformMemoryMalloc	申请内存
platformMemoryFree	释放已申请内存
platformPrint	打印字符串
platformDelay	毫秒延时
platformThreadInit	初始化线程
platformThreadStart	开启线程
platformThreadStop	挂起线程
platformThreadDestroy	销毁线程
platformMutexInit	初始化互斥锁
platformMutexLock	获取互斥锁
platformMutexUnLock	释放互斥锁
platformMutexDestroy	销毁互斥锁
platformCriticalInit	初始化临界区
platformCriticalEnter	进入临界区
platformCriticalExit	退出临界区
platformCriticalDestroy	销毁临界区

network 接口

RyanMqtt 依赖于底层传输接口 API，必须实现该接口 API 才能在网络上发送和接收数据包

MQTT 协议要求基础传输层能够提供有序的、可靠的、双向传输（从客户端到服务端和从服务端到客户端）的字节流

函数名称	函数简介
platformNetworkConnect	根据 ip 和端口连接服务器
platformNetworkRecvAsync	非阻塞接收数据
platformNetworkSendAsync	非阻塞发送数据
platformNetworkClose	断开 mqtt 服务器连接

time 接口

RyanMqtt 依靠函数生成毫秒时间戳，用于计算持续时间和超时，内部已经做了数值溢出处理

函数名称	函数简介
platformUptimeMs	自系统启动以来 ms 时间戳

4、示例

RT-Thread 平台

接口示例请参考 platform/rtthread 文件夹
RyanMqtt 使用示例请参考 example 文件夹
需要使能 SAL 或者 LWIP，示例使用 socket 实现数据收发。
需要 MSH 组件，示例默认挂载到 MSH 组件

详细使用请参考 example，提供了一些测试接口和使用范例

移远QuecOpen平台

接口示例请参考 platform/quecopen 文件夹，请根据平台差异进行修改

Linux平台

接口示例请参考 platform/linux 文件夹，请根据平台差异进行修改

5、依赖

暂无

6、声明

请勿将此库 QOS 消息等级用于支付等可能造成重大损失的场景，如需使用请自行深度评估后使用！！！作者不对使用此库造成的任何损失负责。不要只依靠 qos2 来保证安全！！！。（尽管此库 RyanMqttQos2 消息等级经过很多测试，但是异步组件由于诸多因素例如波动非常大的网络甚至无法建立稳定连接、mqtt 服务端的策略配置等，无法做到绝对的准确性。需要用户用应用层做到数据的最终一致性。）

ryanmqtt's People

Contributors

Stargazers

Watchers

Forkers

ftarpa kamwing1992

ryanmqtt's Issues

能否移植到linux

仔细看了readme，如果没有使能 ulog 或者非 RT-Thread 平台，用户需要手动修改 RyanMqttLog.h 文件调整打印等级，其中RyanMqttLog.h 在源码中没有找到啊？

Random assertion failed

Hi,
I seem to get a lot of assertion failed on different functions on connect and subscribe.

上位机快速发包packetType变成0错误

你好，我遇到了以下问题，请帮我分析一下，谢谢！

如果上位机快速发布topic，大概1s有3帧，mqttclient就会触发错误，

我的配置如下：

static char mqttRecvBuffer[8192];
static char mqttSendBuffer[4096];

    RyanMqttClientConfig_t mqttConfig = {
        .clientId = mqtt_para.localIp,
        .userName = RyanMqttUserName,
        .password = RyanMqttPassword,
        .host = mqtt_para.serverIP,
        .port = RyanMqttPort,
        .taskName = "mqttThread",
        .taskPrio = 16,
        .taskStack = 8192,
        .recvBufferSize = sizeof(mqttRecvBuffer),
        .sendBufferSize = sizeof(mqttSendBuffer),
        .recvBuffer = mqttRecvBuffer,
        .sendBuffer = mqttSendBuffer,
        .mqttVersion = 4,
        .ackHandlerRepeatCountWarning = 6,
        .ackHandlerCountWarning = 20,
        .autoReconnectFlag = RyanMqttTrue,
        .cleanSessionFlag = RyanMqttTrue,
        .reconnectTimeout = 3000,
        .recvTimeout = 11000,
        .sendTimeout = 2000,
        .ackTimeout = 10000,
        .keepaliveTimeoutS = 30,
        .mqttEventHandle = mqttEventHandle,
        .userData = NULL};

触发错误的log：


[D/RyanMqttThread] libraries\RyanMqtt\mqttclient\RyanMqttThread.c:803 连接状态
[D/RyanMqttThread] libraries\RyanMqtt\mqttclient\RyanMqttThread.c:442 packetType: 0
[D/RyanMqttThread] libraries\RyanMqtt\mqttclient\RyanMqttThread.c:803 连接状态
[D/RyanMqttThread] libraries\RyanMqtt\mqttclient\RyanMqttThread.c:442 packetType: 0
[D/RyanMqttThread] libraries\RyanMqtt\mqttclient\RyanMqttThread.c:803 连接状态
[D/RyanMqttThread] libraries\RyanMqtt\mqttclient\RyanMqttThread.c:442 packetType: 0
[D/RyanMqttThread] libraries\RyanMqtt\mqttclient\RyanMqttThread.c:803 连接状态
[D/RyanMqttThread] libraries\RyanMqtt\mqttclient\RyanMqttThread.c:442 packetType: 0
[D/RyanMqttThread] libraries\RyanMqtt\mqttclient\RyanMqttThread.c:803 连接状态
[D/RyanMqttThread] libraries\RyanMqtt\mqttclient\RyanMqttThread.c:442 packetType: 0
[D/RyanMqttThread] libraries\RyanMqtt\mqttclient\RyanMqttThread.c:803 连接状态
[D/RyanMqttThread] libraries\RyanMqtt\mqttclient\RyanMqttThread.c:442 packetType: 0
[D/RyanMqttThread] libraries\RyanMqtt\mqttclient\RyanMqttThread.c:803 连接状态
[D/RyanMqttThread] libraries\RyanMqtt\mqttclient\RyanMqttThread.c:442 packetType: 0
[D/RyanMqttThread] libraries\RyanMqtt\mqttclient\RyanMqttThread.c:803 连接状态
[D/RyanMqttThread] libraries\RyanMqtt\mqttclient\RyanMqttThread.c:442 packetType: 0
[D/RyanMqttThread] libraries\RyanMqtt\mqttclient\RyanMqttThread.c:803 连接状态
[D/RyanMqttThread] libraries\RyanMqtt\mqttclient\RyanMqttThread.c:442 packetType: 0
[D/RyanMqttThread] libraries\RyanMqtt\mqttclient\RyanMqttThread.c:803 连接状态
[D/RyanMqttThread] libraries\RyanMqtt\mqttclient\RyanMqttThread.c:442 packetType: 0
[D/RyanMqttThread] libraries\RyanMqtt\mqttclient\RyanMqttThread.c:803 连接状态
[D/RyanMqttThread] libraries\RyanMqtt\mqttclient\RyanMqttThread.c:442 packetType: 3
         pri  status      sp     stack size max used left tick  error
-------- ---  ------- ---------- ----------  ------  ---------- ---
ftp       27  suspend 0x00000214 0x00000800    33%   0x00000064 000
tshell    20  suspend 0x000001c8 0x00001000    14%   0x0000000a 000
ParserTa  18  suspend 0x000000f8 0x000001f4    49%   0x0000000a 000
crtpRxTa  18  suspend 0x00000100 0x00000400    25%   0x0000000a 000
crtpTxTa  18  suspend 0x000000f0 0x00000400    23%   0x0000000a 000
CRTP-SRV  20  suspend 0x000000c4 0x00000400    26%   0x0000000a 000
motorSrv  20  suspend 0x000000c0 0x00000400    26%   0x0000000a 000
crtp_uar  18  suspend 0x000000a4 0x00000400    16%   0x0000000a 000
mqttThre  16  running 0x00000c08 0x00002000    37%   0x00000006 000
telnet    26  suspend 0x00000210 0x00000800    40%   0x00000064 000
acon       9  suspend 0x00000118 0x00000800    13%   0x00000064 000
tcpip     10  suspend 0x000000f8 0x00000800    45%   0x0000000f 000
etx       12  suspend 0x0000013c 0x00000400    68%   0x00000007 000
erx       12  suspend 0x000000c4 0x00000400    64%   0x00000004 000
sys work  23  suspend 0x00000110 0x00000800    57%   0x0000000a 000
tidle0    31  ready   0x00000070 0x00000100    62%   0x0000000f 000
main      12  suspend 0x0000014c 0x00001000    46%   0x00000004 000

(((void *)0) != topic && 0 != topicLen) has assert failed at RyanMqttMsgHandlerFind:369.

Firmware name: rtthread, hardware version: 1.0, software version: 1.0
Assert on thread mqttThre
===== Thread stack information =====
  addr: 2401fab8    data: 24007f58
  addr: 2401fabc    data: 00000171
  addr: 2401fac0    data: 0807a19c
  addr: 2401fac4    data: 0806f048
  addr: 2401fac8    data: 002efad0
  addr: 2401facc    data: 2401fb70
  addr: 2401fad0    data: 2401fad8
  addr: 2401fad4    data: 0802f645
  addr: 2401fad8    data: 2401fae8
  addr: 2401fadc    data: 00000171
  addr: 2401fae0    data: 0807a19c
  addr: 2401fae4    data: 0806f048
  addr: 2401fae8    data: 0000322e
  addr: 2401faec    data: 010026be