缓存消息
后端推送数据消息格式：{ \"datasetId\":\"xx\
MQ
过滤消息
消息编排
异步
实时消息
消息缓存池
消息缓存池：1、每个数据接口缓存一条消息数据2、第一次无数据时缓存默认配置数据
消息处理器：1、定时从消息缓存池获取消息2、websocketlist2、生成消息对象（处理消息格式包含编排/相同消息跳过不处理） 消息对象： 1、原消息格式 2、过滤参数 2、处理后的消息格式 3、已推送过的websocket3、推送消息数据到前端
前端：1、图表接入接口时，配置启用实时数据2、调用get-result-by-datasource接口时多传一个获取需要接入实时数据的参数标志3、维护一个接入实时数据的 接口id+params 与 图表组件 的关系4、收到消息指定接口加参数的消息，更新对应的图表数据
前端
处理消息格式
topic监听：1、每个数据接口使用连接池创建一个监听2、paramsList2、绑定一个消息处理器对象3、将websocket对象注册给消息处理器
推送消息
UI
topic监听收到消息
后端
定时拉去消息
返回一条缓存消息或默认配置消息
MQ标准格式： { \"type\": \"xx类型设备\" \"id\": \"设备唯一值\
消息队列
前端发送ping消息格式：{ \"token\":\"xxx\
生产者
IOT平台
get-result-by-datasource
