CN1220018A - 分布式目标系统中事件的收集 - Google Patents

Abstract

一分布式目标系统包含接收系统中目标的生成、删除和启动的信息的事件收集机构(14)。事件收集机构将所收集的事件传送到用户应用程序在其注册的事件调度机构(16)。事件调度机构按照用户所选择的判别准则将事件的细节送往用户程序。提供一种将所有被报告的事件联接回到最终承担它们的生成的目标的方法。

Description

分布式目标系统中事件的收集

本发明涉及一种分布式目标系统中的事件的收集。

分布计算是一种计算领域，其中在物理上分开的计算节点上运行的各别软件模块能互相通信，并能互相请求执行任务。近年来面向目标的技术的发展给予分布计算极大的推动，而这两种技术的会聚则产生了分布式目标技术。

由于这些目标的数量和复杂性增加而出现准确地认定这样的系统中正在发生的情况的问题。虽然有许多软件支援工具可供系统设计人员和维护人员应用，但它们目前多半不能令人满意。现今有各种不同工具，例如可用于调试一般的“单处理”软件，使开发人员能逐步通过软件中的编码且能检验程序状态。还有一、二种可应用于面向目标编程的工具，通过展示目标的生成和删除使得程序员能“目测”一般软件中的目标。

但由于这些一般性的工具实际上对大型分布式目标系统设计人员和维护人员的需要不够有效和灵活而存在许多困难。

按照本发明的第一个方面提出一种具有多个目标的分布式目标系统，各目标具有一相关的过滤器，此过滤器被配置来截取由其对应目标发送或接收的消息并将表述所述消息的信息送往一事件收集器。

本发明还延伸到一对应的方法，具体说是延伸到本发明的第二个方面的用于使具有多个目标的分布式目标系统具有特征的方法，此方法包括为各目标设置一相关的过滤器，其被配置来截取由其对应目标发送或接收的消息并将表述所述消息的信息送到一事件收集器，此分布式目标系统则按此事件收集器所接收的消息作为特征。

由事件收集器收集的消息可以表述一预定的事件类别，例如目标间的交互作用和目标的删除及生成的类别。最好，事件收集器可将所收集的事件送到一事件调度机构，其处理这些事件并将它们送往一或多个用户程序。这些用户程序可有多种不同形式，包括：显象应用程序、故障检测应用程序、控制应用程序和计费应用程序。在一优选实施例中，数个不同的用户应用程序(目标)可同时运时，而各自可独立地加以配置。根据具体要求此配置可以是自动的或用户定义的。

在一种形式中，本发明可提供一种用于生成一事件流的机制，其中各事件或者为由从一目标传送消息到另一目标或者由生成或删除一目标构成。此系统的安装可以不对目标本身的程序代码作硬性改变。而且可以由不只一个个体在任何时刻观测系统中的交互作用，而使得每一个体仅能看到有关的动作。

另一方面，在另一实施例中此系统可提供一分布式目标系统内的故障通报和/或故障恢复服务。

从而此系统提供能定义明确地在一分布式目标系统中由各不同目标收集信息的一个或一系列工具。而后被这样收集的信息即可被用来对系统进行分析以便例如确定系统出错或其他意外事件期间所发生的情况。同样重要的是，被收集的信息可被用来协助正在向其他未直接涉及到开发的人们解释此系统的设计人员。一般，分布式目标系统是极其准以解释的，而本发明在至少某些形式中会改善这种由开发人员和设计人员到技术合作者和用户的“信息移交”处理。

本发明可以以多种方法实施，现在参照附图举例说明实现本发明的一特定分布式目标系统，所列附图为：

图1说明一分布处理环境中的远程过程调用；

图2表示按照本发明优选实施例的系统的概观；

图3表明过滤器被用来截取被发送和接收的消息的方法；

图4说明过滤器的操作；

图5表示交互作用如何在目标之间传播；

图6表示带有关键字的消息如何在目标间发送；

