Hose基于规则的数据推送系统及方法

摘要

本发明公开了Hose基于规则的数据推送系统及方法，所述系统包括权威库、服务器及目标库，在所述服务器内设置有驱动引擎、监听器及多个连接器，在所述驱动引擎内设置有驱动管理器、驱动引擎日志记录器及多个驱动，在所述驱动内按数据处理流程顺序设置有过滤器、规则库、处理器及日志记录器；方法包括：监听器监听数据推送请求，驱动引擎接收从连接器发送过来的数据推送请求，查询驱动引擎中所有可用的驱动，依次调用驱动处理数据推送请求；驱动处理请求；过滤器处理请求；在服务器中，设置多个连接器和一个驱动引擎，在驱动中插入过滤器、规则库、处理器和日志加料器等，并将驱动中的对象进行有序的组合，以便处理数据推送请求。

主权项

Hose基于规则的数据推送系统，包括权威库、服务器及目标库，其特征在于：在所述服务器内设置有驱动引擎、监听器及多个连接器，所述连接器与驱动引擎相连接；在所述驱动引擎内设置有驱动管理器、驱动引擎日志记录器及多个驱动，所述连接器与驱动相连接，在所述驱动内按数据处理流程顺序设置有过滤器、规则库、处理器及日志记录器；所述服务器为一个运行的Hose系统；所述驱动引擎，通过驱动管理器，管理所述驱动的生命周期，进行驱动创建、删除、变更、启动及关闭操作；所述驱动引擎日志记录器，记录包括对驱动本身新增、删除、变更、启动及关闭的操作记录；所述驱动管理器，一种可视化的对驱动进行管理的工具；所述驱动，处理权威库与目标库的数据推送分发，支持多驱动，多权威库和多目标库；所述过滤器，将所述驱动不需要推送的数据过滤掉，对推送的数据进行精确的控制；所述规则库，对推送的数据进行控制，执行额外的业务逻辑；并针对不同的驱动和推送要求进行灵活配置规则；所述处理器，根据目标库的不同分别对应不同的处理器，设置有JDBC处理器、LDAP处理器及WebService处理器；所述日志记录器，将数据推送过程中产生的数据审计记录到文件中；所述连接器，为服务器的入口，包括基于TCP/IP的连接器、基于HTTP协议的连接器、基于JMS消息的连接器、基于内存的连接器；所述监听器，监听通过不同渠道发送过来的数据推送请求，是权威库与Hose数据推送集成通信的入口，根据权威库的技术异构，相关限制，提供与之对应的监听器对象，方便集成，并采用TCP/IP技术或HTTP技术或JMS技术将监听到的数据推送请求通过连接器引入服务器内。