消息策略分发uml

引用

DevicePropertiesReportFactory-属性上报分发工厂类

+ getPropertyMethod(propertyName)

聚合

DeviceEventReport--设备事件上报

+messageHandlingfont color=\"#323232\

实现

DeviceInvokeReply--调用设备功能回复

PushCallback--消息处理类（入口）

- defaultTopic //重连时使用

+ connectionLost()//实现MQTT重连+ deliveryComplete()+ messageArrived()//消息分发

DevicePropertiesReport--属性上报处理

- propertyNames:List=String //属性功能

connectionLost: 当连接丢失触发该方法调用messageArrived: 当消息达到订阅客户端触发该方法调用，该方法被客户端同步调用，并且正常执行完会发送消息确认，如果方法实现抛出异常会导致客户端异常退出deliveryComplete: 当消息投递完成，并且收到所有消息确认，触发该方法调用。具体来说，如果服务质量是QoS0，消息发送到网络即触发方法，如果是QoS1，当收到PUBACK报文即触发方法，如果是QoS2，当收到PUBCOMP报文即触发方法。

DeviceInvokeReply--设备时间同步

DeviceEdgeGatewayData--边缘网关运行数据上报

+messageHandling(PropertiesReportProcessingDto)//边缘网关运行数据上报

MqttCallback--MQTT回调处理接口

TopicService--主题消息处理接口

DeviceDailyDataReply--日冻结数据上报

+messageHandling(PropertiesReportProcessingDto)//日冻结数据上报

DevicePropertiesReportHandle--属性上报处理接口

+ processingData(PropertiesReportProcessingDto)

TopicServiceFactory--Topic分发工厂类

+ getTopicService(topic)