图7与图6相对应，但表示与一附加目标的相互作用；

图8表示优选显象应用程序如何以事件调度机构注册；

图9表示事件调度机构将信息送往显象应用程序；

图1O表示由此优选显象应用程序摄取的示范性屏幕；

图11表示对可与本发明相关连应用的分布处理环境(DPE)的一示范性结构；和

图12表示为本发明实施例应用的一平台的硬件视图。

在描述本发明的优选实施例之前，对分布处理环境(DPE)概括地说明某些普遍的背景信息可能是有用的。

大量的DPE遵守被称为“公用目标请求代理体系结构(CORBA)”的实际上的标准。此CORBA标准是由目标管理小组(OMG)建立的，它是一包括大量计算机公司、软件销售商和其他有关方面的国际联合组织。

大部分DPE采用一种称为远程过程呼叫(RPC)类型的交互作用，概括地在图1中表明。在RPC模型中，客户机目标10发送消息11到远程服务器目标，请求一具体操作。服务器目标12执行对应于这一操作的程序码，然后借助应答消息13将控制返回到客户机10。一般，输出消息11包含要调用的操作的名称以及对此操作的自变量，而应答消息则包含被调用的操作的名称以及此操作的结果。

具有其他交互作用形式，但大多数可被认为是由通常的RPC模型得出的。例如，一种CORBA中所用的替换交互作用形式是“单向”形式。在此模式中，调用一操作的消息被发送给服务器目标，但在此期间客户机继续执行其自身的程序代码。当服务器目标完成相应操作的执行时，不发送回任何消息。这可以被简单地视作一个没有结果及没有从服务器目标发回给客户机目标的确认的普通RPC。

现在转到图2，这里表明本发明优选实施例的概况。此示范性系统由三个主要子系统实现。第一子系统14为事件收集机构，涉及因目标的生成和删除及它们间的交互作用所产生的事件的收集。如由图中可看到的，事件收集机构由数个可在计算环境中相隔很远的分布式目标2、4接收信息。例如，一个目标可在一实在的计算机上运行，而另一个在通过普通的局域网或者甚至一广域网连接到第一计算机的另一实在的计算上运行。第二子系统18采取显象应用程序形式，使系统用户能观察交互作用，配置他们观察交互作用的方法，和确定要观察的交互作用。一次可运行数个显象应用程序18a、18b、18c。第三和最后子系统包括事件调度机构16，它由收集机构14取出事件流，并将它分配给各显象应用程序18a、18b、18c。自然可以理解，事件收集机构14、事件调度机构16和显象应用程序18全都可被看作是它们自己方面的目标。

图3较详细地表明各目标与事件收集机构14间的交互作用。为便于对照，用于与RPC模型对应的那些部件的标号对应于图1中所用的号码。可看到，事件收集器14收集由各自与客户机目标10和服务器目标12相关连的过滤器20、22传送的事件26、28。过滤器本身可以包括现在CORBA中的相应产品Orbix。Orbix是由Iona Technologies提供的商业软件产品。这使得能插入将在消息到达、调度、应答和返回(目标交互作用)期间运行的软件。因而，事件收集器14收集关于由一目标到另一目标传送消息(也就是由一个目标对另一目标实行一操作)或一目标的生成或删除的信息。过滤器这样来与目标相连系，即它们截取所发送和接收的消息而不要求目标自身作任何改变。

图4说明实践中系统的操作。图4a表示目标A提出对目标B的请求之前的情况。图4b表示提出请求时的情况。过滤器A截取输出信息11，而一报告消息30被传送到事件收集机构。当然应理解，在生成或删除一目标时也将生成或删除对应的过滤器，由此使得也能对之生成一事件。事件收集机构同时由系统内的所有活动目标收集事件。

被事件收集机构14收集的所有事件以连续流的形式被传送到事件调度机构16(图2)。自然，收集关于在目标间传送的每一个消息和关于一目标的生成和删除的信息很可能导致信息过载。一般，用户可能仅对特定的目标或特定的目标类别所发生的情况感兴趣，因此最需要的是能取得某种所感兴趣事件的方法。现在来叙述实现这一点的途径。

