一种基于数据转换整合的实时数据处理方法

    公开(公告)号:CN114385728A

    公开(公告)日:2022-04-22

    申请号:CN202111532519.0

    申请日:2021-12-15

    IPC分类号: G06F16/25

    摘要: 本发明公开了一种基于数据转换整合的实时数据处理方法,包括以下步骤:首先确定熟悉所需对接消息中间件的软件特性,制定数据转换整合系统集成此中间件的方案;适配抽取插件和加载插件并且使插件适应流式实时传输处理数据;定制消息确认插件,增加容错能力。本发明为数据转换整合系统提供了一种可行有效的实时数据处理方法;本发明可适配市场上多种不同的消息中间件;本发明提供了消息确认机制,由于异常未被确认的消息可重新消费处理,使用此方法保证了数据的完整性、可靠性。

    一种过SQL代理安全隔离装置的服务穿透方法及系统

    公开(公告)号:CN114422165A

    公开(公告)日:2022-04-29

    申请号:CN202111440386.4

    申请日:2021-11-30

    IPC分类号: H04L9/40

    摘要: 本发明公开了一种过SQL代理安全隔离装置的服务穿透方法及系统,包括1、外网系统发起请求,数据写入请求队列;2、请求队列屏蔽并发,将结构化数据写入网闸支持的中间库;3、后置代理服务批量读取请求数据;4、线程池解析请求数据,创建请求线程,并发对内网数据中台目标服务发起请求;5、请求结果放入响应队列,屏蔽并发,将数据写入中间库;6、前置代理服务单线程高频轮询中间库,批量读取响应数据到MAP;7、请求队列从MAP获取响应数据反馈给外网业务系统。本发明支撑内外网多种服务类型的快捷交互,解决应用间内外网业务服务安全交互问题,实现内外网业务实时交互更好地支撑基于数据中台的内外网服务贯通。