NServiceBus 端点可以订阅同一消息的多个发布者吗？

Question

我正在开发一个系统来支持从各种硬件类型接收状态信息。每个硬件都报告相同的状态信息（纬度、经度），但每种硬件类型使用独特的协议来报告此信息。因此，我有多个服务，每种设备类型一个，用于侦听和解析该设备的协议。我希望每个服务都使用通用消息发布状态信息：

public interface IPositionMessage : IMessage
{
   string UnitName { get; set; }
   double Latitude { get; set; }
   double Longitude { get; set; }
}

我在设置第一个服务时没有遇到任何问题，但现在我正在设置第二个服务，我发现我的订阅者无法订阅来自多个发布者的同一条消息。

在类似的关于 NServiceBus yahoo 群组的问题中，推荐的解决方案是将公共消息转换为命令并使用 Bus.Send 而不是 Bus.Publish。我觉得在这种情况下这没有意义，因为真正发生的是一个事件（该单位已经到达一个位置并正在报告新位置）。如果我要将其转换为命令，我需要提前知道该事件的所有潜在订阅者，但我不需要。另一种可能的解决方案是创建一个聚合/重新发布器，每个服务都将 Bus.Send 发送到该聚合/重新发布器，然后从单个发布者重新发布消息。这似乎是一个不必要的瓶颈。

有没有什么方法可以让订阅者从多个发布者那里订阅同一条消息？

Answer 1

这是 Udi 试图让您很难逃脱的 SOA“成功坑”之一。

基本的二元性是这样的：

• 命令应该由许多客户端发送并由单一权威源接收。
• 活动应由单一权威来源发布并被许多客户接收。

但这个单一的权威来源是逻辑上的权威来源。重要的一点是，如果我对所有 IPositionMessage 数据感兴趣，则应该只有一个逻辑点 (queuename@servername)，我可以在其中发送订阅请求。

这并不意味着同一逻辑服务中的多个物理处理器不能全部发布相同的事件类型，只要它们发布的内容是权威的。

关键是所有物理处理器必须共享相同的订阅存储。事实上，您可能希望让一个物理端点仅处理订阅请求，而不进行任何处理。它只是接收订阅请求（QueueX@ServerY 对 IPositionMessage 感兴趣）并更新订阅存储。

然后，绑定到同一订阅存储的每个处理器都会发布 IPositionMessage，并会发现 QueueX@ServerY 感兴趣，并将事件的副本发送到该位置。

在运行 NServiceBus.Lite 配置文件的开发环境中，这将有点难以接受，因为默认情况下订阅存储位于内存中，因此显然它不会被共享，并且不会出现正确运行的情况，因此请做好准备为此。

Answer 2

虽然可以订阅多个发布者（这可以在 中配置），但我同意用户组的观点，因为这应该成为逻辑发送而不是发布。

我不太清楚为什么我会这么想。