基金监控平台和管理平台
采用市面常用的技术:springboot、redis、docker 等
项目架构体系:
前端使用 vue + elementui
编排器服务:和前端请求做直接连接
采集器服务:执行每个节点的采集数据任务
聚合器服务:整合每个节点的采集数据是否采集到
分析器服务:通过编写的groovy脚本逻辑和采集器采集到的数据执行,得到想要的结果数据
告警服务: 通过邮件、短信、或电话,发送到指定的通知人员
整体架构逻辑关系:
Browser前端通过https请求到编排器(后端服务),编排器得到参数后通过kafka发送消息到采集器服务去 采集数据, 采集器通过多线程去执行采集数据,数据采集成功后,通过kafka响应到聚合器服务, 聚合服务先把小的采集任务汇总,等到一个节点的所有采集任务都成功采集后,把采集数据发到分析器 服务,节点上的每个采集数据未完整时,都暂放到redis里面。
分析器服务拿到数据后,从mongodb数据库读取 编写的groovy分析逻辑脚本,和采集到的数据一起去整合,如果脚本中有告警通知逻辑,会调用kafka响应告警 服务发出响应的通知消息到指定通知人,告警消息目前有邮件、短信、电话。 分析器执行结束后,把执行结果写入到mongodb数据库,这时候编排器查询mongodb数据库,把刚刚执 行结果响应给前端页面列表数据。 每次节点采集数据时候,编排器先把请求参数发送到kafka后,就执行查询mongodo数据库,查到的数据 去和缓存里的数据比较,如果和缓存里的数据一样,说明数据还是之前的老数据,新的采集数据还没有到达,在 指定时间内还会再去查询,如果这个时间段内查到的数据还是没有发生变化,会先响应请求超时给前端。如果数 据和缓存里的数据不一样,说明是最新的采集数据,响应给前端。