用于处理一个或多个事件的装置和方法

暂无

用于处理一个或多个事件的装置和方法\n技术领域\n[0001] 本发明涉及用于处理一个或多个事件的装置。\n背景技术\n[0002] 事件是业务应用(business application)中某一活动的出现，该业务应用对于企业中的其他应用是重要的。例如，事件的出现触发另一业务应用中的动作，或者其简单地触发数据移动。\n[0003] 在大的组织中，每天出现成千上万的事件，但是不是所有事件或事件出现具有相等重要性。提供洞察要求确定来自一个或多个源的相关或表面非相关事件的模式何时已经出现，并且协调执行对于事件模式的响应的能力。\n[0004] 复杂事件处理考虑到对于更简单事件流中模式的检测和响应。\n[0005] 下面给出模式的示例：\n[0006] 如果在<时间帧>中事件A和B出现并且事件C未出现，那么在<时间帧>之后进行X、Y和Z\n[0007] 参照图1的复杂事件处理系统(100)，在客户端计算机系统(105)上运行的客户端应用(110)(例如，因特网应用；银行业应用)生成事件。注意，系统(100)可以包括多个客户端计算机系统(105)，并且每个客户端计算机系统(105)可以包括多个可操作来生成事件的客户端应用(110)。\n[0008] 客户端应用(110)调用消息传送API(115)，其将生成的事件作为消息发送到在服务器计算机系统(120)上运行的事件处理器(125)。事件处理器(125)解析事件；针对存储的事件处理逻辑的列表匹配与事件的名称相关联的名称，并且针对在永久存储(135)中存储的包括一个或多个模式的相关联事件处理逻辑，评估接收的事件。如果针对该模式事件评估为真，那么事件处理器(125)生成动作(145)。GUI(140)由用户用于生成和修改事件处理逻辑。当配置对于事件处理逻辑的改变到服务器计算机系统(120)时，规则管理组件(130)可操作来更新永久存储(135)和事件处理器(125)(事件处理器(125)典型地具有可以由规则管理组件(130)调用的方法，使得可以通知事件处理器(125)以更新其存储的与事件名称相关联的事件处理逻辑的列表)。\n[0009] 处理速度和消息传送带宽的许多问题与复杂事件处理系统相关联，减轻这些问题将是有利的。\n发明内容\n[0010] 根据第一方面，提供了一种用于用复杂事件处理系统处理用于使用的一个或多个事件的装置，所述复杂事件处理系统包括服务器计算机系统和可在客户端计算机系统上运行的客户端应用，所述客户端计算机系统可操作来生成一个或多个事件，所述装置包括：规则管理组件，用于分析一个或多个事件的内容，并且分配多个属性到相关联的事件处理逻辑，其中第一属性与可操作来在客户端计算机系统应用的事件处理逻辑相关联，并且第二属性与可操作来在服务器计算机系统应用的事件处理逻辑相关联；事件过滤器组件，响应于接收第一事件，用于使用分配的属性确定相关联的事件处理逻辑是否可操作来在客户端计算机系统应用；其中如果相关联的事件处理逻辑不可操作来在客户端计算机系统应用，则所述事件过滤器组件可操作来将第一事件转发到服务器计算机系统。\n[0011] 根据第二方面，提供了一种用于用复杂事件处理系统处理用于使用的一个或多个事件的方法，所述复杂事件处理系统包括服务器计算机系统和可在客户端计算机系统上运行的客户端应用，所述客户端计算机系统可操作来生成一个或多个事件，所述方法包括：分析一个或多个事件的内容，并且分配多个属性到相关联的事件处理逻辑，其中第一属性与可操作来在客户端计算机系统应用的事件处理逻辑相关联，并且第二属性与可操作来在服务器计算机系统应用的事件处理逻辑相关联；响应于接收第一事件，使用分配的属性确定相关联的事件处理逻辑是否可操作来在客户端计算机系统应用；以及如果相关联的事件处理逻辑不可操作来在客户端计算机系统应用，则将第一事件转发到服务器计算机系统。\n[0012] 根据第三方面，提供了一种计算机程序，其包括当所述程序在计算机上运行时，适于执行上面方法的所有步骤的程序代码装置。\n附图说明\n[0013] 现在参照其优选实施例，仅作为示例将描述本发明，如在以下附图中图示的：\n[0014] 图1是现有技术的复杂事件处理系统的框图；\n[0015] 图2是根据优选实施例的复杂事件处理系统的框图；以及\n[0016] 图3是示出在根据优选实施例的处理中涉及的操作步骤的流程图。\n具体实施方式\n[0017] 所属技术领域的技术人员知道，本发明的各个方面可以实现为系统、方法或计算机程序产品。因此，本发明的各个方面可以具体实现为以下形式，即：完全的硬件实施方式、完全的软件实施方式(包括固件、驻留软件、微代码等)，或硬件和软件方面结合的实施方式，这里可以统称为“电路”、“模块”或“系统”。此外，在一些实施例中，本发明的各个方面还可以实现为在一个或多个计算机可读介质中的计算机程序产品的形式，该计算机可读介质中包含计算机可读的程序代码。\n[0018] 可以采用一个或多个计算机可读介质的任意组合。计算机可读介质可以是计算机可读信号介质或者计算机可读存储介质。计算机可读存储介质例如可以是——但不限于——电、磁、光、电磁、红外线、或半导体的系统、装置或器件，或者任意以上的组合。计算机可读存储介质的更具体的例子(非穷举的列表)包括：具有一个或多个导线的电连接、便携式计算机盘、硬盘、随机存取存储器(RAM)、只读存储器(ROM)、可擦式可编程只读存储器(EPROM或闪存)、光纤、便携式紧凑盘只读存储器(CD-ROM)、光存储器件、磁存储器件、或者上述的任意合适的组合。在本文件中，计算机可读存储介质可以是任何包含或存储程序的有形介质，该程序可以被指令执行系统、装置或者器件使用或者与其结合使用。\n[0019] 计算机可读的信号介质可以包括在基带中或者作为载波一部分传播的数据信号，其中承载了计算机可读的程序代码。这种传播的数据信号可以采用多种形式，包括——但不限于——电磁信号、光信号或上述的任意合适的组合。计算机可读的信号介质还可以是计算机可读存储介质以外的任何计算机可读介质，该计算机可读介质可以发送、传播或者传输用于由指令执行系统、装置或者器件使用或者与其结合使用的程序。\n[0020] 计算机可读介质上包含的程序代码可以用任何适当的介质传输，包括——但不限于——无线、有线、光缆、RF等等，或者上述的任意合适的组合。\n[0021] 可以以一种或多种程序设计语言的任意组合来编写用于执行本发明操作的计算机程序代码，所述程序设计语言包括面向对象的程序设计语言—诸如Java、Smalltalk、C++等，还包括常规的过程式程序设计语言—诸如“C”语言或类似的程序设计语言。程序代码可以完全地在用户计算机上执行、部分地在用户计算机上执行、作为一个独立的软件包执行、部分在用户计算机上部分在远程计算机上执行、或者完全在远程计算机或服务器上执行。\n在涉及远程计算机的情形中，远程计算机可以通过任意种类的网络——包括局域网(LAN)或广域网(WAN)—连接到用户计算机，或者，可以连接到外部计算机(例如利用因特网服务提供商来通过因特网连接)。\n[0022] 下面将参照根据本发明实施例的方法、装置(系统)和计算机程序产品的流程图和/或框图描述本发明。应当理解，流程图和/或框图的每个方框以及流程图和/或框图中各方框的组合，都可以由计算机程序指令实现。这些计算机程序指令可以提供给通用计算机、专用计算机或其它可编程数据处理装置的处理器，从而生产出一种机器，使得这些计算机程序指令在通过计算机或其它可编程数据处理装置的处理器执行时，产生了实现流程图和/或框图中的一个或多个方框中规定的功能/动作的装置。\n[0023] 也可以把这些计算机程序指令存储在计算机可读介质中，这些指令使得计算机、其它可编程数据处理装置、或其他设备以特定方式工作，从而，存储在计算机可读介质中的指令就产生出包括实现流程图和/或框图中的一个或多个方框中规定的功能/动作的指令的制造品(article of manufacture)。\n[0024] 计算机程序产品也可以加载到计算机、其他可编程数据处理装置或其他设备上，以使得在计算机、其他可编程数据处理装置或其他设备上执行一系列操作步骤，以便产生计算机实施的处理，使得在计算机或其他可编程装置上运行的指令提供用于实施在流程图和/或框图块或各块中指定的功能/动作的处理。\n[0025] 附图中的流程图和框图显示了根据本发明的多个实施例的系统、方法和计算机程序产品的可能实现的体系架构、功能和操作。在这点上，流程图或框图中的每个方框可以代表一个模块、程序段或代码的一部分，所述模块、程序段或代码的一部分包含一个或多个用于实现规定的逻辑功能的可执行指令。也应当注意，在有些作为替换的实现中，方框中所标注的功能也可以以不同于附图中所标注的顺序发生。例如，两个连续的方框实际上可以基本并行地执行，它们有时也可以按相反的顺序执行，这依所涉及的功能而定。也要注意的是，框图和/或流程图中的每个方框、以及框图和/或流程图中的方框的组合，可以用执行规定的功能或动作的专用的基于硬件的系统来实现，或者可以用专用硬件与计算机指令的组合来实现。\n[0026] 应该注意，由于通过驻留在服务器计算机系统上的应用评估事件处理逻辑，复杂事件处理系统典型地基于服务器。对于特定类型的事件相关，例如完全需要给定示例模式，例如“如果顾客在一天中进行三个够买，则触发动作”，并且给定可以从多个不同源接收事件，需要在中心位置(例如，通过服务器计算机系统)执行这样的相关，由于个别客户端计算机系统不知道由相互生成的事件。\n[0027] 性能在复杂事件处理系统中是关键的，其中每秒成千上万事件的吞吐量是普遍的，基于服务器的处理可能产生瓶颈。\n[0028] 根据优选实施例，不是仅仅在服务器计算机系统执行事件处理，而是不要求跨越多个、不同事件的跨事件相关的任何简单事件处理可以在客户端计算机系统执行。有利地，在大量事件可以至少部分在客户端计算机系统执行的场景中实现显著的性能优势。\n[0029] 在图2中描绘根据优选实施例的复杂事件处理系统(200)。系统(200)包括在客户端计算机系统(205)上运行的客户端应用(210)；可操作来与存储组件中存储的客户端侧事件处理逻辑(例如，客户端侧库)交互的事件过滤器组件(212)；以及过滤器管理器(214)。\n[0030] 系统(200)还包括具有事件处理器(225)的服务器计算机系统(220)以及规则管理组件(230)。用户使用GUI(240)来操纵规则管理组件(230)。服务器侧事件处理逻辑存储在永久存储(235)中，永久存储(235)也可操作来存储至少一个事件的至少一个出现。\n[0031] 事件过滤器组件(212)提供可以由客户端应用(210)调用的API。事件过滤器组件(212)可以接受表现为例如事件对象(其中事件对象是以给定编程语言的事件的表现)或事件分组(例如，例如以XML写的事件的文本表现)的来自客户端应用的事件。事件过滤器组件(212)可操作来使用消息传送API发送事件到服务器计算机系统(220)，然而，调用客户端应用(210)不需要知道底层的消息传送基础设施，并且简单地进行对于事件过滤器组件(212)的调用。事件过滤器组件(212)配置有事件处理器(225)的定位。\n[0032] 事件过滤器组件(212)包括可以由过滤器管理器(214)调用的方法，使得事件过滤器组件(212)可以被通知以更新其与事件名称相关联的事件处理逻辑的存储列表。事件方法(例如，updateLogic(Listlogic){})是特定实施，然而，功能上方法可操作来接收更新的服务器侧事件处理逻辑，并且当随后被调用时使用更新的逻辑。\n[0033] 过滤器管理器(214)负责保持客户端侧事件处理逻辑(213)最新。当客户端应用(210)初始化时，过滤器管理器(214)用规则管理组件(230)登记自身，并且提供与自身相关联的的回调细节，使得过滤器管理器(214)可以从服务器计算机系统(220)接收更新的服务器侧事件处理逻辑。\n[0034] 在一个实施例中，示例回调细节包括主机名称和规则管理组件(230)使用以便在消息中发送更新的服务器侧事件处理逻辑到过滤器管理器(214)的端口号，过滤器管理器(214)侦听该端口以便接收消息。\n[0035] 在另一实施例中，过滤器管理器(214)从服务器计算机系统(220)输出包括服务器侧事件处理逻辑的静态库，并且手动地(也就是说，通过在每个客户端计算机系统重新部署静态库)执行对于服务器侧事件处理逻辑的任何更新。\n[0036] 现在将参照图3描述根据优选实施例的处理。\n[0037] 在步骤300，客户端应用(210)生成事件，并且调用事件过滤器组件(212)以便发送生成的事件。示例调用包括sendEvent(流消息)，由此流消息表示事件的内容。\n[0038] 响应于接收事件，事件过滤器组件(212)解析事件以便获得事件名称，并且针对事件处理逻辑的列表比对事件名称。如果事件名称对于事件过滤器组件(212)未知，那么这意味着不存在与该事件相关联的关联事件处理逻辑，并且因此对于该事件不需要生成动作，在此情况下，事件过滤器组件(212)丢弃该事件。\n[0039] 如果事件名称对于事件过滤器组件(212)已知，那么在步骤305，事件过滤器组件(212)确定是否存在任何要应用的客户端侧事件处理逻辑(213)。如果事件过滤器组件(212)确定不存在要应用的客户端侧事件处理逻辑(213)(例如，因为该事件不匹配任何与客户端侧事件处理逻辑(213)相关联的模式)，那么事件过滤器组件(212)将事件转发(步骤\n315)到事件处理器(225)。\n[0040] 如果事件名称对于事件过滤器组件(212)已知，并且如果在步骤305，事件过滤器组件(212)确定存在要应用的客户端侧事件处理逻辑(213)，那么事件过滤器组件(212)将客户端侧事件处理逻辑(213)应用(步骤310)到与事件相关联的一个或多个字段。在应用期间，事件过滤器组件(212)应用相对简单的子模式到该事件，将参照工作示例更详细描述该步骤。\n[0041] 在步骤320，如果事件过滤器组件(212)确定不满足由一个或多个模式限定的标准，那么事件过滤器组件(212)丢弃该事件，并且不要求进一步的动作(步骤325)。\n[0042] 在步骤320，如果在针对事件的客户端侧事件处理逻辑(213)的评估期间，事件过滤器组件(212)确定满足由与客户端侧事件处理逻辑(213)相关联的一个或多个模式限定的标准，那么事件过滤器组件(212)将事件转发(步骤315)到事件处理器(225)。\n[0043] 在步骤330，事件处理器(225)通过应用剩余的相对复杂子模式到事件，针对服务器侧事件处理逻辑评估事件，将参照工作示例更详细地描述该步骤。\n[0044] 在步骤345，如果在针对事件的服务器侧事件处理逻辑(213)的评估期间，事件处理器(225)确定满足由与服务器侧事件处理逻辑(213)相关联的一个或多个模式限定的标准，那么事件处理器(225)生成(步骤340)动作。\n[0045] 在步骤345，如果事件处理器(225)确定不满足由一个或多个模式限定的标准，那么事件处理器(225)丢弃该事件并且不要求进一步动作(步骤350)。\n[0046] 现在将参照图3描述第一工作示例。\n[0047] 在步骤300，客户端应用(210)响应于顾客进行10英镑的够买生成事件。\n[0048] 下面示出事件的示例：\n[0049] Event_1\n[0050]\n[0051]\n[0052] 客户端应用(105)将该事件传递到事件过滤器组件(212)，事件过滤器组件(212)解析该事件以获得事件名称(例如，PurchaseEvent)\n[0053] 在第一示例中，事件名称对于事件过滤器组件(212)已知，并且在步骤305，事件过滤器组件(212)针对相关联的事件处理逻辑的列表比较事件名称。下面示出包括事件名称和相关联逻辑的列表的示例：\n[0054] 列表:\n[0055]\n[0056] 参照上面的列表，当配置与事件名称相关联的逻辑时，规则管理组件(230)分析逻辑的内容并且分配属性，规则管理组件(230)分配“简单”属性给应该由事件过滤器(212)处理的逻辑，并且分配“复杂”属性给应该由事件处理器(225)处理的逻辑。\n[0057] 在示例中，当与逻辑(例如，If field(amount)>100then largePurchaseEvent)相关联的参数(例如，field(amount))包含在事件(例如，Event_1)本身中时，由于事件过滤器(212)已经知道事件的内容，所以可以由事件过滤器(212)执行这样的处理，规则管理组件(230)可操作来分配“简单”属性。\n[0058] 在示例中，与由一个或多个客户端应用生成的逻辑(例如，If(occurrences of this  Event in 1  day)then WarningAction)相关联的事件的出现数目(例如，occurrences of this Event in 1 day)需要被计数时，规则管理组件(230)可操作来分配“复杂”属性。这样的处理典型地需要由服务器计算机系统(220)的事件处理器(225)执行，因为客户端计算机系统(205)典型地不知道由其他客户端计算机系统生成的事件。\n[0059] 下面示出与purchaseEvent和largePurchaseEvent相关联的模式的示例。\n[0060] 模式1：\n[0061] 目标：“如果顾客在一天中进行3次超过100英镑的购买，则触发警告动作”[0062] 规则：\n[0063] 规则1：如果“amount”字段中购买事件>100英镑，则激起“大购买事件”。\n[0064] 规则2：如果一天中存在3个“大购买事件”的出现，则触发警告动作。\n[0065] 响应于事件名称(即，PurchaseEvent)针对相关联的事件处理逻辑的比较，事件过滤器组件(212)确定由于PurchaseEvent具有“简单”属性，所以存在要应用的客户端侧事件处理逻辑(213)。\n[0066] 事件过滤器组件(212)应用(步骤310)客户端侧事件处理逻辑(213)到与事件相关联的一个或多个字段。更具体地，事件过滤器组件(212)针对规则1(具体地，针对值100)比较Event_1的“amount type＝"Real">”字段中的值。\n[0067] 在第一示例中，在步骤320，事件过滤器组件(212)确定不满足由一个或多个模式限定的标准(即，规则1)，并且事件过滤器组件(212)丢弃该事件并且不要求进一步的动作(步骤325)。\n[0068] 现在将参照图3描述第二工作示例。\n[0069] 在步骤300，客户端应用(210)响应于顾客进行110英镑的够买生成事件。\n[0070] 下面示出事件的示例：\n[0071] Event_2\n[0072]\n[0073] 客户端应用(210)将该事件传递到事件过滤器组件(212)，事件过滤器组件(212)解析该事件以获得事件名称(例如，PurchaseEvent)。\n[0074] 在该示例中，事件名称对于事件过滤器组件(212)已知，并且在步骤305，事件过滤器组件(212)针对相关联的事件处理逻辑的上面列表比较事件名称。上面示出与客户端侧事件处理逻辑(213)相关联的模式示例，即，模式1。\n[0075] 响应于事件名称(即，PurchaseEvent)针对相关联的事件处理逻辑的比较，事件过滤器组件(212)确定由于PurchaseEvent具有“简单”属性，所以存在要应用的客户端侧事件处理逻辑(213)。\n[0076] 事件过滤器组件(212)应用(步骤310)客户端侧事件处理逻辑(213)到与事件相关联的一个或多个字段。更具体地，事件过滤器组件(212)针对规则1(具体地，针对值100)比较Event_2的“amount type＝"Real">”字段中的值。\n[0077] 在该示例中，在步骤320，事件过滤器组件(212)确定满足由一个或多个模式限定的标准(即，规则1)，并且事件过滤器组件(212)根据规则1生成并且转发(步骤315)“大购买事件”到事件处理器(225)。\n[0078] 下面示出事件的示例：\n[0079] Event_3\n[0080]\n[0081] 在步骤330，事件处理器(225)针对上面相关联的事件处理逻辑的列表比较事件名称。\n[0082] 响应于事件名称(即，LargePurchaseEvent)针对相关联事件处理逻辑的比较，事件处理器(225)确定由于LargePurchaseEvent具有“复杂”属性，所以存在要应用的服务器侧事件处理逻辑。\n[0083] 更具体地，在评估期间，事件处理器(225)访问永久存储(235)以便确定之前已经出现多少事件的出现。由于这是事件的第一出现，在步骤345，如果事件处理器(225)确定不满足由一个或多个模式限定的标准(即，规则2)，并且事件处理器(225)丢弃该事件并且不要求进一步的动作(步骤350)。事件处理器(225)将事件的第一出现存储在永久存储(235)中。\n[0084] 如果LargePurchaseEvent进一步出现两次，则根据规则2，在步骤345，事件处理器(225)确定满足由与服务器侧事件处理逻辑(213)相关联的一个或多个模式限定的标准(即，规则2)，并且事件处理器(225)生成(步骤340)可以以编程方式或由用户使用GUI(240)访问的警告动作。\n[0085] 下面示出该动作的示例。\n[0086] Action_1\n[0087]\n[0088] 根据本发明，用户可以修改服务器侧事件处理逻辑。在示例中，用户使用GUI来修改服务器侧事件处理逻辑，使得针对模式仅仅超过200英镑的事件评估为真。用户使用GUI(240)来操纵规则管理组件(230)，以便修改服务器侧事件处理逻辑。\n[0089] 下面示出修改的服务器侧事件处理逻辑的示例：\n[0090] 模式2：\n[0091] 目标：“如果顾客在一天中进行3次超过200英镑的购买，则触发警告动作”[0092] 规则：\n[0093] 规则1：如果“amount”字段中购买事件>200英镑，则激起“大购买事件”。\n[0094] 规则2：如果一天中存在3个“大购买事件”的出现，则触发警告动作。\n[0095] 规则管理组件(230)通过使用过滤器管理器(214)之前登记的回调进行对于过滤器管理器(214)的调用，用新的服务器侧事件处理逻辑更新过滤器管理器(214)。过滤器管理器(214)调用与事件过滤器组件(212)相关联的方法，以便通知它更新它的存储的与事件名称相关联的事件处理逻辑的列表。随后，大于200英镑的购买事件针对Pattern_2评估为真。\n[0096] 下面示出事件处理逻辑的更新列表：\n[0097] 列表：\n[0098]\n[0099] 本发明允许使用客户端侧库和API的事件过滤。如果不能由客户端计算机系统应用客户端侧事件处理逻辑，则事件仅需要发送到服务器计算系统。此外，如果满足逻辑标准(可替代地，如果满足逻辑标准并且如果不存在要由服务器计算系统应用的进一步逻辑)，则事件仅需要发送到服务器计算系统，客户端计算机系统不采取进一步动作。\n[0100] 本发明还提供更新与客户端侧库相关联的客户端侧事件处理逻辑的能力，以便保持客户端侧事件处理逻辑与服务器侧事件处理逻辑一致。\n[0101] 有利地，如果存在大量事件，从而简单逻辑可以在客户端计算机系统应用于事件，这具有显著的性能优点，由于与使用消息传送API发送事件使得服务器计算机系统可以处理事件的成本相比，该应用非常便宜。本发明具有要求减少CPU循环并且减少对于消息传送系统上的负载的技术优势，消息传送系统上的负载可能是复杂事件处理系统中的瓶颈。转而，有利地，相对于要求运行复杂事件处理系统和相关联的消息传送主干网的硬件，可以减少顾客的成本开销。