在 Azure 逻辑应用中使用顺序编队发送相关的服务总线消息

这些步骤从名为 Azure Service Bus: 从启用会话的队列中处理同一工作流实例的相关消息 - 顺序车队模式 的模板创建工作流。 该模板包括用于实现此工作流模式的触发器和操作。 另外，请创建一个到服务总线命名空间的连接，并指定要使用的服务总线队列的名称。

1. 在 Azure 门户中，打开你的标准逻辑应用资源。

2. 在边栏菜单上的 “工作流”下，选择“ 工作流”。

3. 在“工作流”工具栏上，选择“从模板创建”。>

4. 在 模板 中，选择名为 Azure 服务总线：用于处理同一工作流实例中会话启用队列的相关消息的模板 - 顺序车队模式，然后选择 使用此模板。

   以下示例部分显示了工作流模板库：

   

5. 在 “从模板窗格中创建新工作流 ”上，执行以下步骤：

   1. 在基础选项卡上，按以下步骤操作：

      1. 输入工作流的名称。

         名称必须以字母开头，只能包含字母、数字、短划线和下划线。

      2. 根据方案选择 有状态 或 无状态。

      3. 选择“下一步”。

   2. 在“ 连接 ”选项卡上，执行以下步骤：

      1. 对于服务总线，在 “连接” 列中，选择“ 连接”。

         

      2. 提供以下信息：

         参数	值	说明
         连接名称	< 连接名称>	与服务总线命名空间的连接的名称。
         身份验证类型	连接字符串	要使用的认证类型。
         连接字符串	< 命名空间连接字符串>	您之前从服务总线命名空间保存的连接字符串。

         

      3. 完成后，选择“下一步>”。

   3. 在“ 参数 ”选项卡上，执行以下步骤：

      1. 提供以下信息：

         参数	说明
         队列名称	服务总线会话启用队列的名称，其中包含要处理的消息。
         最大批量大小	获取消息的批次最大数量。

      2. 完成后，选择“下一步”。

   4. 查看提供的信息，然后选择“ 创建”。

   设计器显示了一个工作流，预填充了名为"当消息在队列中可用时 (peek-lock)"的触发器和各种操作，例如：

   

   此工作流包括预定义的跨环境参数，用于抽象值，这些值在工作流运行的各种环境中发生更改，例如开发、测试和生产。 工作流中的许多作使用这些参数，而不是硬编码的值。

   下表描述了这些跨环境参数：

   名称	类型	值	说明
   delayInMinutes_<workflow-name>	整数	0	续订消息锁定令牌之前等待的分钟数。
   messageBatchSize_<workflow-name>	整数	50	当前批的消息数。
   queueName_<workflow-name>	字符串	<Service-Bus-queue-name>	服务总线队列的名称。

   有关详细信息，请参阅 为工作流输入创建跨环境参数。

6. 若要了解工作流中的预定义作，请继续学习下一部分。

工作流操作

以下部分介绍工作流中的预定义作。

当消息在队列中可用时（速览锁定）

此 Azure 服务总线内置触发器等待一个或多个消息到达指定的服务总线队列。 如果队列中存在消息，触发器将触发并运行工作流实例。 术语peek-lock指的是触发器发送请求以从队列中检索消息。 如果有消息存在，则触发器会检索并锁定该消息，防止在锁定期限到期之前对该消息进行其他处理。 触发器还会输出 ServiceBusMessage 对象。

下表描述了预填充的触发器参数：

有关详细信息，请参阅队列中何时提供消息（速览锁定）。

初始化进程完成标志

此名为 Initialize Process Complete Flag 的初始化变量作创建具有以下初始值的变量：

在工作流执行期间，当以下条件满足时，变量 processCompleted 的值会更改为 true。

• 会话中没有更多消息用于处理。
• 会话锁不再需要续订，因此当前工作流实例可以完成运行。

Scope 操作

外部父作用域操作包含一个内嵌的名为业务逻辑作用域的作用域操作。 此嵌套作用域包含名为 Business Logic 的占位符作。 在这里，您可以为您的场景的业务逻辑添加操作，以处理当前消息。

1. 为清晰起见，请将外部父范围操作重命名为Process message。

   

2. 展开内部嵌套操作，名称为业务逻辑范围。

   如果在此范围内出现问题，请使用父 范围 操作之外的后续操作来处理该问题。

3. 将业务逻辑占位符替换为您场景中的业务逻辑实际操作。

在业务逻辑范围操作下，进程完成操作设置为始终运行，而不考虑在业务逻辑范围操作内的所有操作完成后分配给业务逻辑范围操作的状态。 要使 “进程完成” 操作始终运行，工作流将 “运行后” 设置为以下值：

