嵌入式设备联网不发愁：MQTT-C 两个源文件跑通轻量级 C 语言 MQTT 客户端
【免费下载链接】MQTT-CA portable MQTT C client for embedded systems and PCs alike.项目地址: https://gitcode.com/gh_mirrors/mq/MQTT-C
做物联网开发的工程师大多遇到过同样的尴尬：设备端资源有限，跑不动动辄几万行的 MQTT 客户端库；想自己写一个，又要面对协议细节、断线重连、多平台移植这些深坑。MQTT-C 这个纯 C 语言实现的 MQTT v3.1.1 客户端，正是冲着这个痛点来的——整个库只有两个源文件，总代码量不到 2000 行，却能同时在微控制器和 PC 上稳定工作。这篇文章就带你从零认识它，并亲手把第一个 Demo 跑起来。
设备想上云，先过 MQTT 客户端这道坎
MQTT 是物联网领域使用最广的消息协议，特点是极省带宽、极省电，适合低速率、高延迟的链路。但协议简单不等于实现简单：连接握手、心跳保活、QoS 消息确认、报文编解码，每一样都要处理。市面上的 C 客户端要么体积庞大，要么强依赖特定操作系统接口，移植到自家板卡上往往要改半天。
MQTT-C 的思路很直接：协议部分只依赖一个薄薄的标准库，再通过一层透明的平台抽象层（PAL）隔离所有系统调用。于是两个文件的分工就变得清晰——src/mqtt.c负责协议逻辑，src/mqtt_pal.c负责平台相关的收发与时间、锁等原语。要换平台？改 PAL 就够了，协议代码一行不用动。
三个问题，看懂它为什么能这么轻
为什么只有两个源文件？因为它不重复造轮子。MQTT 协议本身的报文格式并不复杂，MQTT-C 把序列化、反序列化和客户端状态机收敛在mqtt.c一个文件里，依赖的只是memcpy、strlen这类标准函数。这两份代码还是 ANSI C（C89）兼容的，任何主流 C 编译器都能直接编过。
跨平台到底怎么跨？答案在mqtt_pal.h。这个头文件是mqtt.c唯一包含的头文件，里面声明了移植所需的一切：MQTT_PAL_TIME()获取时间、MQTT_PAL_MUTEX_LOCK/RELEASE加解锁、mqtt_pal_sendall/recvall收发数据。它还内置了 Unix、Windows、NuttX 等平台的适配，如果你在别的 RTOS 上开发，也可以直接通过MQTTC_PAL_FILE宏指定自己的 PAL 头文件。
线程安全吗？全部 API 都是线程安全的，同时也能在单线程环境里顺畅运行。这个特性对嵌入式场景尤其重要——裸机程序没有线程，但函数仍能正常工作；跑 RTOS 时则可以放心地把收发逻辑放进独立任务。
动手实验：三步让第一个 Demo 跑起来
与其纸上谈兵，不如直接体验。先把代码取下来：
git clone https://gitcode.com/gh_mirrors/mq/MQTT-C项目自带 Makefile 和 CMakeLists.txt 两种构建方式。用 Makefile 最省事，一条命令就把示例和单元测试都编好：
make all编译产物会放进bin/目录。接着运行发布者示例，它会连上公共测试代理（默认test.mosquitto.org:1883），你每按一次回车就发布一次当前时间：
./bin/simple_publisher再开一个终端运行订阅者，就能实时收到消息了：
./bin/simple_subscriber整个过程不需要配置任何东西，从 clone 到看到第一条消息，两分钟足够。你也可以在examples/目录下找到simple_publisher.c、simple_subscriber.c、reconnect_subscriber.c等完整源码，直接当作学习模板。
从 Hello World 到真正收发：核心 API 就五步
示例看懂了，正式写代码也不难。核心流程可以概括为：初始化、连接、收发、同步。
struct mqtt_client client; uint8_t sendbuf[2048], recvbuf[1024]; /* 1. 初始化：传入已连接的 socket、收发缓冲区、消息回调 */ mqtt_init(&client, sockfd, sendbuf, sizeof(sendbuf), recvbuf, sizeof(recvbuf), publish_callback); /* 2. 连接代理，清空会话，400 秒心跳 */ mqtt_connect(&client, "my_device", NULL, NULL, 0, NULL, NULL, MQTT_CONNECT_CLEAN_SESSION, 400); /* 3. 订阅主题，最大 QoS 0 */ mqtt_subscribe(&client, "sensors/temperature", 0); /* 4. 发布消息，QoS 1 确保至少送达一次 */ mqtt_publish(&client, "sensors/temperature", "25.5", 4, MQTT_PUBLISH_QOS_1); /* 5. 周期调用，驱动收发（单线程下放在主循环里即可） */ mqtt_sync(&client);注意缓冲区是你在初始化时自己分配的——这既是 MQTT-C 轻量的原因，也是它的设计哲学：把资源控制权完全交给你。QoS 0/1/2 三种服务质量都完整支持，从"最多一次"到"精确一次"，按业务需要挑选即可。
新手容易踩的三个坑
坑一：缓冲区不够用。sendbuf要能装下多条待发送消息，recvbuf至少要容下一条完整报文，否则会触发MQTT_ERROR_SEND_BUFFER_IS_FULL或MQTT_ERROR_RECV_BUFFER_TOO_SMALL。参考示例的 2048/1024 组合，再按你的消息大小调整。
坑二：连接断了怎么办。别慌，项目提供了mqtt_init_reconnect，配合重连回调（参考examples/reconnect_subscriber.c）能实现自动恢复会话：出错后清理旧连接、重新mqtt_reinit、再次mqtt_connect并恢复订阅。这个示例里甚至支持手动注入错误来观察重连过程，很适合拿来验证自己的重连逻辑。
坑三：明文通信不放心。生产环境建议走加密链路。项目配套了 OpenSSL、mbedTLS、BearSSL 三种方案，对应的openssl_publisher.c、bio_publisher.c示例演示了如何用加密 socket 替代普通 socket，CMake 里分别用MQTT_C_OpenSSL_SUPPORT等选项开启。
两个能直接落地的使用场景
场景一：智能温控器上报室温。设备每隔几分钟把温度、湿度写入home/livingroom/environment主题，QoS 1 保证数据不丢。云端订阅该主题做展示和告警。在 100KB 内存级别的 MCU 上，MQTT-C 的收发缓冲加起来不过 3KB，完全跑得动。
场景二：产线设备状态监控。每台机床周期性向factory/line-3/machine-7/status发布运行参数，运维平台统一订阅。借助自动重连机制，设备断电重启后能自行恢复上报，无需人工干预。
现在就可以开始
MQTT-C 把"轻量"和"易移植"这两件事做到了同级别库里的最前端：两个文件、2000 行以内、C89 兼容、MIT 协议许可，可以放心嵌入到你的产品里。官方还提供了基于 cmocka 的单元测试（./bin/tests可指定代理地址运行），动手改代码前可以先跑一遍，确保环境没问题。
从examples/simple_publisher.c开始，把第一个消息发出去，你的设备就算正式"联网"了。接下来无论是接传感器、接云平台还是接产线系统，MQTT-C 都能稳稳托住你的物联网应用。
【免费下载链接】MQTT-CA portable MQTT C client for embedded systems and PCs alike.项目地址: https://gitcode.com/gh_mirrors/mq/MQTT-C
创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考
