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

我是消息传递体系结构的新手，所以我可能会以错误的方式进行。但我想通过解决一个小问题，慢慢地在我的团队中引入NServiceBus。

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

如果你愿意，我做了一个新的控制台应用程序来模拟这个或做一个概念证明。通过NuGet，我得到了NServiceBus和NServiceBus。因为我从文档中了解到我两者都需要。我知道在生产代码中不建议将所有内容放在同一个程序集中，但是发布者和订阅者很可能最终会在同一个程序集中…

在程序方法Main类中，我编写了以下代码:

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方法Customize中我添加了:

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

AppointmentStateChanged是Events文件夹中的一个简单类，如下所示:

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

任命mentstatechangedhandler是事件处理器:

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(请求操作的超时时间已过期)。所以我一定是做错了什么，让我再次猜测，我不理解更高层次的东西。谁能告诉我正确的方向?

所有内容都在名称空间议程更新中，除了事件类，它在议程更新中。事件名称空间。

更新2 步骤:

• 复制的议程更新解决方案(到议程更新文件夹)
• 在副本中，我将App.Config中的messageendpointmapping中的EndPoint属性更改为"议程更新"我得到MSMQ异常:"队列不存在或您没有足够的权限来执行操作"
• 在副本中，我将这行代码添加到EndPointConfig: configuration.EndpointName("议程更新2");我得到MSMQ异常:"队列不存在或您没有足够的权限来执行操作"
在副本中，我将这行代码添加到Program类的Main方法中:configuration.EndpointName("AgendaUpdates2");

->我用原始和复制的解决方案启动了2个visual studio来测试它。然后在IDE中启动两个控制台应用程序。