使用 BizTalk Server 处理通知消息以完成 Oracle 数据库中的特定任务

可以使用 Oracle 数据库适配器接收对 Oracle 数据库表更改的通知。 但是，适配器仅向你发送一条通知，指出某些记录已插入、更新或删除特定数据库表中。 这些记录上的任何后期处理都必须由客户端应用程序本身处理。 本主题提供了一种情景描述，介绍如何根据接收到的 Oracle 数据库通知来处理表中的记录。

接收通知后进行后续行动的情景

以下是几个情景，其中适配器客户端必须执行某些通知后的任务。

• 方案 1. 假设适配器客户端必须根据从 Oracle 数据库收到的通知类型执行某些任务。 例如，如果记录插入到表“B”中，客户端应用程序必须更新表“A”中的记录。 同样，如果从表“B”中删除记录，客户端应用程序必须从表“A”中删除记录。

  在此方案中，从收到的通知消息中，适配器客户端必须提取通知类型，以确定通知是用于插入作还是删除作。 确定通知类型后，适配器客户端必须执行后续作才能插入或更新相关表。

• 方案 2. 请考虑以下情况：接收用于改变表格的通知消息的接收位置关闭。 当接收位置关闭时，会将一些记录添加到表中。 但是，对于这些记录，适配器客户端不会收到任何通知。 备份接收位置时，适配器通过发送特定消息通知客户端，然后客户端应用程序必须在接收位置关闭时查找在数据库表中插入的所有记录。

  在此方案中，适配器客户端必须从收到的通知消息中提取信息，以判断通知是由于数据库表的更改还是接收位置的启动。 如果通知是关于接收位置开始运行的，适配器客户端必须实现逻辑来处理在接收位置关闭期间可能已插入、更新或删除的记录。

本主题如何演示如何接收通知消息

在本主题中，为了演示如何处理通知消息来执行后续任务，我们考虑了适配器客户端使用 BizTalk 应用程序接收通知消息以更改 ACCOUNTACTIVITY 表的基本方案。 收到通知后，客户端会筛选收到的通知类型并执行后续作。 为了演示一个非常基本的方案，让我们考虑适配器客户端根据收到的通知类型将通知消息复制到不同的文件夹。 因此：

• 如果通知消息用于“插入”或“更新”作，适配器客户端会将该消息复制到 C：\TestLocation\UpsertNotification 文件夹。

• 如果通知消息用于任何其他作业（例如删除），适配器客户端会将该消息复制到 C:\TestLocation\OtherNotification 文件夹。

  若要在 BizTalk 应用程序中实现此目的，业务流程必须包含以下项：

• 用于接收通知消息的单向接收端口。

• 包含 xpath 查询的表达式形状，用于提取有关收到的通知消息类型的信息。

• 一个Decide形状，用于在编排中包含决策块。 在此决策块中，应用程序根据收到的通知消息决定要执行的后续操作。

• 最后接收通知消息的两个单向发送端口。

使用 Oracle 数据库绑定属性配置通知

下表汇总了用于配置从 Oracle 数据库接收通知的 Oracle 数据库适配器绑定属性。 在 BizTalk Server 管理控制台中配置接收端口时，必须指定这些绑定属性。

有关这些属性的更完整说明，请参阅 “使用绑定属性”。 有关如何使用 Oracle 数据库适配器从 Oracle 数据库接收通知的完整说明，请阅读进一步。

如何从 Oracle 数据库接收通知消息

使用 Oracle 数据库适配器与 BizTalk Server 配合在 Oracle 数据库上执行操作，涉及 构建基块中描述的过程任务，以开发 BizTalk 应用程序。 若要将适配器配置为接收通知消息，这些任务包括：

1. 创建 BizTalk 项目，然后为 通知 入站操作生成架构模式。 （可选）可以为 InboundOperationType、 NotificationPort 和 NotificationStatement 绑定属性指定值。

