本文介绍了一种最佳实践,可用它来监视使用了 Oracle 数据库的非 BPEL Enterprise Information Systems (EIS) 过程。这种最佳实践利用在本文的 下载 部分提供的 Oracle Emitter 工具转换事件数据,甚至在需要的时候扩大(augment)事件数据,然后再将数据继续前递以供使用。借助少许定制,就可以很轻松地将 Oracle Emitter 安装到现有的 WebSphere Business Monitor(本文简称为 Monitor)平台或 WebSphere Application Server(本文简称为 Application Server)。
Common Base Event (CBE) 是一种数据格式,用来打包和发送供 Monitor 使用的事件。只要流入业务系统的业务数据可被捕获并转变为 CBE 事件,Monitor 就能提供一种近乎实时的监控业务活动的能力并进而捕获任何性能症状。我们在本文中将要使用的这个场景展示了一种端对端的解决方案,其中使用 Oracle Emitter 发出并转换供 Monitor 监视的业务数据。能反映业务活动情况的结果指标会被呈现至 Monitor 的 Business Space 仪表盘供报告用。
在本文随后的章节中,我们将讨论:
- 这个场景
- 如何使用 Oracle Emitter
- Oracle Emitter 如何工作
图 1 显示了我们在本文中使用的这个场景。
图 1. Oracle Emitter 场景
业务监控的原理是所实现的业务过程被设计为能够在指定的数据点生成事件。之后,这些事件可被定义并扩大来承载能反映所发生的业务活动的数据和指标,比如变量状态和值变更。这些变更活动以及相应的数据都被记录到一个事件表内。这些事件记录然后用于触发事件的发出以便进行监控。这一过程中的主要阶段总结如下:
- 业务过程与底层的 Oracle 数据库交互并在一些应用程序表内存储或修改数据。
- Oracle Emitter 捕获这些来自数据库的操作(比如插入、更新和删除)、检索相应的数据、将数据转变为 CBE 并将其作为事件发出。
- Monitor 模型从 Common Event Infrastructure (CEI) 接收这些 CBE 并计算业务度量。
- 这些业务度量和 KPI 显示在 Business Space 内。
本节介绍了如何在现有的 Monitor 安装内使用 Oracle Emitter。我们将使用 Clips and Tacks Order Handling Future 1 Process 作为示例。
Clips and Tacks Order Handling Future 1 Process 是随 IBM BPM 产品套件发布的一个公共示例。这个示例的主要特点就是针对涉及到订单处理与验证以及送货处理的常规客户订单处理过程有非常详细的处理模型。这个过程包含三个活动:Place Order、Review Order 和 Ship Order。订单信息存储于四个表内:Customer、Product、Order 及 OrderItem。
开始之前,先下载 Clips And Tacks 示例 和 Oracle Emitter 包。遵照 Clips And Tacks 示例中的指导来设置 Clips And Tacks 过程。
完成如下这些步骤来设置 Oracle Emitter。
- 为 Oracle Emitter 配置环境。
- 开发监控模型。
在安装 Oracle Emitter 应用程序之前,需要配置数据源、调度程序和系统表。为此,需要完成如下步骤:
- 为 Emitter Scheduler 和 Oracle
Emitter 创建一个身份验证别名:
- 启动 Monitor 服务器管理控制台。
- 选择 Security => Secure administration, applications, and infrastructure => Java Authentication and Authorization Service => J2C authentication data。
- 单击 New 通过如下属性创建一个新的身份验证别名:
- Alias:
DBEmitterAlias - User ID:
WBMEMIT - Password: (Specify the password for user WBMEMIT to connect to the database.)
- Description:
Authentication Alias for Scheduler and DB Emitter to Connect to database
- Alias:
- 为 Emitter Scheduler 和 Oracle Emitter 创建一个 JDBC Provider:
- 启动这个管理控制台。
- 选择 Resources => JDBC Providers 并将范围设置为 Server。
- 创建一个名为
Oracle JDBC Driver (XA) For DBEmitter的 JDBC Provider。 - 指定存放 Oracle JDBC 驱动程序 (ojdbc14.jar) 的目录为 Oracle_JDBC_DRIVER_PATH。比如,在 Windows 下: <oracle\product\version>\db1\jdbc\lib\ojdbc14.jar
- 为 Emitter Scheduler 创建一个数据源:
- 选择新创建的这个 provider,然后选择 Additional Properties 部分中的 Data sources。
- 单击 New 通过如下属性新建一个数据源:
- Name:
SKDLR Datasource - JNDI name:
jdbc/skdlr - Component-managed authentication alias:
<Node Name>/DBEmitterAlias - Description:
JDBC data source for SKDLR database - URL: URL to the Monitor database. For example,
jdbc:oracle:thin:@localhost:1521:orcl - Data store helper class name:
Oracle 10g data store helper - 复选 Use this Data Source in container managed persistence (CMP)
- Name:
- 为 Oracle Emitter 创建一个调度程序:
- 启动这个管理控制台。
- 选择 Resources => Schedulers 并将范围设置为 Server。
- 单击 New 通过如下属性创建一个新的调度程序:
- Name:
Poller for DB Emitter - JNDI name:
sched/Poller(这是在 EJB 部署描述符中作为一个环境项指定的默认设置) - Description:
Scheduler for DB Emitter's Event Table Poller - Data source JNDI name:
jdbc/skdlr - Data source alias:
<Node Name>/DBEmitterAlias - Table prefix:
DBEMTR_ - Poll interval:
30 - Work managers:
wm/default
- Name:
- 单击 OK,然后单击 Save。
- 在 Schedulers 页面上,选择最新创建的 Poller 调度程序并单击 Create tables。
- 创建此事件及可由 Oracle Emitter 使用的日志表:
- 用用户 id system 打开 sqlplus。
- 运行随本文所附带的 createEventAndLogTable.ddl 脚本。这会创建可由 Oracle Emitter 使用的事件表、日志表以及一些必需进程。
- 为 Oracle Emitter 创建一个数据源:
- 在 JDBC providers 页面,单击新创建的 Oracle JDBC Driver (XA) For DBEmitter,然后单击 Additional Properties 部分中的 Data sources。
- 单击 New 通过如下属性创建一个新的数据源:
- Name:
DB Emitter Datasource - JNDI name:
jdbc/DBEmitter(这是在 EJB 部署描述符中作为一个环境项指定的默认设置) - Component-managed authentication alias:
<Node Name>/DBEmitterAlias - Description:
DBC Datasource for DBEmitter - URL: 连接到 monitor 数据库的那个 URL。例如,
jdbc:oracle:thin:@localhost:1521:orcl - Data store helper class name:
Oracle 10g data store helper - 复选 Use this Data Source in container managed persistence (CMP)。
- Name:
- 创建必需的目录。如下的这个表列出了 Windows™ 系统上的默认目录。
名称 目录 备注 EventConfDir C:/DBEmitter/EventConfiguration 存储事件配置文件的目录 EventSchemaDir C:/DBEmitter/EventSchema 存储所生成的事件模式的目录
- 使用管理控制台部署这个 Oracle Emitter 企业应用程序(DBEmitterEAR.ear)。接受所有默认值并在部署完成后保存配置。
- 将随本文附带的事件配置文件复制到 <EventConfDir>。针对订单处理过程有三个事件配置文件: OrderCreate.xml、OrderItemAdd.xml 和 OrderUpdate.xml。
- 重启 Monitor 服务器来运行这个调度程序。
- 让浏览器指向
http://<hostname>:<WC_defaulthost port>/DBEmitterWeb/CreateTriggerServlet。 这将会在此数据库中为所有在 <EventConfDir> 目录中定义的事件定义一个触发器。每当改变事件定义文件、添加新的事件定义文件或者改变应用程序表的结构时,都需要重启 Oracle Emitter 并将浏览器指向上述链接来创建或更新触发器。
在本文中,我们将不会介绍常见的一些监控模型的开发任务,比如创建指标、触发器、秒表、度量、规格以及 KPI。有关监控模型创建的完整步骤,请参阅 Clips and Tacks 示例 。在本文中,我们将只介绍使用 Oracle Emitter 扩展监控能力所需要的步骤。
- 为了根据配置为所有事件创建事件模式,需要让浏览器指向
http://<hostname>:<WC_defaulthost port>/DBEmitterWeb/CreateSchemaServlet。事件模式在 <EventSchemaDir> 目录中生成并可在监控模型创建时作为事件定义导入到这个监视模型内。每当改变事件定义文件、添加新的事件定义文件或者改变应用程序表的结构时,都需要重启这个 Oracle Emitter 并将浏览器指向上述链接来创建或更新这个模式。 - 将如图 2 所示的事件模式作为事件定义导入到这个监控模型。
图 2. 订单处理过程的事件模式
- 我们要创建一个具有导入事件模式的监控模型。因为由 Oracle Emitter 发送的 CBE 不包含任何 BPEL 数据,比如 ECSParentID、ECSCurrentID 等,所以只能使用业务逻辑来关联所有的事件。在订单处理过程的监控模型中,有两个监控上下文:OrderMM MC 和 OrderItemMC。
- 接下来,我们需要创建入站事件。有关如何创建入站事件的指导,请参阅 Clips And Tacks 示例文档。图 3 给出在此模型中使用的一个入站事件的例子。请特别留意过滤器条件和相关表达式,它们均与业务逻辑相关。过滤器条件确保只有相关的事件才会被特定的模型接受,而相关表达式则确保事件能被应用到正确的实例。
图 3. OrderCreate 入站事件
- 为监控上下文指定键。有关如何指定键的详细指导,请参阅
Clips
And Tacks
示例文档。如前所述,我们将使用业务逻辑及其相应的有效负载数据来关联事件与监控上下文实例。在这个示例模型中,Order Number 被设置为 OrderMM MC 的键。
Product Number 被设置为 OrderItemMC 的键。在子监控上下文(MC)中的事件应该与父 MC 内的键相关联。这样一来,Order Number 和 Product Number 被用来关联此模型中的这三个事件。这样的键关系与数据库中的主和外键关系是一致的。Order Number 是 OrderMain 表的主键,而 Order Number 和 Product Number 则是 OrderItem
表的主键。Order Number 是 OrderItem 表的外键,它引用 Order 表。图 4 给出了 OrderMM MC 的键。
图 4. OrderMM MC 的键定义
- 此外,还需要定义触发器以便在订单处理过程结束时终止这个监控上下文。当订单被拒或已经发货后,订单处理过程实例就会终止,所以需要定义两个触发器来终止 OrderMM MC:一个是 OrderShipTr,另一个是
OrderDeclinedTr。图 5 展示了这个 OrderShipTr。
图 5. OrderShipTr 触发器
- 在完成入站事件创建、键设置和触发器后,接下来就需要继续扩大这个监控模型。更多信息,请参考本文随附的 OrderMM 模型。
- 现在,就可以用这个模型来消费订单处理过程通过 Oracle 数据库发射器发出的事件了。为了简便起见,在 sqlplus 内执行 insertData.ddl 以便模拟订单处理过程的运行,然后检查业务空间来查看监控结果,如图 6、7 和 8 所示。
图 6. Instance 视图
图 7. Dimension 视图
图 8. KPI 视图
有了 Oracle Emitter 工具,我们就可以借助从运行于 Oracle 数据库上的非 BPEL 过程发出的业务事件来监控业务活动。Oracle Emitter 是一个运行在 WebSphere Application Server 上的 J2EE 应用程序。图 9 展示了 Oracle Emitter 的过程流。
图 9. Oracle Emitter 过程流
事件表和日志表是可由 Oracle Emitter 使用的系统表。 Oracle Emitter 本身包含两个部分:一个事件配置加载器和一个发射器。事件配置加载器(图 9 左侧)负责从文件中读取事件配置信息、从数据库中获取应用程序表的元数据、创建触发器以插入监控模型所用的事件记录及事件定义(模式)文件。在应用程序启动期间,事件配置加载器只调用或初始化一次。发射器(在图 9 的右侧)是通过扩展来自 Event Framework API 的一些类和特定的接口实现的。其任务列表涵盖:从事件表轮询(poll)数据、从应用程序表获取应用程序数据、将业务数据转变为 CBE 事件有效负载的 V6.1 xsd 格式、将事件发送至 CEI、删除事件记录以及记录结果。在接下来的章节中,我们将详细地逐一讨论这些组件。
由用户定义的事件配置文件为 Oracle Emitter 指定应该监视哪个源表、该源表应该引用哪些表以及感兴趣的是哪些列。事件配置文件增进了 Oracle Emitter 的灵活性,用户无需实现 retriever 和 formatter 类。事件配置文件为 XML 格式并遵循如下所示的模式结构。
清单 1. 事件配置文件的模式
<xsd:schema>
<xsd:element name="emitter_event">
<xsd:complexType>
<xsd:sequence>
<xsd:element ref="source_table" minOccurs="1" maxOccurs="1"/>
<xsd:element ref="related_table" minOccurs="0" maxOccurs="unbounded"/>
</xsd:sequence>
<!-- event name, which should be unique -->
<xsd:attribute name="name" type="xsd:string" use="required"/>
<!-- operation: C – insert; U– update; D - Delete. -->
<xsd:attribute name="operation" use="required">
<xsd:simpleType>
<xsd:restriction base="xsd:string">
<xsd:enumeration value="C"/>
<xsd:enumeration value="U"/>
<xsd:enumeration value="D"/>
</xsd:restriction>
</xsd:simpleType>
</xsd:attribute>
</xsd:complexType>
</xsd:element>
<!--Define the table which business process has modified. -->
<!--Triggers will be invoked if there are modifications to this table.-->
<!-- The schema and table name should be provided -->
<xsd:element name="source_table">
<xsd:complexType>
<xsd:sequence>
<!-- If the occurs = 0, all the columns will be included in the CBE -->
<xsd:element ref="selected_column" minOccurs="0" maxOccurs="unbounded"/>
</xsd:sequence>
<xsd:attribute name="name" type="xsd:string" use="required"/>
<xsd:attribute name="schema" type="xsd:string" use="required"/>
</xsd:complexType>
</xsd:element>
<!--Define the table that will provide detail information for some columns in the
source table -->
<xsd:element name="related_table">
<xsd:complexType>
<xsd:sequence>
<!--If the occurs = 0, all the columns will be included in the CBE -->
<xsd:element ref="selected_column" minOccurs="0" maxOccurs="unbounded"/>
<xsd:element ref="correlation" minOccurs="1" maxOccurs="unbounded"/>
</xsd:sequence>
<xsd:attribute name="name" type="xsd:string" use="required"/>
<xsd:attribute name="schema" type="xsd:string" use="required"/>
</xsd:complexType>
</xsd:element>
<!--Define the columns in the table need to be included in the CBE -->
<xsd:element name="selected_column">
<xsd:complexType>
<xsd:sequence>
</xsd:sequence>
<xsd:attribute name="name" type="xsd:string" use="required"/>
</xsd:complexType>
</xsd:element>
<!--Define the conditions that can uniquely determine which record is related to the
source table-->
<xsd:element name="correlation">
<xsd:complexType>
<xsd:sequence>
</xsd:sequence>
<xsd:attribute name="column" type="xsd:string" use="required"/>
<xsd:attribute name="ref_schema" type="xsd:string" use="required"/>
<xsd:attribute name="ref_table" type="xsd:string" use="required"/>
<xsd:attribute name="ref_column" type="xsd:string" use="required"/>
</xsd:complexType>
</xsd:element>
</xsd:schema> |
事件配置文件应包括如下信息:
- 事件名(必须的):在系统中事件名应该惟一。Emitter 使用事件名作为查找每个事件记录相应的事件配置信息的键。
- 要在此表上执行的操作(必须的):它将是这三个值中的一个:C 代表插入一个记录;U 代表更新一个记录;D 代表删除一个记录。
- 源表(必须的):这个表是与业务处理交互的那个表。表名和模式都必须要提供。
- 相关表(可选的):如果源表不能提供足够的监视信息,就可以指定由源表引用的额外的表。例如,顾客信息表就可以是订单表的相关表。
- 源表或相关表的 选定列(可选的):可以通过指定选定列来只包括将要被转变为 CBE 的那些列。这将减少 CBE 的有效负载并提高性能。如果没有指定选定列,则此表中的所有列都会包括到所生成的这个 CBE 中。对于删除操作,只有主键可被设置为选定列。
- 相互关系(为每个相关表所需):它定义了各表之间的外键关系。属性
ref_schema和ref_table分别指的是模式名和引用表的表名。ref_column是引用表的外键。属性列指的是所引用的表的主键。
清单 2 给出了一个示例事件配置文件。
清单 2. 一个示例事件配置文件
<?xml version="1.0" encoding="UTF-8"?>
<!-- event name, which should be unique -->
<!-- operation: C – insert U– update D -- Delete -->
<emitter_event name="OrderItemAdd" operation="C">
<!-- source table: the table which business process has modified. The schema and
table name should be provided -->
<source_table name="OrderItem" schema="CT“>
<!-- selected column: the columns in the table need to be included in the CBE-->
<selected_column name="OrderNumber"/>
<selected_column name="Quantity"/>
</source_table>
<!-- related table: table that will provide detail information for some items
in the source table-->
<related_table name="Product" schema="CT">
<!--If no selected column is specified, all the columns will be included in
the CBE-->
<!-- correlation: conditions that can uniquely determine which record is
related to the source table-->
<!-- correlation: minOccur = 1, maxOccur = unbounded-->
<correlation column="Productnumber" ref_schema="CT" ref_table="OrderItem"
ref_column="ProductNumber"/>
</related_table>
</emitter_event>
|
为了记录和获取在应用程序表上执行的所有操作,需要一个事件表来记录每次发生的操作。Oracle Emitter 查询此事件表并检索有关该操作的详细信息。事件表内的记录包含有关在此应用程序表内发生的事件的总结信息。它还会存储这个应用程序表记录的主键,而这个主键可被用来检索有关该事件的全部信息。表 1 列出了 Oracle Emitter 所用的这个事件表的模式。
表 1. 事件表的结构
| 列名 | 列类型 | 描述 |
|---|---|---|
| SID | NUMBER | 事件的 ID;主键;自动增量 |
| KEYVALUE | VARCHAR(4000) | 插入/更新/删除记录的主键值。复合主键由 “;” 分隔。 |
| EVENTNAME | VARCHAR(256) | 事件名 |
| CREATETIMESTAMP | TIMESTAMP(9) | (插入/更新/删除)操作发生的时间 |
注意:由于 “;” 被用来分隔复合主键,因此 “;” 不能出现于任何主键值中。否则,Oracle Emitter 将不能正确工作。
图 10 给出了在事件表记录中所存储的信息的来源。
图 10. 事件表记录
若此发射器想要处理一个事件记录,那么它就会删除事件记录并在日志表内记录结果,而不管此操作是否成功。日志表的结构,如表 2 所示,与事件表的结构是一样的,只不过添加了 Result 和 LOGTIMESTAMP 列。
表 2. 日志表的结构
| 列名 | 列类型 | 描述 |
|---|---|---|
| SID | NUMBER | 事件的 ID;主键;事件表中相同的 SID |
| KEYVALUE | VARCHAR(4000) | 插入/更新/删除记录的主键值。复合主键由 “;” 分隔。 |
| EVENTNAME | VARCHAR(256) | 事件名 |
| CREATETIMESTAMP | TIMESTAMP(9) | (插入/更新/删除)操作发生的时间 |
| Result | CHAR(1) | 指示发射器发送事件是否成功:S – 成功; F – 失败 |
| LOGTIMESTAMP | TIMESTAMP(9) | 发射器创建此日志记录的时间 |
应用程序表必须由合适的触发器配置,当源表上发生了某个感兴趣的操作时,这些触发器会在事件表内创建一个记录。清单 3 显示了触发器的模板。
清单 3. 触发器模板
CREATE OR REPLACE TRIGGER <Schema Name>.<Event Name>
AFTER INSERT/UPDATE/DELETE
ON <Schema Name>.<Table Name>
REFERENCING NEW AS NEWROW/ REFERENCING OLD AS OLDROW
FOR EACH ROW
BEGIN
INSERT INTO EVENTTABLE(KEYVALUE, EVENTNAME, CREATETIMESTAMP)
VALUES(:TRIM(NEWROW/OLDROW.<Primary Key Name>), <Event Name>, SYSDATE);
END;
|
注意:对于插入操作,应该使用 REFERENCING NEW AS NEWROW,对于更新或删除操作,应该使用 REFERENCING OLD AS OLDROW。
清单 4 显示了触发器的一个示例。如果有一个记录插入到 orderitem 表,这个触发器就会插入一个事件记录。请注意 orderitem 表使用的是一个复合主键,并且键值被 “;” 分隔。
清单 4. 一个示例触发器
-- CREATE TRIGGERS FOR ORDERITEM TABLE CREATE OR REPLACE TRIGGER OrderItemAdd AFTER INSERT ON CT.OrderItem REFERENCING NEW AS NEWROW FOR EACH ROW BEGIN INSERT INTO EVENTTABLE(KEYVALUE, EVENTNAME, CREATETIMESTAMP) VALUES(TRIM(:NEWROW.ORDERNUMBER)||';'||TRIM(:NEWROW.PRODUCTNUMBER), 'OrderItemAdd', SYSDATE); END; |
Oracle Emitter 还创建了事件模式,这些模式作为事件定义被导入到 Monitor Model 编辑器来进行模型创建。数据库内的数据类型不同于 XSD 模式内的类型。要生成事件模式,我们需要先解决数据类型映射问题。表 3 总结了常用数据类型与 Oracle Emitter 内所用的 XSD 类型间的映射。
表 3. 数据类型与 XSD 类型间的映射
| 数据类型 | XSD 类型 |
|---|---|
| LONG, LONG RAW, RAW, CLOB, BLOB, NCLOB, ROWID, CHAR, NCHAR, VARCHAR2, NVARCHAR2, VARCHAR | xsd:string |
| NUMBER(n,0) | xsd:integer |
| NUMBER(n,m) (m>0), FLOAT, BINARY_FLOAT, BINARY_DOUBLE | xsd:decimal |
| TIMESTAMP(n), TIMESTAMP(n) WITH TIME ZONE, TIMESTAMP(n) WITH LOCAL TIME ZONE, DATE | xsd:dateTime |
| 其他 | xsd:string |
在生成 CBE 模式之前,我们还需要确定数据库数据到 CBE 元素之间的转变规则。由 Oracle Emitter 发出的这些 CBE 的头由通用值设置,而源表和相关表(如果有)内的数据则被作为 wbi:any 元素的子元素转变。详细的映射如表 4 所示。
表 4. 数据库数据到 CBE 的映射
| CBE 元素名 | CBE 元素值 |
|---|---|
| sourceComponentId* | |
| sourceComponentId.application | “IBM_WBM_DB_EMITTER_SAMPLE” |
| sourceComponentId.location | IP Address of Emitter |
| sourceComponentId.locationType | “IPV4” |
| sourceComponentId.component | “EventFormatter” |
| sourceComponentId.subComponent | “n/a” |
| sourceComponentId.componentIdType | “n/a” |
| sourceComponentId.componentType | "com.ibm.wbimonitor.dbemitter.formatter.xsd.DBEmitterEventFormatterImpl" |
| sourceComponentId.executionEnvironment | <Was root name> <WAS root version> <WAS root bulild Level> |
| sourceComponentId.threaded | Thread ID |
| situation* | |
| situation.categoryName | “AvailableSituation” |
| situation.situationType* | |
| situation.situationType.reasoningScope | “External” |
| situation.situationType.operationDisposition | “STARTABLE” |
| situation.situationType.processingDisposition | “FUNCTION_PROCESS” |
| situation.situationType.availabilityDisposition | “NOT AVAILABLE” |
| sequenceNumber | “1” |
| globalInstanceId | Generated Automatically |
| Version | “1.0.1” |
| creationTime | EVENTTABLE.CREATETIMESTAMP |
| extensionName | Event Name |
| wbi:any | Database data |
| Trigger | Operation |
| SID | EVENTTABLE.SID |
| Source Table* | |
| Source Table. Selected Column 1 Name | Source Table. Selected Column 1 Value |
| … | … |
| Source Table. Selected Column N Name | Source Table 1. Selected Column N Value |
| [Related Table 1*] | |
| Related Table 1. Selected Column 1 Name | Related Table 1. Selected Column 1 Value |
| … | … |
| Related Table 1. Selected Column N Name | Related Table 1. Selected Column N Value |
| … | … |
| [Related Table N*] | |
| Related Table N. Selected Column 1 Name | Related Table N. Selected Column 1 Value |
| … | … |
| Related Table N. Selected Column N Name | Related Table N. Selected Column N Value |
在解决了数据类型和数据映射之后,发射器就可以使用这些表的元数据创建这个事件模式了。OrderItemAdd 事件的事件模式如清单 5 所示。
清单 5. CBE 事件模式示例
<xsd:complexType name="OrderItemAdd">
<xsd:sequence>
<xsd:element name="SID" type="xsd:int"/>
<xsd:element name="Trigger" type="xsd:string"/>
<xsd:element name="OrderItem" type="tns:OrderItem"/>
<xsd:element name="Product" type="tns:Product"/>
</xsd:sequence>
</xsd:complexType>
<xsd:complexType name="OrderItem">
<xsd:sequence>
<xsd:element name="OrderNumber" type="xsd:integer"/>
<xsd:element name="Quantity" type="xsd:integer"/>
</xsd:sequence>
</xsd:complexType>
<xsd:complexType name="Product">
<xsd:sequence>
<xsd:element name="ProductNumber" type="xsd:string"/>
<xsd:element name="ProductName" type="xsd:string"/>
<xsd:element name="Price" type="xsd:decimal"/>
<xsd:element name="Description" type="xsd:string"/>
</xsd:sequence>
</xsd:complexType>
</xsd:schema>
|
Oracle Emitter 还通过实现 retriever 和 formatter 接口扩展了事件框架。有关此事件框架的更多信息,请参考 DB2 Event Emitter Sample for WebSphere Business Monitor V6.0.2。
在运行时,发射器按固定间隔由 WebSphere Application Server 内的一个调度程序调用。在每个调用中,它都会轮询事件表来查看是否有任何新的记录被转换。如果有,它就会检索相应的应用程序数据并将其格式化成 CBE。此 CBE 之后被发出至 CEI 以便再前递给 Monitor。Oracle Emitter 删除事件表内的记录并将结果记录在日志表内。
清单 6 显示了由 Oracle Emitter 生成的一个 CBE 示例 (OrderItemAdd)。
清单 6. CBE 示例
<CommonBaseEvent creationTime="2008-04-02T08:08:32.562Z" extensionName="OrderItemAdd"
globalInstanceId="CE82A47FFCF8908C05A1DD008BFC608120" sequenceNumber="1" version="1.0.1">
<sourceComponentId application="IBM_WBM_DB_EMITTER_SAMPLE" component="EventFormatter"
componentIdType="n/a" executionEnvironment="null null null" location="9.186.116.195"
locationType="IPV4" subComponent="n/a" threadId="189"
componentType="com.ibm.wbimonitor.dbemitter.formatter.xsd.DBEmitterEventFormatterImpl"/>
<situation categoryName="AvailableSituation">
<situationType xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:type="AvailableSituation" reasoningScope="EXTERNAL"
operationDisposition="STARTABLE" processingDisposition="FUNCTION_PROCESS"
availabilityDisposition="NOT AVAILABLE"/>
</situation>
<tns:OrderItemAdd xmlns:tns="http:///DBEmitter/EmitterEvent.xsd">
<tns:TRIGGER>CREATE</tns:TRIGGER>
<tns:SID>60</tns:SID>
<tns:OrderItem>
<tns:OrderNumber>6632</tns:OrderNumber>
<tns:Quantity>2</tns:Quantity>
</tns:OrderItem>
<tns:Product>
<tns:ProductNumber>RB-0003</tns:ProductNumber>
<tns:ProductName>5 MP Digital Camera</tns:ProductName>
<tns:Price>499</tns:Price>
<tns:Description>This digital camera takes MPEG4 movies</tns:Description>
</tns:Product>
</tns:OrderItemAdd>
</CommonBaseEvent>
|
在本文中,您对 Oracle Emitter 有了一定的了解,这个工具让您能够通过 Oracle 数据库的中介体(intermediary)监视业务处理事件。您了解了为了使用这个工具该如何设置现有的 Monitor 安装。此外,本文还介绍了 Oracle Emitter 框架的各组成组件的设计。
| 描述 | 名字 | 大小 | 下载方法 |
|---|---|---|---|
| Oracle Emitter 样例工件 | OracleEmitter.zip | 967KB | HTTP |
学习
-
DB2 事件发射器示例:了解有关此事件框架的更多信息。
-
Clips and Tacks Order Handling Future 1 Process:了解有关在本文中使用的 Clips and Tacks Order Handling Process 的更多信息。
-
Clips and Tacks: Getting started with the IBM BPM suite of products
:本教程详细介绍了如何开发一个监控模型。
-
Canonical Situation Data Format: The Common Base Event V1.0.1
:这篇文档定义了以一种常见的一致格式定义一个事件结构所需的 Common Base Event 以及支持技术。
-
Common Base Event best practices: Getting it right the first time
(developerWorks,2006 年):看看 IBM 是如何正确阐释自动计算技术的原理的,developerWorks
着重强调了最新发布的指南 “Best Practices for the Common
Base Event and Common Event Infrastructure”,该指南带您亲历了吸引人之处以及一些很酷的地方。
-
WebSphere Business Monitor V6.2 Information Center :获得完整的产品文档。
获得产品和技术
- 下载
IBM 产品评估版 并开始使用来自 DB2 ®、Lotus ®、Rational ®、Tivoli
® 和 WebSphere ® 的应用程序开发工具和中间件产品。

