OSD数据处理链路剖析

osd数据处理链路剖析

针对 topic：thing/product/{device_sn}/osd 这个主题，pilot2 会定期向主题中推送消息，dji-simple 端接收并处理消息。

dji-simple 中集成了SpringIntegration 框架，解耦了消息的处理。需要关注两个 messageChannel ：ChannelName.INBOUND 和 ChannelName.INBOUND_OSD。

整体处理过程：

• 首先mqtt-client会订阅该主题并将消息输出到 INBOUND 频道进行处理。
• InboundMessageRouter 路由在INBOUND频道中有消息的时候将开始工作。
• InboundMessageRouter 路由的工作是将 INBOUND 中的消息转发到 INBOUND_OSD 频道进行处理。
• OsdRouter 路由在 INBOUND_OSD 频道中有消息的时候将开始工作。
• OsdRouter 路由的工作有很多，其中包括：
  • 转换二进制消息为java bean
  • 过滤器做业务逻辑处理
  • 进一步转发到其它的多个频道

mqtt-client会订阅该主题并将消息输出到 INBOUND 频道：

InboundMessageRouter 路由

OsdRouter 路由