当前位置：网站首页>MQTT源码解析

MQTT源码解析

2022-07-21 09:11:00 【L7256】

创建client

MQTTAsync_create //创建client
MQTTAsync_setCallbacks //设置回调函数--收到消息onMesg()/ 发送成功/ 连接断开

接收消息

MQTTAsync_connect
        MQTTAsync_receiveThread //创建接受线程
                MQTTPacket_Factory() //从socket读一个MQTT包
                        MQTTAsync_deliverMessage() //收到包进MQTTAsync_setCallbacks 的回调函数onMesg()

发送消息

MQTTAsync_connect
          Thread_start(MQTTAsync_sendThread, NULL); //创建发送线程
                        MQTTAsync_processCommand //处理消息
                                MQTTProtocol_startPublish-->MQTTPacket_sends

原网站

版权声明
本文为[L7256]所创，转载请带上原文链接，感谢
https://blog.csdn.net/m0_37844072/article/details/125854681