2. 在 BizTalk 项目中创建一条消息，用于从 Oracle 数据库接收通知。

3. 创建如前一部分所述的编排流程。

4. 生成和部署 BizTalk 项目。

5. 通过创建物理发送和接收端口来配置 BizTalk 应用程序。

   注释

   对于入站操作（如接收通知消息），只能配置单向 WCF-Custom 或 WCF-OracleDB 接收端口。 入站操作不支持双向接收端口。

6. 启动 BizTalk 应用程序。

   本主题提供执行这些任务的说明。

生成架构

必须为 通知 入站操作生成架构。 有关如何生成架构的详细信息，请参阅 在 Visual Studio 中获取 Oracle 数据库操作的元数据 。 生成架构时执行以下任务。 如果不想在设计时指定绑定属性，请跳过第一步。

1. 生成架构时，指定 InboundOperationType、 NotificationPort 和 NotificationStatement 绑定属性的值。 有关此绑定属性的详细信息，请参阅 “使用绑定属性”。 有关如何指定绑定属性的说明，请参阅 配置 Oracle 数据库的绑定属性。

2. 选择合同类型为服务（入站操作）。

3. 为 通知 生成模式。

定义消息和消息类型

前面生成的架构描述了业务流程中消息所需的“类型”。 消息通常是变量，类型由相应的架构定义。 生成架构后，必须将其链接到 BizTalk 项目的业务流程视图中的消息。

对于本主题，必须创建一条消息才能从 Oracle 数据库接收通知。

执行以下步骤以创建消息并将其链接到架构。

创建消息并链接到架构

1. 将一项编排添加到 BizTalk 项目中。 在解决方案资源管理器中，右键单击 BizTalk 项目名称，指向 “添加”，然后单击“ 新建项”。 键入 BizTalk 业务流程的名称，然后单击“添加”。

2. 打开 BizTalk 项目的业务流程视图窗口（如果尚未打开）。 单击 “视图”，指向 “其他窗口”，然后单击 “编排视图”。

3. 在 业务流程视图中，右键单击 “消息”，然后单击“ 新建消息”。

4. 右键单击新创建的消息，然后选择“ 属性窗口”。

5. 在Message_1的“属性”窗格中，执行以下作：

   用这个	要执行的操作
   标识符	键入 NotifyReceive。
   消息类型	在下拉列表中，展开 “架构”，然后选择 “Process_Notification.OracleDBBinding.Notification”，其中 Process_Notification 是 BizTalk 项目的名称。 OracleDBBinding 是为 通知 生成的架构。

设置业务流程

必须创建 BizTalk 业务流程才能使用 BizTalk Server 从 Oracle 数据库接收通知消息，然后根据收到的通知类型执行任务。 在此业务流程中，适配器根据为 NotificationStatement 绑定属性指定的 SELECT 语句接收通知消息。 表达式形状中指定的 xpath 查询将通知类型提取到变量中，例如 NotificationType。 “决定”形状使用此变量中的值来决定收到的通知类型，并采用相应的“路径”来执行后续作。 如前一部分所述，编排将根据收到的通知消息类型执行以下操作。

• 如果通知消息用于“插入”或“更新”作，适配器客户端会将该消息复制到 C：\TestLocation\UpsertNotification 文件夹。

• 如果通知消息用于任何其他操作（例如删除），适配器客户端会将该消息复制到 C:\TestLocation\OtherNotification 文件夹。

  所以，你的编排必须包含以下各项：

• 用于接收通知消息的单向接收端口。

• 包含 xpath 查询的表达式形状，用于提取收到的通知类型。

• 一个决策形状，用于在协调处理过程中包含决策块。 在此决策块中，应用程序根据收到的通知消息决定要执行的后续操作。

• 最后接收通知消息的两个单向发送端口。

• 接受形状。

  示例编排如下所示。

  

添加消息形状

请确保为每个邮件形状指定以下属性。 “形状”列中列出的名称是消息形状的名称，如刚才提到的编排中所示。

