当前位置：首页 > news >正文

在 ARM 嵌入式 Linux 下使用 C/C++ 实现 MQTT

news 来源：原创 2025/8/5 12:50:00

在 ARM 嵌入式 Linux 下使用 C/C++ 实现 MQTT 通信是一个常见的需求，尤其是在资源受限的环境中。以下是一个详细的教程，使用 Eclipse Paho C Client 库来实现 MQTT 客户端。

1. 安装 Eclipse Paho C Client 库

Eclipse Paho C Client 是一个轻量级的 MQTT 客户端库，适合嵌入式系统。

安装依赖

在 ARM 嵌入式 Linux 中，首先安装必要的依赖：

sudo apt update
sudo apt install build-essential cmake libssl-dev

下载和编译 Paho C Client

下载 Paho C Client 源码：

git clone https://github.com/eclipse/paho.mqtt.c.git
cd paho.mqtt.c

编译并安装：

cmake -Bbuild -H. -DPAHO_WITH_SSL=OFF
make -C build
sudo make -C build install

2. 编写 MQTT 客户端代码

以下是一个简单的 MQTT 客户端示例，包括订阅和发布功能。

代码：`mqtt_client.c`

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include "MQTTClient.h"#define ADDRESS     "tcp://localhost:1883"
#define CLIENTID    "arm_mqtt_client"
#define TOPIC       "test/topic"
#define PAYLOAD     "Hello from ARM MQTT Client!"
#define QOS         1
#define TIMEOUT     10000L// 收到消息的回调函数
void messageArrived(void *context, char *topicName, int topicLen, MQTTClient_message *message) {printf("Message arrived on topic: %s\n", topicName);printf("Payload: %.*s\n", message->payloadlen, (char *)message->payload);MQTTClient_freeMessage(&message);MQTTClient_free(topicName);
}int main() {MQTTClient client;MQTTClient_connectOptions conn_opts = MQTTClient_connectOptions_initializer;int rc;// 创建 MQTT 客户端rc = MQTTClient_create(&client, ADDRESS, CLIENTID, MQTTCLIENT_PERSISTENCE_NONE, NULL);if (rc != MQTTCLIENT_SUCCESS) {printf("Failed to create client, return code: %d\n", rc);exit(EXIT_FAILURE);}// 设置消息到达回调rc = MQTTClient_setCallbacks(client, NULL, NULL, messageArrived, NULL);if (rc != MQTTCLIENT_SUCCESS) {printf("Failed to set callbacks, return code: %d\n", rc);MQTTClient_destroy(&client);exit(EXIT_FAILURE);}// 连接 MQTT 代理conn_opts.keepAliveInterval = 20;conn_opts.cleansession = 1;rc = MQTTClient_connect(client, &conn_opts);if (rc != MQTTCLIENT_SUCCESS) {printf("Failed to connect, return code: %d\n", rc);MQTTClient_destroy(&client);exit(EXIT_FAILURE);}// 订阅主题rc = MQTTClient_subscribe(client, TOPIC, QOS);if (rc != MQTTCLIENT_SUCCESS) {printf("Failed to subscribe, return code: %d\n", rc);MQTTClient_disconnect(client, TIMEOUT);MQTTClient_destroy(&client);exit(EXIT_FAILURE);}printf("Subscribed to topic: %s\n", TOPIC);// 发布消息MQTTClient_message pubmsg = MQTTClient_message_initializer;pubmsg.payload = (void *)PAYLOAD;pubmsg.payloadlen = strlen(PAYLOAD);pubmsg.qos = QOS;pubmsg.retained = 0;rc = MQTTClient_publishMessage(client, TOPIC, &pubmsg, NULL);if (rc != MQTTCLIENT_SUCCESS) {printf("Failed to publish message, return code: %d\n", rc);MQTTClient_disconnect(client, TIMEOUT);MQTTClient_destroy(&client);exit(EXIT_FAILURE);}printf("Published message: %s\n", PAYLOAD);// 等待消息到达printf("Waiting for messages...\n");while (1) {sleep(1);}// 断开连接并销毁客户端MQTTClient_disconnect(client, TIMEOUT);MQTTClient_destroy(&client);return 0;
}

