开发者社区> 问答> 正文

MQTT连接方式,对于数据的读取,只能通过不停地调用IOT_MQTT_Yield来轮询获取吗?有没有方法通过事件触发的方式来告知有消息来了?IOT_MQTT_Yield会阻塞(block)当前的工作,请问有没有办法可以让IOT_MQTT_Yield尽量不阻塞其他工作?

设备端SDK使用问题 MQTT连接

展开
收起
iot小能手 2018-11-30 13:59:35 7872 0
1 条回答
写回答
取消 提交回答
  • 如果使用的TCPIP协议栈可以实现TCP主动通知上层有数据到达,就有机会进行改动实现事件触发的方式来触发IOT_MQTT_Yield[但是改动比较大,所以还请自行评估是否需要修改]。

     修改的大致流程是:
     utils_net.c里面是socket的对接模块,在这里调整socket的API变成可以由TCP数据到达时回调的API。
     当TCP主动通知上层有数据到达时一路通知到MQTT,让MQTT内部执行IOT_MQTT_Yield,这样就可以不需要外部调用IOT_MQTT_Yield来读取数据了。
     如果TCP无法做到主动上报数据,但OS支持多线程,也可以在MQTT-example里面再起一个thread,在这个thread里面
      while(1) {
          IOT_MQTT_Yiled(pclient, 200);
          HAL_SleepMs(200);
      }
    专门用于接收数据,收到数据时触发主线程进行数据处理,而主线程大部分时间可以用于处理其他逻辑。

    如果使用的系统也不支持多线程,那就只能把IOT_MQTT_Yield的timeout时间间隔减小,然后提高调用的频率,在每次调用的时间间隔内执行其他操作,从而做到尽量减少对其他操作的阻塞。

    2019-07-17 23:17:30
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
基于 RocketMQ+ Knative 驱动云原生 Ser 立即下载
基于 RocketMQ + Knative 驱动云原生 Serverless 应用 立即下载
RocketMQ Operator-K8s平台自动化部署工具 立即下载