NServiceBus 集群工作者/分发者使用

Question

当前设置

我们有一个 UI（远不止 1 个 UI，但这不相关），我们有 2 个负载平衡的应用服务器。这样的 UI 将与别名对话，别名后面是 2 个负载均衡器应用服务器。 应用服务器也是自托管 NServiceBus 端点。处理当前请求的应用服务器（可以是 App Server 1 或 App Server 2 ）能够使用自托管的 NServiceBus 执行以下操作：

• 在本地发送消息（这是一种可以在任何时间运行的计算 时间，不管是谁触发的，它只是一个触发 做计算）
• 向辅助设备上的发布者发送命令 Service Box（发布者向 Worker 1 和 Worker 2 推送新事件）
• 直接在辅助服务盒上向 Worker 1 发送命令
• 直接在辅助服务盒上向 Worker 2 发送命令

“应用服务器”当前 App.Config

因此，每个应用服务器的 App.Config 都有类似的内容

  <UnicastBusConfig ForwardReceivedMessagesTo="audit">
    <MessageEndpointMappings>
      
      <add Assembly="Messages" Type="PublisherCommand" Endpoint="Publisher" />
      <add Assembly="Messages" Type=" Worker1Command" Endpoint="Worker1" />
      <add Assembly="Messages" Type=" Worker2Command" Endpoint="Worker2" />
      <!-- This one is sent locally only -->
      <add Assembly=" Messages" Type="RunCalculationCommand" Endpoint="Dealing" />
    </MessageEndpointMappings>
  </UnicastBusConfig>

“发布者”当前 App.Config

目前是“Publisher”App.Config

<UnicastBusConfig ForwardReceivedMessagesTo="audit">
  <MessageEndpointMappings>
  </MessageEndpointMappings>
</UnicastBusConfig>

“Worker(s)”当前 App.Config

目前，worker App.Configs 只需要订阅另一个端点“Publisher”，它们的配置文件如下所示：

<UnicastBusConfig ForwardReceivedMessagesTo="audit">
  <MessageEndpointMappings>
    <add Assembly="Messages" Type="SomeEvent" Endpoint="Publisher" />
  </MessageEndpointMappings>
</UnicastBusConfig>

现在发送给工作人员的所有其他消息都直接来自其中一个应用服务器，如上面针对应用服务器的 App.Config 所示。

一切正常。

问题是我们有一个单点故障，如果“辅助服务盒”死了，我们就被塞满了。

所以我们想知道是否可以使用多个“辅助服务框（每个都有一个 Publishers/Worker1/Worker2）”。理想情况下，它们将完全按照上述方式工作，如上图所示。如果“辅助服务框 1”可用，则使用它，否则我们使用“辅助服务框 2”

我已经阅读了有关分发器的信息（但没有使用它），如果我正确，我们可以在 AppServer(s) 本身中使用它，我们将每个 AppServer 视为分发器和工作器（对于我们需要执行 SendLocal 命令（RunCalculationCommand）的情况，我们需要运行）。

“辅助服务盒”必须为每个包含的端点使用分发器：

所以我们最终可能会得到这样的结果：

有人可以帮助我知道我是否以正确的方式思考这个问题，或者我是否离题了。

基本上我想知道的是：

• 分销商的使用方法是否正确？
• 工人/发布者配置会是什么样子，他们必须以某种方式更改以指向分配器编号？正如我现在所说，应用服务器直接向工作人员发送消息，应用服务器配置具有工作人员端点地址，工作人员仅设置为指向发布者
• 应用服务器配置是什么样的？这会停止直接发送给发布者/工作人员吗？
• 发布者配置是什么样的？这应该指向分销商吗？

Answer 1

分发器在这里是一个很好的方法，但它的代价是增加了基础架构的复杂性。为避免引入另一个单点故障，分发器及其队列必须在 Windows 故障转移集群上运行。这意味着 MSMQ 和 DTC 都必须配置为集群服务。这可以非常有趣.. :D

我已将您所谓的“worker”重命名为端点，从 Worker1 到 Endpoint1，从 Worker2 到 Endpoint2。这是因为当您介绍经销商时，“工人”被非常明确地定义为特定的东西。从分发服务器接收消息的机器上的实际物理端点是工作人员。所以 Endpoint1@ServicesMachine01、Endpoint2@ServicesMachine02 等都是工人。工人从经销商那里得到工作。

场景01

在第一个场景中，您看到应用服务器从负载均衡器获取请求并将其发送到 Endpoint1@Cluster01 或 Endpoint2@Cluster01 在分发服务器上排队，具体取决于命令。这 然后分发器在该队列中找到一个准备好消息的工作人员并将命令发送给它。 所以对于 WorkerCommand1 要么 Endpoint1@ServicesBox01 要么 Endpoint1@ServicesBox02 最终得到 来自分发者的命令并正常处理。

场景02

在场景二中几乎是一样的。 PublishCommand 被发送到 Endpoint3@Cluster01。它 选择一个准备好的 Endpoint3，在本例中为 Endpoint3@ServicesBox02，并给它命令。 ServiceBox02 处理消息并将 SomeEvent 发布到 Endpoint01@Cluster01 和 端点02@Cluster01。这些由分销商收取，在这种情况下发送到 Endpoint1@ServiceBox01 和 Endpoint2@ServiceBoxN。

请注意消息如何始终通过分发服务器和 Cluster01 上的队列流动。这是 MSMQ 的实际负载均衡。

应用服务器配置更改以确保命令通过集群。

<UnicastBusConfig ForwardReceivedMessagesTo="audit">
    <MessageEndpointMappings>

      <add Assembly="Messages" Type="PublisherCommand" Endpoint="Endpoint3@Cluster01" />
      <add Assembly="Messages" Type="Worker1Command" Endpoint="Endpoint1@Cluster01" />
      <add Assembly="Messages" Type="Worker2Command" Endpoint="Endpoint2@Cluster01" />
      <!-- This one is sent locally only -->
      <add Assembly=" Messages" Type="RunCalculationCommand" Endpoint="Dealing" />
    </MessageEndpointMappings>
  </UnicastBusConfig>

ServicesBox 配置略有变化，以确保订阅也通过分销商。

<UnicastBusConfig ForwardReceivedMessagesTo="audit">
  <MessageEndpointMappings>
    <add Assembly="Messages" Type="SomeEvent" Endpoint="Endpoint3@Cluster01" />
  </MessageEndpointMappings>
</UnicastBusConfig>

发布者配置没有变化。它不需要指向任何东西。订阅者会告诉它在哪里发布。