情境化定向实时双向推送同步处理系统

摘要

本发明公开了一种情境化定向实时双向推送同步处理系统。在服务器端，将数据库分为累积数据、实时数据和待录缓存三个组；实时数据发生器读取累积数据，进行条件选择、传输排期和目标判断机制后，将当期需要传送的数据编译加密后与其触发器写入实时数据；数据录入模块在检测到待录缓存非空的情况下，对传入的XML数据包进行解析和可信度检测机制，将包内数据应用于数据库的累积数据；传输引擎包括输入终端和输出终端对外界可见；预分析引擎与数据库的实时数据建立连接；客户端的后台亦可采用与服务器端相同的传输引擎设计。本发明可以缓解网络压力并降低服务器的负载要求，弥补现有数据自动化系统的实时性、安全性的不足。

主权项

一种情境化定向实时双向推送同步处理系统，其特征在于：在服务器端，设置一个数据库，将数据库分为累积数据、实时数据和待录缓存三个组，其中，累积数据用于存储既有的数据基础，实时数据用于存储当期准备进行推送的数据与传输计划，待录缓存用于存储已经输入并即将录入累积数据组的数据；设置一个实时数据发生器，实时数据发生器用于读取累积数据，结合系统内部的规则和拓展模块所要求的条件筛选出需要进行传送的数据；在进行传输计划排期和目标判断机制后，将当期需要传送的数据编译为XML格式的数据包，加密后与其触发器写入数据库的实时数据部分；设置一个数据录入模块，数据录入模块在检测到待录缓存非空的情况下，自队列开头解开传入的XML数据包，并对其准确性和可信度进行评估确认；在确认完毕后将包内数据应用于数据库的累积数据部分，同时将回执写入实时数据模块的传输队列，通知该数据包的来源运行结果；设置一个传输引擎，传输引擎包括一个输入终端和一个输出终端对外界可见；设置一个传输缓存，传输缓存包括一个传出缓存和一个传入缓存；设置一个预分析引擎，预分析引擎与数据库的实时数据建立连接；输出时，预分析引擎通过对实时数据中传输触发器进行轮询，结合外部条件确认需要发送的数据包；预分析引擎同时打开准备传输的数据包，确认是否有需要外部数据源转发的信息，启动对应的驱动程序请求外部数据源，并将这些数据一同汇入输出的数据流；传送的数据流根据硬件或操作系统的固有机制进入传出缓存，最后由输出终端负责定向送到指定的目标；输入时，输入终端接收到传送的数据流，数据流根据硬件或操作系统的固有机制进入传入缓存；预分析引擎读入数据头，判断该数据的目标是外部目标还是数据库；如数据属于拓展模块定义的外部目标，将直接转发数据给相应的驱动程序，从而转向送出系统；如数据属于数据库，则将编译好的数据包存入待录缓存。