You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

为什么libmosquitto的publish回调触发早于connection回调?

现象原因说明
  • 该反直觉的执行顺序是由mosquitto库的异步设计和内部事件处理优先级决定的:
    1. mosquitto_connect为异步调用,返回MOSQ_ERR_SUCCESS仅代表连接请求已发起,不代表MQTT连接已完成握手。此时TCP连接建立、MQTT CONNECT报文交互还在后台进行。
    2. 主线程调用mosquitto_publish时,MQTT连接尚未建立完成,消息会先存入mosquitto客户端的出站缓冲队列,函数直接返回成功,不会阻塞等待消息实际发送。
    3. mosquitto_loop_start启动的后台IO线程的事件处理优先级为:出站消息发送优先级高于连接回调执行:
      • 后台线程收到broker返回的CONNACK连接成功报文后,会先标记连接为可用状态,立即取出缓冲队列中的PUBLISH报文发送
      • 由于你使用的是QoS 0等级消息,publish回调触发时机为客户端成功将消息写入网络套接字发送缓冲区,因此会先打印this is the publish callback
      • 出站队列的待发消息处理完成后,后台线程才会执行注册的连接回调,打印connection success
  • 若要保证执行顺序符合预期,只需将mosquitto_publish逻辑放到connection_callback的连接成功分支中,即可保证先完成连接再发送消息。

内容的提问来源于stack exchange,提问作者fgalan

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.09.30 11:54:04