3. 编译代码

在 ARM 嵌入式 Linux 中编译代码：

gcc -o mqtt_client mqtt_client.c -lpaho-mqtt3c

4. 运行代码

确保 Mosquitto 代理已启动。
运行编译后的程序：
```
./mqtt_client
```
如果一切正常，程序将订阅 test/topic 主题并发布一条消息。

5. 测试和验证

使用 mosquitto_sub 订阅 test/topic 主题：
```
mosquitto_sub -h localhost -t test/topic
```
运行 mqtt_client，你应该能在 mosquitto_sub 终端中看到发布的消息。

6. 优化和注意事项

资源优化：
- 如果内存资源紧张，可以禁用 SSL（如示例中所示）。
- 减少 MQTTClient_message 的缓冲区大小。
网络稳定性：
- 在嵌入式系统中，确保网络连接稳定，避免因网络问题导致通信失败。
日志管理：
- 在发布版本中禁用调试日志，减少资源占用。
交叉编译：
- 如果需要在开发主机上交叉编译，请使用合适的交叉编译工具链，例如：
```
arm-linux-gnueabihf-gcc -o mqtt_client mqtt_client.c -lpaho-mqtt3c
```

通过以上步骤，可在 ARM 嵌入式 Linux 中成功实现 MQTT 通信，并编写高效的 C/C++ 客户端程序。

在 ARM 嵌入式 Linux 下使用 C/C++ 实现 MQTT

在 ARM 嵌入式 Linux 下使用 C/C 实现 MQTT 通信是一个常见的需求，尤其是在资源受限的环境中。以下是一个详细的教程，使用 Eclipse Paho C Client 库来实现 MQTT 客户端。 1. 安装 Eclipse Paho C Client 库 Eclipse Paho C Client 是一个轻量级的 MQTT…...

编程日记 2025/8/5 12:50:00

C++20 中 `constexpr` 的强大扩展：算法、工具与复数库的变革

文章目录一、constexpr 在 <algorithm> 中的应用1. 编译时排序2. 编译时查找二、constexpr 在 <utility> 中的应用1. 编译时交换2. 编译时条件交换三、constexpr 在 <complex> 中的应用1. 编译时复数运算四、总结 C20 对 constexpr 的增强是其最引人注目…...

编程日记 2025/7/31 5:58:17

C++ 介绍STL底层一些数据结构