• 成功
• 超时
• 已跳过
• 失败

“进程完成”作将processCompleted变量值从 false 更改为 true，指示消息处理已完成。

截止

在 业务逻辑范围 级别，并行分支运行 一个 Until 循环，该循环确定同一会话中是否存在任何其他消息。 操作在循环内运行，直到满足循环条件或超时时间到。 在此示例中，循环将继续运行，直到消息处理按以下条件表示完成：

processCompleted = true

更新队列中消息的锁定

在 Until 循环中，名为“更新队列中消息的锁定”的服务总线操作控制着工作流处理消息的时间，直到消息再次可供处理。 此行为可防止由于长时间运行的任务而过早释放，并确保在将锁定持续时间设置为初始值之前，一次只有一个客户端处理消息。 有关详细信息，请参阅 “续订锁”。

下表描述了动作的预填充参数：

等待进程完成

在Until循环中，名为“等待进程完成”的延迟动作增加了额外延迟，以确保消息处理完成。 请确保此延迟值小于队列的锁定超时持续时间。 最短锁持续时间为 30 秒。

下表描述了动作的预填充参数：

消息后处理操作

Process message在此作用域下，存在两个并行分支来处理消息处理成功和未成功的情况。

• 分支 1

  此分支包含一个名为Compose的补偿逻辑操作，作为要运行的用于处理错误和异常的操作的占位符。

  1. 将此占位符替换为您想要的操作。

     例如，您可以设置一个包含错误处理操作的作用域操作。

  2. 确保仅在Process message作用域以以下状态之一完成后，Process message作用域下的错误处理操作才会直接运行。

     • 超时
     • 已跳过
     • 失败

     例如：

     

  在错误处理操作下，名为“放行队列中的消息” 的服务总线操作会解锁消息，并将消息重新排队以进行另一次尝试。

  下表列出了该操作的预置值：

  参数	值	说明
  队列名称	queueName_<workflow-name>	指定服务总线队列的跨环境预定义参数。 若要设置此值，请执行以下步骤： 1. 在 “队列名称 ”框中选择，然后选择闪电图标以打开动态内容列表。 2.从列表中选择 queueName_<workflow-name>。
  锁定令牌	锁定令牌	消息放弃时使用的锁定令牌。 若要设置此值，请执行以下步骤： 1. 在 “锁定令牌 ”框中选择，然后选择闪电图标以打开动态内容列表。 2. 在列表中，找到 当队列中有可用消息时，然后选择 Lock Token。

  例如：

  

• 分支 2

  此分支包含一个名为 “完成队列中的消息” 的服务总线操作，该操作将消息标记为已完成，并从队列中删除该消息。 此行为可防止重新传送并将消息移动到“已处理”状态。 仅当 Process message 作用域成功完成时，此操作才会运行。

  下表列出了该操作的预置值：

  参数	值	说明
  队列名称	queueName_<workflow-name>	指定服务总线队列的跨环境预定义参数。 若要设置此值，请执行以下步骤： 1. 在 “队列名称 ”框中选择，然后选择闪电图标以打开动态内容列表。 2.从列表中选择 queueName_<workflow-name>。
  锁定令牌	锁定令牌	消息放弃时使用的锁定令牌。 若要设置此值，请执行以下步骤： 1. 在 “锁定令牌 ”框中选择，然后选择闪电图标以打开动态内容列表。 2. 在列表中，找到 当队列中有可用消息时，然后选择 Lock Token。

  例如：

  

这些步骤手动创建一个使用 Azure 服务总线触发器和操作来实现顺序车队模式的工作流。 工作流创建与服务总线命名空间的连接，并指定要使用的服务总线队列的名称。

将参数添加到工作流

在本部分中，创建跨环境参数以抽象化工作流运行的各种环境（例如开发、测试和生产）更改的值。 稍后，您在工作流中添加使用这些参数的各种操作。

按照以下 常规步骤 在此表中创建跨环境参数：

完成后，跨环境参数如以下示例所示：

添加服务总线触发器

这些步骤添加一个服务总线触发器，用于根据指定的计划初始化会话并检查指定的服务总线队列中的消息。 如果队列中存在消息，触发器将触发并运行工作流。

1. 在 Azure 门户中，在设计器中打开消耗型逻辑应用资源和空白工作流。

2. 按照 常规步骤 添加一个名为“一个或多个消息到达队列（peek-lock）”的服务总线触发器。

   术语peek-lock是指触发器发送请求以从队列中检索消息。 如果有消息存在，则触发器会检索并锁定该消息，防止在锁定期限到期之前对该消息进行其他处理。