首先应指出的是，在一分布式目标系统中，当系统中一目标与另一个交互作用时，能可靠地保证另外的“撞击”交互作用。这在图5中说明，其中，目标32、34间的一交互作用产生了与另外的目标36、38的“撞击”交互作用。在此优选实施例中提供一种机制由其能将随后发生的“撞击”交互作用连接回到激发它们的原先的交互作用。

参照图6可了解达到这一点的途径。系统中的各个目标均被给予专用关键字即标识符，此关键字被与各自的过滤器相关联地存储。这样，如果一目标(例如目标A)请求另一目标(目标B)的服务，目标A的关键字即被传递给目标B，后者承接这一关键字直到它结束对目标A的请求的服务。然后它舍弃目标A的关键字，再回复到它自己的关键字。

图6a说明在目标A提出对目标B的请求之前的情况。将可看到，与目标A相关的过滤器20含有一专用关键字A，而与目标B相关的过滤器22含有专用关键字B。

图6b表示在目标A对目标B提出请求时的情况。在目标A与目标B之间传送一输出消息11，此消息如前述被过滤器20所截取，后者生成一报告消息30。过滤器20将自己的关键字A附着到消息11，并将其传送给当前含有关键字B的接收过滤器22。当含关键字A的消息到达时，过滤器22承接关键字A来代替它的原始关键字，并将消息其余部分传送给目标B。

图6c表明当目标B对此请求进行服务期间的情况。将会看到，目标B的过滤器22现在承接关键字A。

图6d表明当目标B完成此请求和送回一应答消息给目标A时发生的情况。在此消息被发送时，目标B的过滤器22接回它的原始关键字B。应答消息被过滤器20接收和被传送到目标A。同时过滤器20生成再一个报告消息30′，其被传送到事件收集机构14(图2)。

这样，所有作为由目标A发送到目标B的起始交互作用的结果发生的事件即能经由关键字A与目标A相关联。事件收集机构明白所有被报告的事件均发自目标A，因为报告消息30、30′两者均在其内包含关键字A。

图7中可看到一稍许复杂的情况，其中目标B接着调用第三目标即目标C的服务。

图7a表示目标A对目标B提出请求前的情况。

图7b表示在提出请求期间的情况。包含关键字A的报告消息44被送到事件收集机构，通知它该提出的请求。

图7c表示在目标B对目标A的请求服务期间的情况。将注意到，目标B的过滤器22承接了关键字A。

图7d表示在控制返回到目标A之前、目标B需要对另一目标40(目标C)提出请求时所发生的情况。目标C具有其此时含关键字C的自己的过滤器42。过滤器22截取此消息并将它自己的当前为关键字A的关键字附加到此消息上。它还提供另一个报告消息46给事件收集机构，该消息本身含有关键字A指明此起始相互作用发自目标A。

图7e表示目标C进行对来自目标B的请求的服务期间的情况。目标B的过滤器22含有关键字A，如现在目标C的过滤器42那样。

图7f说明由目标C向目标B发送回应答。一旦发送了此应答，过滤器42即废除关键字A并恢复到它的原始关键字即关键字C。过滤器22截取应答消息并发送另一报告消息48到事件收集机构。该消息仍含有关键字A，因为它发自当前含有该特定关键字的过滤器22。

最后，图7g表示当目标B完成其请求并返回控制到目标A时所发生的情况。应答消息被由目标B发送回目标A，目标B的过滤器22重新具有其原始关键字B。在接收到此应答消息后，目标A的过滤器20发送出又一另外消息到事件收集机构。此消息将再次含有关键字A，因为这是当前与过滤器20相关连的关键字。

因此将看到，关键字由一目标到下一目标的传递是依靠在发送过滤器将其附加到此消息和在接收过滤器将其由此消息去除来进行的。

