负载平衡的分发器

var configuration = new BusConfiguration();

// --------------------------------------
// Running the Distributor and a Worker
configuration.AsMSMQMasterNode();
//or
configuration.RunMSMQDistributor();
// --------------------------------------

// --------------------------------------
// Running the Distributor only
configuration.RunMSMQDistributor(false);
// --------------------------------------

在版本4和使用使用NServiceBus.Distributor。MSMQ NuGet.

人员配置

任何NServiceBus端点都可以作为一个工人节点运行。来激活它,创建一个处理程序相关的信息和保证 app.config经销商的文件包含路由信息。

当主机在NServiceBus.Host.exe

如果你举办与NServiceBus.Host端点。exe运行作为一个工人,使用这个命令行:

NServiceBus.Host.exe NServiceBus.MSMQWorker

或者使用一个版本早于NServiceBus的v4.3中:

NServiceBus.Host.exe NServiceBus.Worker

配置主节点服务器的名称所示 app.config的例子。注意 MasterNodeConfig部分:

<?xml version="1.0" encoding="utf-8" ?>
<configuration>
  <configSections>
    <!-- Other sections go here -->
    <section name="MasterNodeConfig" type="NServiceBus.Config.MasterNodeConfig, NServiceBus.Core" />
  </configSections>
  <!-- Other config options go here -->
  <MasterNodeConfig Node="MachineWhereDistributorRuns"/>
</configuration>

读到的 DistributorControlAddress和 DistributorDataAddress在路由与经销商部分。

当用到

如果你用到这里端点所需的代码与经销商争取端点。

var configuration = new BusConfiguration();
configuration.EnlistWithMSMQDistributor();

在版本4和使用使用NServiceBus.Distributor。MSMQ NuGet.

类似于自我托管,保证 app.config职工的包含 MasterNodeConfig指节主节点的主机名(经销商)正在运行。

路由与经销商

经销商为其运行时使用了两个队列的操作。的 DataInputQueue是客户端进程队列发送他们适用的消息。的ControlInputQueue就是工人的队列节点发送控制消息。

使用价值以外的NServiceBus违约可以覆盖它们,如所示 UnicastBusConfig部分如下:

<UnicastBusConfig DistributorControlAddress="[email protected]" DistributorDataAddress="[email protected]">
  <MessageEndpointMappings>
    <!-- regular entries -->
  </MessageEndpointMappings>
</UnicastBusConfig>

如果不存在这些设置,控制队列是假定的端点名称工人,连接的 [email protected]字符串。

类似于标准NServiceBus路由,您不希望高优先级消息困在低优先级的消息,所以就像你有单独的NServiceBus过程不同的消息类型,你也设置不同的经销商实例(有单独的队列)不同的消息类型。

在这种情况下,名称的队列和消息一样。例如, SubmitPurchaseOrder.StrategicCustomers.Sales。这是经销商的数据队列的名称和输入队列的每个工人。经销商的控制队列是最好的命名前缀为“控制”,如下:Control.SubmitPurchaseOrder.StrategicCustomers.Sales.

当使用部署一个完整的发布/订阅的经销商,你看到的是一个分销商在每个用户平衡负载的事件被发表,如下:

记住,经销商是专为负载平衡在一个网站,网站之间的所以不要使用它。在上面的图片中,发布者和订阅者都是在单个物理站点。关于使用NServiceBus在多个物理网站的信息,明白了网关.

高可用性

如果经销商宕机了,即使工人节点保持运行,他们不会收到任何消息。因此,重要的是要在集群上运行的经销商,有其队列配置为集群资源。

因为经销商不做CPU或内存密集型的工作,通常可以把几个经销商过程在同一集群服务器。请注意网络IO经销商可能会成为瓶颈,所以考虑消息的大小和吞吐量上浆基础设施。