mqttbroker
处理发送缓存
app
报文taskID >=
AC与云2选1
物主动修改自己的关系发布 /cloud/物ID/relation/(bind\\unbind)/订阅更新 /clodu/物ID/realtion/update
2秒定时器
否
是
订阅/xxx/+/UserID/#发布/xxx/UserID/#特殊
状态正常
失败
获取当前状态
发送缓存
订阅/xxx/+/gwsn/#发布/xxx/gwn/#
taskID（最后处理）
成功
订阅/xxx/gwsn/sub/#发布/xxx/gwsn/pub/(x/x) 多个
结束
为空？
关系逻辑在平台数据库订阅所有的物发过来的信息/xxx/+/pub/#通过物与物的绑定关系，查找出相关topic发布信息/xxx/物ID/sub/#
整合数据
订阅 /xxx/userID/sub/#发布/xxx/userId/pub/（x/x） 多个
云转发topic ：/路标/物ID/类型/事件单个物不知道自己的绑定关系，只关心自身。
解析报文
发送
否，防止回复报文反复处理
mqtt接收触发