c 标准模板库中，set和map的底层实现通常基于红黑树，然们都是平衡二叉搜索树(Balanceed Binary Serach Tree）的一种,这种结构保证了插入，删除，查找的时间复杂度为O(log n)比普通二叉搜索树更高效。 set set<T>…...

编程日记 2025/8/1 19:30:07

算法2--两数相加

题目描述解题思路题目说的很详细了，也就是把每个数倒序写成链表进行输入，然后让你计算两个倒序数组的和，要保证跟预期的结果一样。首先应该考虑的是两个数组的长度问题，对于链表的每一位进行加法运算，如果两个列表…...

编程日记 2025/7/29 13:06:21

Docker搭建Testlink教程

1.拉取镜像打开终端输入命令： #拉取mariadb镜像 docker pull bitnami/mariadb #拉取testlink镜像 docker pull bitnami/testlink-archived 执行结果： 2.运行容器打开终端输入命令： #创建容器网络 docker network create testlink #查…...

编程日记 2025/8/5 12:49:59

安卓7.0以上App抓包

安卓7.0以上App抓包导出BurpSuite证书设置本机IP的8080端口监听证书转换将这个der证书下载到kali上，并使用以下命令进行证书转换 openssl x509 -inform der -in cacert.der -out burp.pem openssl x509 -inform PEM -subject_hash_old -in burp.pem转换成功…...

编程日记 2025/8/5 12:48:02

CCBCISCN复盘

AWDP – ccfrum 自己搭了一下环境, 复现一下这道题目, 之前比赛的时候完全没想到这个漏洞要怎么打, 修也不知道要怎么修, 就仅仅是对用户名的账号和密码进行了一下过滤, 完全没起到作用, 唉, 实在太菜如果想要尝试复现的话可以尝试拉取这个镜像, 我打完之后就直接把这个容器给…...

编程日记 2025/8/3 1:10:02

【C++】八大常见的设计模式的实现与实践指南

目录创建型模式单例模式工厂方法模式抽象工厂模式结构型模式适配器模式装饰者模式代理模式行为型模式观察者模式策略模式命令模式高级主题现代C特性影响模式性能对比典型应用案例设计模式分类一、创建型模式 1. 单例模式（Singleton） 现代…...

编程日记 2025/8/1 20:51:07

OpenEMMA: 基于多模态大语言模型的端到端开源自动驾驶框架

OpenEMMA: 基于多模态大语言模型的端到端开源自动驾驶框架创新点 OpenEMMA 将前置摄像头图像和车辆历史文本状态作为输入。驾驶任务被构建为视觉问答（VQA）问题，利用思维链推理来指导模型生成关键物体的详细描述、行为洞察和元驾驶决策。这…...

编程日记 2025/7/31 9:31:00

kali，NTFS，用户管理，文件共享，本地安全策略，计算机基础

kali更新源 vim /etc/apt/sources.list 优质源中科大Kali镜像源deb http://mirrors.ustc.edu.cn/kali kali-rolling main non-free contribdeb-src http://mirrors.ustc.edu.cn/kali kali-rolling main non-free contrib阿里云Kali镜像源deb http://mirrors.aliyun.com…...

编程日记 2025/7/31 11:55:54

零基础上手Python数据分析 (7)：Python 面向对象编程初步

写在前面回顾一下，我们已经学习了 Python 的基本语法、数据类型、常用数据结构和文件操作、异常处理等。到目前为止，我们主要采用的是面向过程 (Procedural Programming) 的编程方式，即按照步骤一步一步地编写代码，解决问题。这种方式对于简单的任务已经足够，但当程序…...

编程日记 2025/8/5 12:48:26

基于深度学习的皮肤癌智能检测与语音提示系统【python源码+Pyqt5界面+数据集+训练代码】

《------往期经典推荐------》一、AI应用软件开发实战专栏【链接】项目名称项目名称1.【人脸识别与管理系统开发】2.【车牌识别与自动收费管理系统开发】3.【手势识别系统开发】4.【人脸面部活体检测系统开发】5.【图片风格快速迁移软件开发】6.【人脸表表情识别系统】7.【…...

编程日记 2025/7/29 12:56:25

脚本一键式启动Nginx、Mysql、Redis

此脚本包含拉取镜像、数据卷挂载、容器启动三大部分，可一键式安装三大环境新建一个depoy.sh文件在服务器上，然后复制以下内容。给脚本文件添加执行权限 chmod x depoy.sh # 文件的当前目录下如果需要修改数据库MYSQL密码和Reids密码 MYSQL_ROO…...

编程日记 2025/8/1 17:00:13

蓝桥杯备赛-DFS-有奖问答

问题描述小蓝正在参与一个现场问答的节目。活动中一共有 3030 道题目, 每题只有答对和答错两种情况, 每答对一题得 1010 分，答错一题分数归零。小蓝可以在任意时刻结束答题并获得目前分数对应的奖项，之后不能再答任何题目。最高奖项需要 100100 分, …...

编程日记 2025/8/1 16:56:58

[AI速读]CHISEL vs. SystemVerilog：用RISC-V核心对比两种硬件设计语言

在硬件设计领域，选择合适的语言对开发效率、维护成本和最终性能都至关重要。最近，一项研究对比了两种硬件描述语言——CHISEL（基于Scala的嵌入式语言）和传统的SystemVerilog，它们分别实现了同一款RISC-V核心（SweRV-EL2）。以下是关键发现和结论。为什么选择CHISEL？ CHI…...

编程日记 2025/7/23 18:06:45

PHP PSR（PHP Standards Recommendations）介绍

PHP PSR（PHP Standards Recommendations）是 PHP 社区制定的一系列标准化规范，旨在统一 PHP 代码的编写方式、接口设计和开发实践，以提高代码的可读性、可维护性和互操作性。以下是核心 PSR 标准的解读和具体使用方法： …...

编程日记 2025/8/4 1:29:32

字节跳动实习生主导开发强化学习算法，助力大语言模型性能突破

目录禹棋赢的背景与成就主要成就 DAPO算法的技术细节算法优势禹棋赢的研究历程关键时间节点字节跳动的“Top Seed人才计划” 计划特点小编总结在大模型时代，经验不再是唯一的衡量标准，好奇心、执行力和对新技术的敏锐洞察力成为推动技术…...

编程日记 2025/7/30 7:48:30

Java并发编程面试题：锁（17题）

🧑 博主简介：CSDN博客专家，历代文学网（PC端可以访问：https://literature.sinhy.com/#/?__c1000，移动端可微信小程序搜索“历代文学”）总架构师，15年工作经验，精通Java编…...

编程日记 2025/8/1 19:04:55

各类神经网络学习：（四）RNN 循环神经网络（下集），pytorch 版的 RNN 代码编写

上一篇下一篇RNN（中集）待编写代码详解 pytorch 官网主要有两个可调用的模块，分别是 nn.RNNCell 和 nn.RNN ，下面会进行详细讲解。 RNN 的同步多对多、多对一、一对多等等结构都是由这两个模块实现的，只需要将对输入…...

编程日记 2025/8/5 12:48:02

【python】OpenCV—Hand Landmarks Detection

文章目录 1、功能描述2、代码实现3、效果展示4、完整代码5、涉及到的库函数6、参考更多有趣的代码示例，可参考【Programming】 1、功能描述基于 opencv-python 和 mediapipe 实现手部关键点的检测（无法检测出手，不过可以根据关键点的信息外…...

编程日记 2025/8/4 9:17:54

C++和标准库速成(十)——类型别名、类型定义、类型推断和标准库简介

目录 1. 类型别名2. 类型定义(不建议)3. 类型推断3.1 auto3.1.1 auto&3.1.2 auto*3.1.3 拷贝列表初始化和直接列表初始化 3.2 decltype 4. 标准库简介参考 1. 类型别名类型别名为现有的类型声明提供新名称。可以将类型别名视为用于为现有类型声明引入同义词而无须创建新类…...

编程日记 2025/7/30 21:54:51

Java JMX 未授权访问漏洞分析与修复指南

#作者：张桐瑞文章目录一、漏洞背景二、漏洞描述三、漏洞影响四、修复方案1. 禁用远程JMX访问：2. 配置JMX访问权限： 一、漏洞背景 Java管理扩展（Java Management Extensions，简称JMX）是Java平台的管理和…...

编程日记 2025/8/3 1:18:23

挂谷问题与挂谷猜想：从平面转针到高维拓扑

挂谷问题与挂谷猜想：从平面转针到高维拓扑目录挂谷问题的起源数学定义与基本性质研究进展挂谷集合与挂谷猜想王虹与Joshua Zahl的突破意义与影响挂谷问题的起源 1917年，日本数学家挂谷宗一(かけやそういち Soichi Kakeya，1886-1947)提…...

编程日记 2025/8/3 13:53:12

区块链智能合约安全 | 整型溢出漏洞

目录： 核心概念溢出类型上溢原理案例下溢原理案例练习漏洞修复使用 SafeMath 库（旧版本） 升级 Solidity 版本（≥0.8.0） 地址：zkanzz 整型溢出漏洞（Integer Overflow/Underflow Vulne…...

编程日记 2025/8/5 12:48:24

C# HTTP 文件上传、下载服务器

程序需要管理员权限，vs需要管理员打开首次运行需要执行以下命令注册URL（管理员命令行） netsh advfirewall firewall add rule name"FileShare" dirin actionallow protocolTCP localport8000 ipconfig | findstr "IPv4&quo…...

编程日记 2025/7/21 12:29:04

IDEA导入jar包后提示无法解析jar包中的类，比如无法解析符号 ‘log4j‘

IDEA导入jar包后提示无法解析jar包中的类问题描述解决方法问题描述 IDEA导入jar包的Maven坐标后，使用jar中的类比如log4j，仍然提示比如无法解析符号 log4j。解决方法在添加了依赖和配置文件后，确保刷新你的IDE项目和任何缓存&#xff…...

编程日记 2025/8/2 13:31:42

C++前缀和

个人主页：[PingdiGuo_guo] 收录专栏：[C干货专栏] 大家好，今天我们来了解一下C的一个重要概念：前缀和目录 1.什么是前缀和 2.前缀和的用法 1.前缀和的定义 2.预处理前缀和数组 3.查询区间和 4.数组中某个区间的和是否为特定…...

编程日记 2025/7/29 9:48:14

kafka压缩

最近有幸公司参与kafka消息压缩，背景是日志消息量比较大。kafka版本2.4.1 一、确认压缩算法根据场景不同选择不同。如果是带宽敏感患者推荐高压缩比的zstd，如果是cpu敏感患者推荐lz4 lz4和zstd底层都使用的是lz77算法，具体实现逻辑不同&am…...

编程日记 2025/8/5 12:48:03

C 语言 --- 扫雷游戏(初阶版)

C 语言 --- 扫雷游戏初阶版代码全貌与功能介绍扫雷游戏的功能说明游戏效果展示游戏代码详解game.htest.cgame.c 总结 💻作者简介：曾与你一样迷茫，现以经验助你入门 C 语言 💡个人主…...

编程日记 2025/8/3 8:01:50

黑鲨外设2025春季新品发布会：全球首款“冷暖双控”鼠标亮相！

据可靠消息称，电竞外设领域的创新引领者——黑鲨外设，正式官宣将于2025年3月28日17:00召开主题为“究极体验，竞在其中”春季新品发布会。据悉，此次新品发布会将于黑鲨游戏外设和黑鲨游戏手机官方平台同步直播，&#xf…...

编程日记 2025/8/5 12:48:02

SpringBoot-MVC配置类与 Controller 的扫描

文章目录前言一、自动配置类位置二、自动配置类解析2.1 WebMvcAutoConfiguration2.1.1 EnableWebMvcConfiguration 2.2 DispatcherServletAutoConfiguration 三、RequestMapping 的扫描过程3.1 RequestMappingHandlerMapping#afterPropertiesSet3.2 RequestMappingHandlerMapp…...

编程日记 2025/7/28 11:05:06

Nexus L2 L3基本配置

接口基本配置 N7K上所有端口默认处于shutdown状态; N5K上所有端口默认处于no shutdown状态(所有端口都是switchport) 默认所有接口都是三层route模式, 只有当线卡不支持三层的时候, 接口才会处于二层switchport模式 show run all | in “system default” 创建SVI口需要提前打…...

编程日记 2025/8/1 21:39:43

asp.net 4.5在医院自助系统中使用DeepSeek帮助医生分析患者报告

环境： asp.net 4.5Visual Studio 2015本地已经部署deepseek-r1:1.5b 涉及技术 ASP.NET MVC框架用于构建Web应用程序。使用HttpWebRequest和HttpWebResponse进行HTTP请求和响应处理。JSON序列化和反序列化用于构造和解析数据。SSE（服务器发送事件&#xf…...

编程日记 2025/8/5 8:02:12

LCCI ESG 中英联合认证国际分析师适合的岗位

LCCI ESG中英联合认证国际分析师领域热门岗位大揭秘！🌍 大家好！今天我们来探讨LCCI ESG中英联合认证国际分析师领域的热门岗位，看看是否有适合你的选择。 1️⃣ LCCI ESG中英联合认证国际分析师报告专员：主要负责编制…...

编程日记 2025/7/30 19:29:06

AGI成立的条件

AGI（通用人工智能）的成立需满足多项核心条件，这些条件既涵盖技术能力层面的突破，也涉及伦理与认知维度的考量。一、通用性与多任务处理能力跨领域泛化能力 AGI需具备类似人类的通用性，能够灵活切换不同领域&#xf…...

编程日记 2025/7/26 12:30:54

论文阅读：2023 EMNLP SeqXGPT: Sentence-level AI-generated text detection

总目录大模型安全相关研究：https://blog.csdn.net/WhiffeYF/article/details/142132328 SeqXGPT: Sentence-level AI-generated text detection https://aclanthology.org/2023.emnlp-main.73/ https://github.com/Jihuai-wpy/SeqXGPT https://www.doubao.com/…...

编程日记 2025/8/5 8:27:04

解决python配置文件类configparser.ConfigParser，插入、读取数据，自动转为小写的问题

配置类 [Section1] Key_AAA Value[Section2] AnotherKey Value默认情况下，ConfigParser会将ini配置文件中的KEY，转为小写。重载后配置类： 继承类从configparser.ConfigParser改为configparser.RawConfigParser重载方法optionxform&#…...

编程日记 2025/7/21 12:23:29

超图神经网络的详细解析与python示例

扩展传统集合关系至超边结构，处理高阶交互问题。有关人工智能的数学基础之逻辑、集合论和模糊理论：看我文章人工智能的数学基础之逻辑、集合论和模糊理论-CSDN博客一、超图神经网络概述超图神经网络（Hypergraph Neural Network&#xff0…...

编程日记 2025/7/31 17:13:39

机器视觉中图像的腐蚀和膨胀是什么意思？它能用来做什么？

腐蚀（Erosion）和膨胀（Dilation）是两种基本的形态学操作，通常用于二值图像（黑白图像）的处理。它们是形态学图像处理的基础，广泛应用于图像分割、边缘检测、噪声去除等任务。 1…...

编程日记 2025/7/30 23:47:21

破局 MySQL 死锁：深入理解锁机制与高效解决方案

死锁的原理 1. 什么是死锁？ 当多个事务在并发执行时，每个事务都持有其他事务需要的锁，同时又在等待对方释放锁，导致所有事务都无法继续执行的状态，称为死锁（Deadlock）。 2. 死锁的四个必要…...

编程日记 2025/7/28 3:43:03

机器学习——分类、回归、聚类、LASSO回归、Ridge回归（自用）

纠正自己的误区：机器学习是一个大范围，并不是一个小的方向，比如：线性回归预测、卷积神经网络和强化学都是机器学习算法在不同场景的应用。机器学习最为关键的是要有数据，也就是数据集名词解释：数据集中的…...

编程日记 2025/8/2 17:20:07

脚本语言 Lua

概念 Lua由标准C编写而成，几乎在所有操作系统和平台上都可以编译、运行。Lua脚本可以很容易地被C/C 代码调用，也可以反过来调用C/C的函数，这使得Lua在应用程序中可以被广泛应用。Lua并没有提供强大的库，它是不适合作为开发独立应…...

编程日记 2025/8/5 12:29:33

Spring相关面试题

目录 Spring中常用的注解有哪些 Spring Boot中RestController和Controller注解有什么区别？ Spring的注解requestBody和responseBody的区别说说Bean和componentscan的区别简单介绍一下springboot Spring Boot有哪些常用的Starter依赖？ 说说sprin…...

编程日记 2025/8/4 15:16:18

Python学习- 数据结构类型

一. list list_data [10, 20, 30]列表：是一个不限制类型，可增加，修改，删除的数据类型可操作的方法：append，extend, pop，del ，insert append: 可向list最后一个位置添加一个元…...

编程日记 2025/8/2 22:54:23

Azure Delta Lake、Databricks和Event Hubs实现实时欺诈检测

设计Azure云架构方案实现Azure Delta Lake和Azure Databricks，结合 Azure Event Hubs/Kafka 摄入实时数据，通过 Delta Lake 实现 Exactly-Once 语义，实时欺诈检测（流数据写入 Delta Lake，批处理模型实时更新&#xff0…...

编程日记 2025/8/3 5:31:53