添加表达式形状

在业务流程中包含一个表达式形状的目的是使用 Xpath 查询来提取收到的通知消息的类型。 在创建 xpath 查询之前，让我们看看通知消息的格式。 典型的通知消息如下所示：

<?xml version="1.0" encoding="utf-8" ?>
<Notification xmlns="http://Microsoft.LobServices.OracleDB/2007/03/Notification/">
  <Details>
    <NotificationDetails>
      <ResourceName>SCOTT.ACCOUNTACTIVITY</ResourceName>
      <Info>1</Info>
      <QueryId>0</QueryId>
    </NotificationDetails>
  </Details>
  <Info>Insert</Info>
  <ResourceNames>
    <string xmlns="http://schemas.microsoft.com/2003/10/Serialization/Arrays">SCOTT.ACCOUNTACTIVITY</string>
  </ResourceNames>
  <Source>Data</Source>
  <Type>Change</Type>
</Notification>

如你所看到的，有关通知类型的信息位于 <info> 标签内，属于父标签 <Notification>。 因此，作为此表达式形状的一部分，您必须：

• 创建一个变量，其中包含标记中的 <Info> 值，并将其类型设置为 System.String。 有关创建变量的详细信息，请参阅 在业务流程中使用变量。

  对于本主题，将变量命名为 NotificationType。

• 创建 xpath 查询以从 <Info> 标记中提取值。 XPath 查询将像下面这样：

  NotificationType = xpath(NotifyReceive,"string(/*[local-name()='Notification']/*[local-name()='Info']/text())");
  

  在此 xpath 查询中， NotifyReceive 是你为接收通知消息而创建的消息。 函数代码片段表明，查询必须从 <Info> 标记中提取值，而此标记又嵌套在 <Notification> 标记中。 最后，查询提取的值分配给 NotificaitonType 变量。

添加选择形状

添加“决定”形状的目的是在业务流程中包含决策块，以便根据收到的通知消息类型决定执行哪些后续操作。 根据 NotificationType 变量的值做出决策。 在本主题中，业务流程根据收到的通知消息类型做出决策。 因此，规则形状中的条件指定如下：

NotificationType.Equals("Insert") | NotificationType.Equals("Update")

此条件表明，如果 NotificaitonType 变量的值为 Insert 或 Update，则业务流程将执行一组任务。 如果 NotificationType 变量的值是任何其他值，业务流程将执行其他一组任务。

如前面的部分所述，为了演示一个简单的方法，业务流程将根据通知消息类型将消息复制到不同的文件夹。 因此，在 Rule 和 Else 块中，必须添加“发送”形状才能将消息发送到不同的端口。 对于本主题，将 Rule 块中的“发送”形状命名为 SendUpsertNotification ，将 Else 块中的“发送”形状命名为 SendOtherNotification。

添加端口

现在必须将以下逻辑端口添加到编排中：

• 用于从 Oracle 数据库接收通知消息的单向接收端口。

• 单向发送端口，用于将“插入”和“更新”作的通知消息发送到特定文件夹。

• 单向发送端口，用于向特定文件夹发送任何其他操作的通知消息。

  请确保为每个逻辑端口指定以下属性。 端口列中列出的名称是编排中显示的端口的名称。

为动作形状指定消息并连接至端口

下表列出了为操作形状指定消息及将消息链接到端口时需要设置的属性及其值。 Shape 列中列出的名称是前文提到的业务编排中显示的消息形状的名称。

指定这些属性后，消息形状符和端口被连接，您的编排已完成。

现在必须生成 BizTalk 解决方案并将其部署到 BizTalk Server。 有关详细信息，请参阅 生成和运行业务流程。

配置 BizTalk 应用程序

部署 BizTalk 项目后，前面创建的业务流程将列在 BizTalk Server 管理控制台中的 “业务流程 ”窗格下。 必须使用 BizTalk Server 管理控制台来配置应用程序。 有关演练，请参阅 演练：部署基本 BizTalk 应用程序。

