0

0

c++ mqtt客户端 c++如何使用mosquitto库连接mqtt broker

月夜之吻

月夜之吻

发布时间:2026-03-18 19:05:34

|

198人浏览过

|

来源于php中文网

原创

mosquitto_connect() 返回 MOSQ_ERR_CONN_PENDING 是正常异步连接状态,需立即调用 mosquitto_loop_start() 或 mosquitto_loop() 启动网络循环,否则连接卡住、on_connect 不触发。

c++ mqtt客户端 c++如何使用mosquitto库连接mqtt broker

mosquitto_connect() 为什么一直返回 MOSQ_ERR_CONN_PENDING

这是新手最常卡住的地方:调用 mosquitto_connect() 后没立刻连上,却误以为失败了。mosquitto 默认使用异步 I/O,这个返回值是正常流程的一部分,不是错误。

真正要做的不是重试或报错,而是启动网络循环:

  • 必须在 mosquitto_connect() 之后立即调用 mosquitto_loop_start()(推荐)或手动轮询 mosquitto_loop()
  • 如果用了 mosquitto_loop_start(),记得后续用 mosquitto_loop_stop() 清理线程
  • 漏掉循环 → 连接永远卡在 pending,on_connect 回调永远不会触发
  • 在单线程 CLI 工具里用 mosquitto_loop() 更可控;服务类程序建议用 mosquitto_loop_start() 避免阻塞主逻辑

回调函数里不能直接调用 mosquitto_publish()

可以调,但有陷阱:如果 publish 在 on_connect 里执行,而此时 broker 还没完成 CONNECT ACK 的收发流程,部分 broker(比如 EMQX 5.x)会静默丢弃这条消息。

安全做法是等 on_connect 被调用且 rc == MOSQ_ERR_SUCCESS 后,再延后一小段时间(哪怕 10ms)再发:

立即学习C++免费学习笔记(深入)”;

一览妙笔
一览妙笔

自媒体、编剧、营销人员写作工具

下载
  • std::this_thread::sleep_for(std::chrono::milliseconds(10)) 简单垫一下
  • 更健壮的做法是发个空消息或 ping 测试通路,确认 session 已激活
  • 别在 on_message 回调里同步调 mosquitto_publish() 太多次——容易触发 broker 的 QoS 限流或本地 socket 缓冲区溢出

编译时找不到 libmosquitto.so 或链接失败

不是头文件路径问题,而是运行时动态链接路径没配对。mosquitto 库安装后通常不在系统默认路径(/usr/lib/usr/local/lib),尤其用包管理器(如 apt、brew)装的版本。

  • Linux 下检查:ldconfig -p | grep mosquitto,如果没输出,说明库路径没注册
  • 临时解决:export LD_LIBRARY_PATH=/usr/lib/x86_64-linux-gnu:$LD_LIBRARY_PATH(Ubuntu/Debian 路径)
  • CMake 中正确写法:find_package(mosquitto REQUIRED) + target_link_libraries(your_target PRIVATE mosquitto),别手写 -lmosquitto
  • macOS 上 brew 安装后路径通常是 /opt/homebrew/lib,需加 -rpath /opt/homebrew/lib 到 linker flags

订阅后收不到消息,但 on_message 回调明明注册了

常见原因不是代码逻辑,而是 QoS 和 broker 状态不匹配:

  • 确保 mosquitto_subscribe()qos 参数和发布端一致;QoS 0 订阅收不到 QoS 1 发布的消息(某些 broker 严格校验)
  • 检查 broker 是否启用了 ACL:用户没权限订阅对应 topic,broker 不报错,只是静默过滤
  • 确认 client id 是唯一的——重复 client id 会导致前一个连接被踢下线,新连接还没来得及订阅就断开了
  • mosquitto_sub -t 'test/topic' -v -d 手动验证 broker 是否真在发消息,排除 client 端解析问题

异步库的坑往往藏在“看起来什么都没做错”的地方:连接状态、QoS 匹配、权限、client id 唯一性——这四个点漏查一个,调试时间就翻倍。

相关文章

c++速学教程(入门到精通)
c++速学教程(入门到精通)

c++怎么学习?c++怎么入门?c++在哪学?c++怎么学才快?不用担心,这里为大家提供了c++速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

WorkBuddy
WorkBuddy

腾讯云推出的AI原生桌面智能体工作台

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
session失效的原因
session失效的原因

session失效的原因有会话超时、会话数量限制、会话完整性检查、服务器重启、浏览器或设备问题等等。详细介绍:1、会话超时:服务器为Session设置了一个默认的超时时间,当用户在一段时间内没有与服务器交互时,Session将自动失效;2、会话数量限制:服务器为每个用户的Session数量设置了一个限制,当用户创建的Session数量超过这个限制时,最新的会覆盖最早的等等。

337

2023.10.17

session失效解决方法
session失效解决方法

session失效通常是由于 session 的生存时间过期或者服务器关闭导致的。其解决办法:1、延长session的生存时间;2、使用持久化存储;3、使用cookie;4、异步更新session;5、使用会话管理中间件。

776

2023.10.18

cookie与session的区别
cookie与session的区别

本专题整合了cookie与session的区别和使用方法等相关内容,阅读专题下面的文章了解更详细的内容。

97

2025.08.19

线程和进程的区别
线程和进程的区别

线程和进程的区别:线程是进程的一部分,用于实现并发和并行操作,而线程共享进程的资源,通信更方便快捷,切换开销较小。本专题为大家提供线程和进程区别相关的各种文章、以及下载和课程。

806

2023.08.10

macOS怎么切换用户账户
macOS怎么切换用户账户

在 macOS 系统中,可通过多种方式切换用户账户。如点击苹果图标选择 “系统偏好设置”,打开 “用户与群组” 进行切换;或启用快速用户切换功能,通过菜单栏或控制中心的账户名称切换;还能使用快捷键 “Control+Command+Q” 锁定屏幕后切换。

363

2025.05.09

磁盘配额是什么
磁盘配额是什么

磁盘配额是计算机中指定磁盘的储存限制,就是管理员可以为用户所能使用的磁盘空间进行配额限制,每一用户只能使用最大配额范围内的磁盘空间。php中文网为大家提供各种磁盘配额相关的内容,教程,供大家免费下载安装。

1584

2023.06.21

如何安装LINUX
如何安装LINUX

本站专题提供如何安装LINUX的相关教程文章,还有相关的下载、课程,大家可以免费体验。

717

2023.06.29

linux find
linux find

find是linux命令,它将档案系统内符合 expression 的档案列出来。可以指要档案的名称、类别、时间、大小、权限等不同资讯的组合,只有完全相符的才会被列出来。find根据下列规则判断 path 和 expression,在命令列上第一个 - ( ) , ! 之前的部分为 path,之后的是 expression。还有指DOS 命令 find,Excel 函数 find等。本站专题提供linux find相关教程文章,还有相关

300

2023.06.30

Python WebSocket实时通信与异步服务开发实践
Python WebSocket实时通信与异步服务开发实践

本专题聚焦 Python 在实时通信场景中的开发实践,系统讲解 WebSocket 协议原理、长连接管理、消息推送机制以及异步服务架构设计。内容包括客户端与服务端通信实现、连接稳定性优化、消息队列集成及高并发处理策略。通过完整案例,帮助开发者构建高效稳定的实时通信系统,适用于聊天应用、实时数据推送等场景。

7

2026.03.18

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
C# 教程
C# 教程

共94课时 | 11.6万人学习

C 教程
C 教程

共75课时 | 5.6万人学习

C++教程
C++教程

共115课时 | 22.5万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号