为什么 NServiceBus 会从两个不同的服务器接收通知？

Question

我的应用程序有两个组件。一种是通知程序进程（Notifier），它运行在媒体服务器上，当文件被修改时使用 NServiceBus 发布消息。另一个是 MVC Web 应用程序 (PhotoWeb)，它订阅这些消息以执行缓存失效等操作。

我正在为 QA 设置暂存环境，问题是在暂存环境中运行的 PhotoWeb 应用程序正在接收通知 服务器 - 这是意外的，而且有点奇怪...

部署到生产环境的 PhotoWeb 实例具有以下配置：

<MsmqTransportConfig InputQueue="PhotoWebInputQueue" ErrorQueue="PhotoWebErrorQueue" NumberOfWorkerThreads="1" MaxRetries="5" />
<UnicastBusConfig>
  <MessageEndpointMappings>
    <clear/>
    <!-- Where do we subscribe to messages about filesystem changes? -->
    <add Messages="MyProject.Messages" Endpoint="NotifierInputQueue@webmedia"/>
  </MessageEndpointMappings>
</UnicastBusConfig>

登台环境中的配置是：

<MsmqTransportConfig InputQueue="PhotoWebInputQueue" ErrorQueue="PhotoWebErrorQueue" NumberOfWorkerThreads="1" MaxRetries="5" />
<UnicastBusConfig>
  <MessageEndpointMappings>
    <clear/>
    <!-- Where do we subscribe to messages about filesystem changes? -->
    <add Messages="MyProject.Messages" Endpoint="NotifierInputQueue@staging_media"/>
  </MessageEndpointMappings>
</UnicastBusConfig>

来自登台媒体服务器和实时媒体 注意：

1. 我误解了队列的实际含义 - PhotoWebInputQueue 实际上是共享网络资源，而不是特定服务器本地的队列
2. 以前的部署导致 NServiceBus 订阅实时网络媒体暂存 Web 服务器上的队列，并且此订阅在重新启动等过程中持续存在。

但是，我的 NServiceBus-fu 不够强大，无法知道如何测试这些理论中的任何一个。您可以看到此配置或架构有什么明显的错误吗？

谢谢，

迪伦

Answer 1

通知程序向两个订阅者发送消息的唯一方法是通知程序的订阅存储中存在两个订阅者的订阅。订阅包括：

• 消息类型（包括程序集、版本和公钥令牌）
• 订阅者的输入队列地址。

当发布者收到消息时，它会依次根据每个订阅评估该消息，并将该消息发送给每个匹配的订阅者。

如果您清除实时通知程序的订阅存储，然后重新启动实时订阅者，这应该可以解决该问题。