配置应用程序涉及：

• 为应用程序选择主机。

• 将业务流程中创建的端口映射到 BizTalk Server 管理控制台中的物理端口。 对于此编排，必须：

  • 定义物理 WCF-Custom 或 WCF-OracleDB 单向接收端口。 此端口侦听来自 Oracle 数据库的通知。 有关如何创建接收端口的信息，请参阅 手动配置到 Oracle 数据库适配器的物理端口绑定。 请确保为接收端口指定以下绑定属性。

    重要

    如果在设计时指定绑定属性，则无需执行此步骤。 在这种情况下，通过导入由“Consume Adapter Service Add-in”创建的绑定文件，可以设置所需的绑定属性，来创建 WCF 自定义或 WCF-OracleDB 接收端口。 有关详细信息，请参阅使用端口绑定文件配置物理端口绑定。

    Binding 属性	价值
    InboundOperationType	将此设置为 “通知”。
    NotificationPort	指定 ODP.NET 必须打开的端口号，以侦听 Oracle 数据库中的数据库更改通知。 将此设置为必须添加到 Windows 防火墙例外列表的相同端口号。 有关如何将端口添加到 Windows 防火墙例外列表的说明，请参阅 https://go.microsoft.com/fwlink/?LinkID=196959。 重要： 如果将此项设置为默认值 -1，则必须完全禁用 Windows 防火墙才能接收通知消息。
    NotificationStatement	将此设置为： SELECT TID,ACCOUNT,PROCESSED FROM SCOTT.ACCOUNTACTIVITY WHERE PROCESSED = ‘n’ 注意： 必须指定表名以及架构名称。 例如，SCOTT.ACCOUNTACTIVITY。
    NotifyOnListenerStart	将此设置为 True。

    有关不同绑定属性的详细信息，请参阅 “使用绑定属性”。

    注释

    建议在使用 Oracle 数据库适配器执行入站作时配置事务隔离级别和事务超时。 可以通过在配置 WCF-Custom 或 WCF-OracleDB 接收端口时添加服务行为来执行此作。 有关如何添加服务行为的说明，请参阅 使用 Oracle 数据库配置事务隔离级别和事务超时。

  • 定义硬盘上的位置和相应的文件端口，以便 BizTalk 编排将用于插入和更新操作的通知消息从 Oracle 数据库抛出。 将此端口配置为将通知消息删除到文件夹 C：\TestLocation\UpsertNotification。

  • 定义硬盘上的一个位置和一个对应的文件端口，以便 BizTalk 业务流程能够将来自 Oracle 数据库的通知消息放置在那里，以执行所有其他操作。 将此端口配置为将通知消息删除到文件夹 C：\TestLocation\OtherNotification。

启动应用程序

必须启动 BizTalk 应用程序，以便从 Oracle 数据库接收通知消息，并执行后续的“选择和更新”作。 有关启动 BizTalk 应用程序的说明，请参阅 如何启动业务流程。

在此阶段，请确保：

• WCF-Custom 或 WCF-OracleDB 单向接收端口（用于接收来自 Oracle 数据库的通知消息）正在运行。

• 从 Oracle 数据库接收消息的两个 FILE 发送端口正在运行。

• 正在运行该操作的 BizTalk 业务流程。

执行操作

启动 BizTalk 编排后，将执行以下一系列操作：

• 由于 NotifyOnListenerStart 绑定属性设置为 True，因此会收到以下消息：

  <?xml version="1.0" encoding="utf-8" ?>
  <Notification xmlns="http://Microsoft.LobServices.OracleDB/2007/03/Notification/">
    <Info>ListenerStarted</Info>
    <Source>OracleDBBinding</Source>
    <Type>Startup</Type>
  </Notification>
  

  请注意，标记中的 <Info> 值为“ListnerStarted”。 因此，此消息在 C：\TestLocation\OtherNotification 文件夹中接收。

