同一个应用程序可以是NServiceBus的发布者/订阅者吗？

Question

我是消息体系结构的新手，所以我可能会以这种错误的方式去做。但是我想通过解决一个小问题，在我的团队中慢慢地介绍NServiceBus。

议程中的任命有州。两个用户可以在同一个应用程序中查看同一个议程中的同一个约会。他们通过中央服务器上的远程会话启动该应用程序。因此，如果用户1更新了约会的状态，我希望用户2看到新的状态'实时'。

为了模拟这种或进行概念证明，如果你愿意，我做了一个新的控制台应用程序。通过NuGet我得到NServiceBus和NServiceBus.Host，因为我从文档中理解我需要两个。我知道在生产代码，不建议把一切都在同一程序，但出版商和用户将最有可能在同一程序虽然结束了......

在类节目的方法主要我写了下面的代码：

BusConfiguration configuration = new BusConfiguration(); 

configuration.UsePersistence<InMemoryPersistence>(); 
configuration.UseSerialization<XmlSerializer>(); 
configuration.UseTransport<MsmqTransport>(); 
configuration.TimeToWaitBeforeTriggeringCriticalErrorOnTimeoutOutages(new TimeSpan(1, 0, 0)); 
ConventionsBuilder conventions = configuration.Conventions(); 
conventions.DefiningEventsAs(t => t.Namespace != null 
    && t.Namespace.Contains("Events")); 

using (IStartableBus bus = Bus.Create(configuration)) 
{ 
    bus.Start(); 

    Console.WriteLine("Press key"); 
    Console.ReadKey(); 

    bus.Publish<Events.AppointmentStateChanged>(a => 
    { 
     a.AppointmentID = 1; 
     a.NewState = "New state"; 
    }); 

    Console.WriteLine("Event published."); 
    Console.ReadKey(); 
} 

在类EndPointConfig方法自我加入：

configuration.UsePersistence<InMemoryPersistence>(); 
configuration.UseSerialization<XmlSerializer>(); 
configuration.UseTransport<MsmqTransport>(); 
ConventionsBuilder conventions = configuration.Conventions(); 
conventions.DefiningEventsAs(t => t.Namespace != null 
    && t.Namespace.Contains("Events")); 

AppointmentStateChanged处于活动的简单类文件夹，如下所示：

public class AppointmentStateChanged: IEvent { 
    public int AppointmentID { get; set; } 
    public string NewState { get; set; } 
} 

AppointmentStateChangedHandler是事件处理程序：

public class AppointmentStateChangedHandler : IHandleMessages<Events.AppointmentStateChanged> { 
public void Handle(Events.AppointmentStateChanged message) { 
     Console.WriteLine("AppointmentID: {0}, changed to state: {1}", 
      message.AppointmentID, 
      message.NewState); 
    } 
} 

如果我启动一个控制台应用程序，一切工作正常。我看到处理程序处理事件。但是，如果我尝试启动第二个控制台应用程序，它会崩溃：System.Messaging.MessageQueueException（请求的操作超时已过期）。所以我必须做出错误的事情，让我第二次猜测我不了解更高层次的事情。任何人都可以向我指出正确的方向吗？

更新 寄托都在命名空间AgendaUpdates，除了事件类，这是在AgendaUpdates.Events命名空间。采取

更新2 步骤：

• 复制AgendaUpdates解决方案（以AgendaUpdates2文件夹）
• 在副本中我App.Config中改变MessageEndpointMappings的端点属性为 “AgendaUpdates2” 我MSMQ例外：“队列不存在，或者您没有足够的权限来执行的操作”
• 在我加入这行代码到E副本ndPointConfig：configuration.EndpointName（ “AgendaUpdates2”）; 我MSMQ例外：“队列不存在，或者您没有足够的权限来执行的操作”
• 在我加入这行代码到主架法程序类的副本： configuration.EndpointName （ “AgendaUpdates2”）; 按键后再次出现原始异常。

- >我用原始和复制的解决方案开始2视觉工作室的测试。然后在IDE中启动两个控制台应用程序。

Answer 1

如果您希望发布者也是邮件的接收者，您希望在配置中指定此名称。

这在this article中有清楚的解释，您的问题的解决方案完全在文章的最后。

Answer 2

我不确定你为什么会得到特定的异常，但我可以解释为什么你试图做的失败。问题不在于同一个应用程序中的发布者和订阅者（​​这是可能的并且可能有用）;问题在于你在同一台机器上运行同一应用程序的两个实例。

NServiceBus依靠排队技术（MSMQ你的情况），并且一切正常工作的每个应用程序都需要有自己独特的队列。当你启动两个相同的实例时，它们都试图共享相同的队列。

有一些事情你可以鼓捣让您的方案工作，以更好地了解排队是如何工作的：

1. 更改您的二审
2. 运行在二审的EndPointName单独的机器
3. 独立出版商和用户到单独的进程

不管你走哪条路，你就需要调整你[R MessageEndpointMappings（对消费者/用户），以反映主机/出版商队列生活（的消息类型的“所有者”）：

http://docs.particular.net/nservicebus/messaging/message-owner#configuring-endpoint-mapping

编辑根据您的更新

我知道这是一个观念的考验设置/证明，但认为（相同代码）这两种部署作为出版商/主机和用户/客户端的它仍然是有用的。所以让我们调用原来的主机并复制客户端。我假设你不希望每个都订阅另一个（至少对于这个基本测试）。

此外，请确保您正在运行的IDE都为您的计算机的管理员。我不确定这是否会造成干扰。

在副本中我改变MessageEndpointMappings在App.Config中的端点属性为“AgendaUpdates2”我MSMQ例外：“队列不存在，或者您没有足够的权限来执行的操作”

由于副本是客户端，因此您希望将其映射指向主机。所以这应该是“AgendaUpdates”（省略“2”）。

在副本中，我将这行代码添加到EndPointConfig：configuration.EndpointName（“AgendaUpdates2”）;我MSMQ例外：“队列不存在，或者您没有足够的权限来执行的操作”

在我加入这行代码到主架法程序类的副本：configuration.EndpointName（ “AgendaUpdates2”）;得到原始异常按键

我最初没有注意到这一点后再次，但你并不需要配置端点的两倍。我相信你的EndPointConfig没有被调用，因为它仅在通过NSB主机可执行文件托管时使用。您可能只需删除此课程。

这否则听起来很有道理，但要记住，你的副本不应如果用户被发布，所以不按任何键启动后（在原来只有按下键）。