实时消息处理

缓存消息

后端推送数据消息格式：{     \"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