利用这种机制，现在就可能选择特定的事件或事件类别来作进一步分析。例如，假如一系统用户希望观察作为由目标A发出的交互作的结果而发生的整个事件序列，他所需做的将是仅仅选择那些具有与之相关连的相应关键字即关键字A的事件。

现在参照图8和9给出有关事件调度机构及其与显象应用程序的关系的进一步的细节。

在事件被事件收集机构所收集时，它们被送往事件调度机构16。事件调度机构接收由事件收集机构14所收集的所有事件的细节，并被配置来将那些用户感兴趣的特定事件送到显象应用程序18。

如在图8中可看到的，事件调度机构16在其内部结合有一称之为事件调度程序因子52的目标，用于生成进一步的称之为事件调度程序的目标54。各个事件调度程序用于发送事件到一特定的显象应用程序。希望观察一特定的事件子集的用户运行显象应用程序目标18，而后此目标将如数码56所指明的在事件调度机构16注册。

如图9中所示，显象应用程序18的数个个别实例(目标)在实践中可同时运行，其中每一个均在事件调度机构16作了注册。每次注册，事件调度程序单元52生成一新的事件调度程序目标54，其将如58所指明的信息送到其对应的显象应用程序。各显象应用程序18可作不同配置，并可以请求关于已被事件收集机构14收集的(或正被收集的)事件的不同子集的信息。由各事件调度程序54执行必要的过滤，使仅具有已由其各个显象应用程序请求的信息通过。

显象应用程序18可取具有各种不同前端的许多形式，优选方案在图10中有原理性说明。显象应用程序的用户观察在一大窗口60中图形显示的信息。在此窗口的一工作空间62中显示显象应用程序被配置来显示的各种目标。一般，此显示将表明由箭头66连接的多个目标图标64。每一个图标64代表一特定目标，以箭头表示目标之间的交互作用。某些箭头67和/或目标图标68可以不同色彩显示来指明活动的(当前的)交互作用和/或目标。在此优选显示中，最近显示的交互作用被表示为红色，在另一事件到达时，其即成为活动的交互作用而前面的活动交互作用则成为灰色。

窗口60还可包含具有一状态显示72和多个钮74的工具棒70，利用它用户可按自己的要求配置显示。

显象应用程序的优选性能如下：可配置的模式：

(a)步进模式在此模式中，事件被以队列形式存储在应用程序中，而此应用程序上的计数器表明多少事件在当前排队中。一个步进钮使用户能顺序地移动通过所存储的事件，每次按步进钮即显示一事件。

(b)运行模式在此模式中，应用程序不将发生的交互作用排队而是要立即显示它们。可控制来使用户能暂停事件的显示，在此情况下它们被暂时存储在队列中直到按下播放按钮。应用程序在可由用户配置的事件的显示之间施加一最小时间。现场或被记录的事件流：

(a)在现场模式，如上述由事件收集和调度系统接收事件；

(b)在由文件播放时，由一存储的文件馈给事件序列；

(c)在记录到文件时，显示现场的事件序列，同时将其记录进一文件供以后再播放用。显示的配置；

显现应用程序可通过装载进一配置文件加以配置，该文件包含有信息关于：

(a)目标以配置文件使用户能配置所要显示哪些目标，它们要显示在什么位置，对目标采用何种色彩，和适应哪一类显示规范；

(b)事件此配置文件还使用户能按排要显示哪些输入的事件，和各事件应显示怎样的与用户友好的名称。关键字的配置：

这使得用户能接收作为一已被配置成带有某一关键字的目标(或目标组)所做的取动作的结果而发生的事件。

仅只有在符合以下的所有4个标准时才在屏幕上显示交互作用：

(a)交互作用必须具有与已被配置进显象应用程序的关键字相同的关键字(除非没有配置有关键字)；

(b)交互作用必须源自于被配置为感兴趣目标；

(c)交互作用必须已被配置为所感趣的目标终结；

(d)交互作用必须具有一已被配置为感兴趣的消息名。