• 在 ACCOUNTACTIVITY 表中插入记录。 将收到一条通知消息，该消息与以下内容相同：

  <?xml version="1.0" encoding="utf-8" ?>
  <Notification xmlns="http://Microsoft.LobServices.OracleDB/2007/03/Notification/">
    <Details>
      <NotificationDetails>
        <ResourceName>SCOTT.ACCOUNTACTIVITY</ResourceName>
        <Info>1</Info>
        <QueryId>0</QueryId>
      </NotificationDetails>
    </Details>
    <Info>Insert</Info>
    <ResourceNames>
      <string xmlns="http://schemas.microsoft.com/2003/10/Serialization/Arrays">SCOTT.ACCOUNTACTIVITY</string>
    </ResourceNames>
    <Source>Data</Source>
    <Type>Change</Type>
  </Notification>
  

  请注意，标记中的 <Info> 值为“Insert”。 因此，此消息在 C：\TestLocation\UpsertNotification 文件夹中接收。

• 更新 ACCOUNTACTIVITY 表中的记录。 将收到一条通知消息，该消息与以下内容相同：

  <?xml version="1.0" encoding="utf-8" ?>
  <Notification xmlns="http://Microsoft.LobServices.OracleDB/2007/03/Notification/">
    <Details>
      <NotificationDetails>
        <ResourceName>SCOTT.ACCOUNTACTIVITY</ResourceName>
        <Info>32</Info>
        <QueryId>0</QueryId>
      </NotificationDetails>
    </Details>
    <Info>Update</Info>
    <ResourceNames>
      <string xmlns="http://schemas.microsoft.com/2003/10/Serialization/Arrays">SCOTT.ACCOUNTACTIVITY</string>
    </ResourceNames>
    <Source>Data</Source>
    <Type>Change</Type>
  </Notification>
  

  请注意，标记中的 <Info> 值为“Update”。 因此，此消息在 C：\TestLocation\UpsertNotification 文件夹中接收。

• 从 ACCOUNTACTIVITY 表中删除记录。 将收到一条通知消息，该消息与以下内容相同：

  <?xml version="1.0" encoding="utf-8" ?>
  <Notification xmlns="http://Microsoft.LobServices.OracleDB/2007/03/Notification/">
    <Details>
      <NotificationDetails>
        <ResourceName>SCOTT.ACCOUNTACTIVITY</ResourceName>
        <Info>16</Info>
        <QueryId>0</QueryId>
      </NotificationDetails>
    </Details>
    <Info>Delete</Info>
    <ResourceNames>
      <string xmlns="http://schemas.microsoft.com/2003/10/Serialization/Arrays">SCOTT.ACCOUNTACTIVITY</string>
    </ResourceNames>
    <Source>Data</Source>
    <Type>Change</Type>
  </Notification>
  

  请注意，标记中的 <Info> 值为“Delete”。 因此，此消息在 C：\TestLocation\OtherNotification 文件夹中接收。

最佳做法

部署并配置 BizTalk 项目后，可以将配置设置导出到名为绑定文件的 XML 文件。 生成绑定文件后，可以从该文件导入配置设置，以便无需为同一业务流程创建发送端口和接收端口。 有关绑定文件的详细信息，请参阅 重复使用 Oracle 数据库适配器绑定。

接收到通知消息后执行复杂操作。

为简单和更好地了解，本主题中的业务流程会根据通知类型将邮件复制到不同的文件夹。 但是，在实际情境中，你可能希望执行更复杂的操作。 可以执行本主题中提供的类似过程，并以此为基础来进行你希望的操作。 例如，如果在 ACCOUNTACTIVITY 表中收到插入操作的通知消息，则可以更改编排以在另一个表中插入记录。 在这种情况下，可以在“决定”形状中进行适当的更改。

另请参阅

使用 BizTalk Server 接收 Oracle 数据库更改通知