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