如上面已提到的，目标可被配置为符合某些特性。下面的特性类型是示范性的，而通过修改此显象应用程序可随时增加额外的类型：

类型1目标这一目标类型总可以在显象应用程序的屏幕上看到；

类型2目标这一目标类型在当事件被接收而告知显象应用程序已生成该目标时成为可看到的，而在当事件到达对应于目标的删除时则隐匿；

类型3目标这一目标类型在当显示的交互作用是到达此目标时成为可见的，但在发生删除事件时则隐匿。

在其他实施例中(未作图示)显象应用程序18可由能利用事件收集机构所收集的信息的其他目标代替。例如，一故障报告应用程序可提供一分布式目标系统的故障监控，这样的应用程序可包含在发生意外事件时产生系统报警，以及设计来在万一发生报警时修正系统的运行的出错恢复目标。例如说，系统在适当的环境下可自动完全关闭，或者运行其他们故障恢复目标。因此本发明的系统不仅对系统设计人员和维护人员有用，还可用作监视一运行分布式目标系统的手段。

在再一个实施例中(未图示)此显象应用程序可以由一计费应用程序代替。然后由事件收集机构收集的事件即可被用来对目标的使用或服务进行收费。

现在参看说明定义优选分布处理环境(DPE)的设计模型的基础结构方面的图11。DPE是支持前面讨论的各种不同目标的交互作用的(本质上是公知的)基础结构。DPE的目的除其他外，还在于使应用程序不致受基础环境的不一致的和分布的性质的影响，并提供一种机制使得目标能交互作用而无需知道它们活动中的特定计算节点的细节。DPE定义4种类型的实体：DPE核811，核传递网络901,DPE存根(stub)，和DPE服务器809。核传递网络901如图示与多个相互链结的计算节点810相连接。

DPE核定义一组假定各节点中应存在的核心通信、存储和处理能力(例如一协议栈)。

核传递网络901是一所有DPE核均连接的用来交换消息此实现目标的交互作用的通信网络。它被定义来以便在逻辑上将此计算网络与可用于传递声音和图象的传递网络分开。此逻辑分离是考虑此二网络对服务质量可有不同的要求。

DPE服务器809提供例如交换程序和通知服务器形式的基础结构支持。交换程序提供为使目标能确定其他目标的接口地点的运行时间机制。通知服务器使目标发出通知(例如一目标的生存时间内发生的有效事件)给其他目标。希望接收通知的目标在运行时间在此通知服务器进行注册。

现在参照图12，这里表明一本发明实施例可运行的系统的硬件视图。此硬件是围绕将由服务提供者提供的数据服务送往系统的各用户的传递网络1100建立的。通过网络1100发送的数据可能包括例如声音和/或图象信息。各用户由不同的随用户而定的设备(CPE)1101、1102连接到网络。涉及提供和传播网络服务的各不同方面，例如服务经纪人、服务提供者和网络提供者，在计算节点810连接到传递网络。各计算节点810包含各种不同的硬件和软件特点，总体标明为812。它们包括DPE核811，一按照DPE原则应用的协议栈，存储设施1121和在此计算节点运行的应用程序1120。

此系统还将包括有连接到传递网络的各种不同的数据存储器1105、1106，如图示。这些数据存储器1105之一可包括管理信息数据存储器，用于提供有关网络所提供的服务的全局管理信息。

当然会理解，利用图12中所示硬件，显象应用程序18的示例(图2)将可在各计算节点810中的任一个运行。此应用程序将在网络的分布式目标收集信息，并可借助在各操作人员自己的终端处的图10中所示的信息屏幕加以报告。

Claims (24)

1、一种具有多个目标的分布式目标系统，其特征是各个目标具有一相关过滤器，此过滤器被配置来截取其对应目标所发送或接收的消息和将表述所述消息的信息送往一事件收集器。

2、如权利要求1所述的分布式目标系统，其特征是该过滤器还被配置来将关于一对应目标的生成或删除的信息送往事件收集器。

