一种大规模事件处理的规则群组系统及处理方法

摘要

本发明是一种大规模事件处理的规则群组系统及处理方法，本发明以提高规则处理效率本发明不采用将事件顺次递交给规则进行判断的传统方式执行，而是采用规则主动索取事件的方式，系统让每条规则都能自行决定自己的判断过程，并且让众多的规则形成不同的群组，每个群组处理事件的负载基本相同，调度模块不仅保证事件能够经过每条规则的判断，同时还将串行化的规则处理过程并行化，极大的提高了规则的处理效率。

主权项

一种大规模事件处理的规则群组系统，该系统属于网络设备集中管理平台，其特征在于：该系统包括：A.规则服务单元(1)，完成与其连接的单元的创建和初始化，并保留这些单元在内存中的地址，以便在撤销这些单元时能够执行相应的从内存中清除指定单元的命令；B.事件缓冲区单元(2)，由规则服务单元(1)对其进行创建和初始化，接收外部系统提供的各种网络事件，事件缓冲区单元(2)采用双向循环队列的结构形式，队列中的每一个节点由一块内存缓冲区构成，每块这样的内存缓冲区都将存放接收到的若干条事件信息；C.规则管理单元(3)，由规则服务单元(1)对其进行创建和初始化，用于从事件缓冲单元(2)中获取事件并交给内部的规则进行判断，对于满足某条逻辑规则的判断，将触发动作响应单元(7)中的指定动作，包括：C1.内存管理单元(4)，由规则管理单元(3)对其进行创建和初始化，用于规则在内存中的存储管理，包括：规则机器人单元(41)，是具体规则在内存管理单元中的表现形式，用于具体的事件逻辑判断；过滤器插件单元(42)，是内存管理单元(4)的功能模块，功能是加载各种过滤判断条件，并以哈希表的方式将各个过滤条件保存在内存中，并提供给规则机器人单元(41)访问；C2.执行群组单元(5)，功能是组织规则判断的负载管理，由规则管理单元(3)对其进行创建和初始化，包括：关联线程组单元(51)，以数组的方式组织于执行群组单元(5)，用于保存不同的规则群组；关联线程执行单元(52)，作为关联线程组单元(51)的数组元素，用于为自身执行单元内的所有规则机器人单元(41)提供事件来源并交给规则机器人单元(41)处理，其中该关联线程执行单元(52)含有被管理的规则机器人单元(41)在内存管理单元(4)中的地址信息，关联线程组单元(51)的元素由分别独立运行的线程组成，每个线程由关联线程执行单元(52)控制；C3.外部访问单元(6)，提供以JMX为标准协议的对外访问接口，调用内存管理单元(4)提供的访问内存中已加载规则的方法，包含加入、变更、删除、获取指定规则、变更规则状态。