3. 在连接窗格中，提供以下信息：

   参数	值	说明
   连接名称	< 连接名称>	与服务总线命名空间的连接的名称。
   身份验证类型	访问密钥	要使用的认证类型。
   连接字符串	< 命名空间-连接字符串>	您之前从服务总线命名空间保存的连接字符串。

   

4. 完成后，选择“ 新建”。

5. 触发器信息窗格打开后，在“ 参数 ”选项卡上提供以下值：

   1. 在 “队列名称 ”框中选择，然后选择闪电图标以打开动态内容列表。

   2. 从列表中选择 queueName_<workflow-name>。

      此前创建的跨环境参数指定服务总线队列的名称。

   3. 对于 队列类型，请将默认类型设置为 Main。

      此类型指的是您的主要服务总线队列。

   4. 在 “高级参数”下，对于 “会话 ID”，请选择“ 下一步可用”。

      下表介绍了有关 会话 ID 值的详细信息：

      会话 ID	说明
      没有	默认值，不会导致会话，不能用于实现顺序车队模式。
      下一个可用	此值指定触发器触发时，触发器根据服务总线队列中的消息中的会话 ID 获取会话。 工作流的后续作处理与同一会话关联的所有消息。 会话已锁定，以便其他工作流或客户端无法处理与同一会话相关的消息。
      输入自定义值	触发器始终要使用的一个已知静态会话 ID。

      注意

      服务总线连接器一次可以将有限数量的唯一会话保存到 Azure 服务总线的连接器缓存。 如果会话计数超过此限制，则将从缓存中删除旧会话。 有关详细信息，请参阅使用 Azure 逻辑应用和 Azure 服务总线在云中交换消息。

   5. 在 “最大消息计数 ”框中选择，然后选择闪电图标以打开动态内容列表。

   6. 从列表中选择 messageBatchSize_<workflow-name>。

   已完成的触发器如以下示例所示：

   

   触发器输出 ServiceBusMessage 对象。

   注意

   轮询间隔一开始设置为三分钟，这样逻辑应用的运行频率就不会超出预期，因此不会产生意外的账单费用。 理想情况下，可将时间间隔和频率设置为 30 秒，这样逻辑应用就会在消息到达时立即触发。

   有关详细信息，请参阅服务总线 - 当一个或多个消息到达队列时（速览锁定）。

添加变量以检查是否存在更多消息

为了帮助工作流确定会话中是否有更多消息需要处理，请创建一个默认值设置为 false的布尔变量。 此变量表示在以下条件为真时：

• 会话中没有更多消息用于处理。
• 会话锁不再需要续订，因此当前工作流实例可以完成运行。

1. 在设计器的触发器下，按照常规步骤添加名为变量的Initialize动作。

2. 将动作重命名为 Initialize Process Complete Flag.

3. 在操作信息窗格中，提供以下值：

   参数	值	说明
   名称	< variable-name>	变量的名称。 对于此示例，名称为 processCompleted.
   类型	布尔值	变量的数据类型。
   价值	假	变量的初始默认值。

   完成后，工作流如以下示例所示：

   

   有关详细信息，请参阅 初始化会话。

4. 继续到下一部分，为消息处理添加作用域。

添加操作以处理每条消息

这些步骤将 作用域 动作 添加到工作流。 在此 范围 操作中，另一个作用域包含用于基于您的情境的业务逻辑的消息处理操作。 如果这些作用域中出现问题，则最外部作用域之外的动作将处理该问题。

1. 在设计器的 Initialize Process Complete Flag 操作下，按照 常规步骤 添加 作用域 操作。

2. 请将范围重命名为 Process message，例如：

   

3. 在处理消息范围中，添加另一个作用域动作。

   1. 将第二个作用域名称更改为 Business Logic Scope，例如：

      

   2. 在 Business Logic Scope 内，根据场景的业务逻辑添加动作以处理当前消息。

4. 在Business Logic Scope外部，添加一个名为“Set variable”的Variables动作。

   1. 将 Set 变量 更改为 Process Finished.

   2. 在“ 参数 ”选项卡上，提供以下信息：

      参数	值	说明
      名称	< variable-name>	变量的名称。 对于此示例，名称为 processCompleted.
      价值	true	更新的值，指示消息处理已完成。

      消息完成处理后，该作会将 Processed Finished 变量中的 processCompleted 值从 false 更新为 true。

   3. 在 “设置” 选项卡上的“ 运行后 ”部分中，展开 业务逻辑范围。

   4. 选择所有未选择的状态： 已超时、 跳过且 失败，例如：

      

