DatasourceDO
assetServer
输入
在监听池创建topic的监听
输出
DatasetDO
UI
依赖
ResultDto
DatasetMapper
实现
返回
LSODriver(服务编排驱动接口)
MessageHandle
DbGetDataDriverImpl
FileGetDataDriverImpl
DataCache
推送
写入缓存
DataConfigCache
DatasetTopicListenPool
TargetDataDTO
SouceDataDTO
DatasetTopicListen
DataSourceServiceImpl
DataConfigRepository(获取配置数据)
MqGetDataDriverImpl
无消息返回上次消息/返回默认配置消息
registerWebsocket:注册对应应用的websocket连接给监听对象
assetService
DataSourceService
DatasourceMapper
GetDataDriver(获取原始数据驱动接口)
DataConfig
MessageCachePool
Controller
ApiGetDataDriverImpl
feign
DataHandle(数据再处理,获取返回值)
Websocket
定时获取消息
DB
请求
获取缓存
assetServiceImpl