3、如权利要求1或2所述的分布式目标系统，其特征是各客户机目标均具有一相关的客户机过滤器，此客户机过滤器具有一表述此客户机目标的客户机关键字。

4、如权利要求3所述的分布式目标系统，其特征是当客户机目标发送一输出消息到一服务器目标请求该服务器目标时，客户机过滤器将表述此客户机关键字的信息送往事件收集器。

5、如权利要求3所述的分布式目标系统，其特征是当客户机目标发送一输出消息到一服务器目标请求此服务器目标时，此客房机过滤器将表述该客户机关键字的信息加到此输出消息上。

6、如权利要求5所述的分布式目标系统，其特征是该输出消息由一与该服务器目标相关连的服务器过滤器接收，此服务器过滤器被配置成在接收到该输出消息后以客户机关键字替换服务器关键字。

7、如权利要求6所述的分布式目标系统，其特征是当服务器目标发送一应答消息到客户机目标而返回控制到客户机目标时，服务器过滤器以服务器关键字替换服务器关键字。

8、如权利要求7所述的分布式目标系统，其特征是该应答消息由客户机过滤器接收，此客户机过滤器被配置来还将表述该客户机关键字的信息送往事件收集器。

9、如前述权要求中任一项所述的分布式目标系统，其特征是该多个目标自身被配置来作为该分布式目标系统独立于过滤器地进行交互作用，这些过滤器与目标相关联但不改变目标的其任何代码。

10、如权利要求1所述的分布式目标系统，其特征是被送往事件收集器的信息包含有识别一基本目标的信息，此基本目标为一输出服务器请求信息的最初激发者，该请求信息最终导致产生所述被截取的消息。

11、如权利要求1所述的分布式目标系统，其特征是该过滤器为符合CORBA的。

12、如前述权利要求中任一项所述的分布式目标系统，其特征是由事件收集器所收集的事件由一事件调度机构进行处理并被送到用户应用程序。

13、如权利要求12所述的分布式目标系统，其特征是该用户应用程序是可配置的，该事件调度机构被配置为仅将该对用户应用程序感兴趣的事件送到该用户应用程序。

14、如权利要求12或13所述的分布式目标系统，其特征是事件收集器被配置来将被处理事件送往多个独立的用户应用程序。

15、如权利要求14所述的分布式目标系统，其特征是该独立用户程序为当前运行中的目标。

16、如权利要求12～15中任一项所述的分布式目标系统，其特征是该用户应用程序为一配置来对用户显示所选择事件的显象应用程序。

17、如权利要求12～15中任一项所述的分布式目标系统，其特征是用户应用程序为被配置来根据所接收的事件检测分布式目标系统的运行中的故障的故障检测应用程序。

18、如权利要求12～15中任一项所述的分布式目标系统，其特征是用户应用程序是一被配置来根据所接收的事件控制该分布式目标系统的应用程序的控制应用程序。

19、如权利要求12～15中任一项所述的分布式目标系统，其特征是用户应用程序为被配置来根据所接收事件对该分布式目标系统的各用户进行计费的收费应用程序。

20、如权利要求12～19中任一项所述的分布式目标系统，其特征是各用户应用程序被配置来在事件调度机构注册。

21、如权利要求20所述的分布式目标系统，其特征是配置了事件调度机构的事件调度单元以便为在事件调度机构的各用户应用程序的注册生成一事件调度程序，此事件调度程序被配置来根据各用户应用程序的配置将来事件送往其各用户应用程序。

22、基本上如参照图2～9具体描述的分布式目标系统。

23、一种使具有多个目标的分布式目标系统具有特点的方法，其特征是所述方法包括对各目标提供一被配置来截取由其对应目标所发送或接收的消息和将表述所述消息的信息送往一事件收集器的相关过滤器，此分布式目标系统按照此事件收集器所接收的消息作为其特点。

24、以基本上如参照图2～9具体描述的分布式目标系统为特征的方法。

Images