如何在控制台应用程序中创建发布者

Question

我刚刚开始使用 NServiceBus，并已更新 PubSub 示例以使用 .NET 4.0 Framework。这工作完全没问题。它在“NServiceBus.Host.exe”环境中运行一个发布者和两个订阅者 - 因此它负责设置总线实例并执行任何相关订阅。这一切都工作正常（正如您所期望的），但我现在试图将发布者从“NServiceBus.Host.exe”中运行移到它自己的控制台应用程序中（最终我想从网站发布消息，以便这似乎是朝这个方向迈出的一小步）。

如果我启动 3 个项目（我的控制台应用程序、Sub1 和 Sub2），它会在我的本地计算机上创建 5 msmq，但不是端点.config...订阅 Q，而是创建通用的“nservicebus_subscriptions”Q。如果我启用日志，我看到 MyPublisherInputQueue 有 3 个（已处理的）完成消息，错误代码为 0，而订阅者 1 输入队列和订阅者 2 输入队列各有一个。这一切看起来都不错，但如果我随后发布消息，发布者似乎不会抛出任何错误，但没有消息到达订阅者（他们只是等待消息）。此外，任何 MQ 的新消息或日志中都不会出现任何消​​息。

我显然错过了一些步骤 - 控制台应用程序是否未开放订阅？如果是这样，需要采取哪些步骤来做到这一点？当您在 nservicebus.host.exe 中托管发布者时，我缺少运行哪些步骤？

为了创建控制台应用程序，我执行了以下操作：

1. 在 pubsub 解决方案中，创建了一个控制台应用程序。
2. 在控制台应用程序中添加了对 mymessages、nservicebus.dll 和 nservicebus.core.dll 的引用
3. 从 NServiceBus 网站上现有的 pub 代码和示例，将以下代码添加到“Main()”

代码：

IBus Bus = Configure.With()
                    .Log4Net()
                    .DefaultBuilder()
                    .MsmqSubscriptionStorage()
                    .XmlSerializer()
                    .MsmqTransport()
                    .UnicastBus()
                        .LoadMessageHandlers()
                    .CreateBus()
                    .Start();

bool publishIEvent = true;
do
{
    Console.ReadLine();
    var eventMessage = publishIEvent ? Bus.CreateInstance<IEvent>() : new EventMessage();

    eventMessage.EventId = Guid.NewGuid();
    eventMessage.Time = DateTime.Now.Second > 30 ? (DateTime?)DateTime.Now : null;
    eventMessage.Duration = TimeSpan.FromSeconds(99999D);

    Bus.Send(eventMessage);

    Console.WriteLine("Published event with Id {0}.", eventMessage.EventId);

} while (true);

1. 为使用现有“publisher”app.config 的内容创建新的控制台应用程序。

2. 向控制台应用程序项目的命令行参数添加了“NServiceBus.Integration”。

Answer 1

如果您查看日志，NServiceBus 可能会告诉您需要将发布者配置为事务性的。方法是在 .MsmqTransport() 之后包含 .IsTransactional(true)。