5. 在 与业务逻辑范围相同的级别，添加并行分支以确定同一会话中是否存在任何其他消息。

   1. 在 Process message 和 Business Logic Scope 之间，选择加号 (+)，然后选择 添加并行分支。

   2. 在添加操作窗格中，添加一个名为直到的控制操作，这是一种循环类型，例如：

      

   3. 在“直到”动作信息窗格中，提供停止运行循环的条件。

      此 Until 循环可确保会话锁在消息存在时保留，或直到一小时过去。 若要更改循环的时间限制，请编辑名为 Timeout 的循环的高级参数，该参数设置为 PT1H。

      1. 在“ 参数 ”选项卡上，选择最左侧的“ 选择值 ”框，然后选择表达式编辑器（函数图标）。

      2. 在表达式编辑器中，输入以下表达式：

         variables('processCompleted')

      3. 完成后，选择“添加”。

         表达式解析，部分完成的条件如以下示例所示：

         

      4. 在中间列表中，确保操作设定为等号（=）。

      5. 在最右侧 的“选择值 ”框中，输入值 true。

         条件的完成情况示例如下：

         

   4. 按照以下步骤将检测消息的操作添加到 Until 循环：

      1. 按照 常规步骤 添加一个名为“在队列消息上续订锁”的服务总线操作。

         此操作延长了工作流可以处理消息的时间，直到消息再次可供处理。 此行为可防止由于长时间运行的任务而过早释放，并确保一次只有一个客户端处理消息，然后再将锁定持续时间设置为初始值。 有关详细信息，请参阅 “续订锁”。

      2. 服务总线操作信息窗格打开后，请提供以下值：

         1. 在 “队列名称 ”框中选择，然后选择闪电图标以打开动态内容列表。

         2. 从列表中选择 queueName_<workflow-name>。

         3. 在消息框 的“锁定令牌 ”内选择，然后选择闪电图标以打开动态内容列表。

         4. 从列表中，在 一个或多个消息到达队列中时，选择 “锁定令牌”。

         以下示例显示了已完成的服务总线操作：

         

      3. 在“服务总线”操作下，添加一个名为Delay 的计划操作。

         1. 将操作名称更改为 Wait for Process to Complete.

         2. 在参数选项卡上，操作信息窗格中，在计数框内选择，然后选择闪电图标。

         3. 从列表中选择 delayInMinutes_<workflow-name>。

            请确保此延迟值小于队列的锁定超时持续时间。 最短锁持续时间为 30 秒。

         4. 对于 “单位”，设置延迟的时间单位。

            此示例使用 Minute。

         以下示例显示了完成的延迟时间：

         

      完成后， Until 循环如以下示例所示：

      

      重要

      使用具有相同连接器类型的触发器和作来处理同一实体（例如消息队列或主题订阅）时，请确保工作流不会创建无限循环。 此循环导致永远不会完成的工作流。

添加消息后处理操作

在 Process message 作用域下，设置以下两个分支：

• 分支 1

  1. 添加用于处理错误和异常的操作。

     例如，您可以设置一个包含错误处理操作的作用域操作。

     确保仅在Process message作用域以以下状态之一完成后，Process message作用域下的错误处理操作才会直接运行。

     • 超时
     • 已跳过
     • 失败

     例如：

     

  2. 在错误处理操作中，添加名为在队列中放弃消息的服务总线操作，然后按如下所示设置该操作。

     1. 在 “队列名称 ”框中选择，然后选择闪电图标以打开动态内容列表。

     2. 从列表中选择 queueName_<workflow-name>。

     3. 在消息框 的“锁定令牌 ”内选择，然后选择闪电图标以打开动态内容列表。

     4. 从列表中，在 一个或多个消息到达队列中时，选择 “锁定令牌”。

     5. 在 “会话 ID ”框中选择，然后选择闪电图标以打开动态内容列表。

     6. 从列表中，在 一个或多个消息到达队列时下，选择 “会话 ID”。

     完成后，服务总线操作应如下例所示：

     

• 分支 2：添加名为“完成队列中的消息”的服务总线操作。 仅当 Process message 作用域成功完成时，此操作才会运行。 按如下所示设置操作：

  1. 在 “队列名称 ”框中选择，然后选择闪电图标以打开动态内容列表。

  2. 从列表中选择 queueName_<workflow-name>。

  3. 在消息框 的“锁定令牌 ”内选择，然后选择闪电图标以打开动态内容列表。

  4. 从列表中，在 一个或多个消息到达队列中时，选择 “锁定令牌”。

  5. 在 “会话 ID ”框中选择，然后选择闪电图标以打开动态内容列表。

  6. 从列表中，在 一个或多个消息到达队列时下，选择 “会话 ID”。

  完成后，服务总线操作应如下例所示：