5

当创建一个 NServiceBus SendOnly 端点时，其目的是一劳永逸，即只发送一条消息，然后其他人会处理它。这似乎是我需要的东西。我不希望总线和系统处理消息之间有任何通信。系统“A”想要通知系统“B”某事。

好吧，如果非常简单，那么创建一个 SendOnly 端点，但是系统监听来自 SendOnly 端点的消息呢？

我正在尝试在将处理消息的命令行项目中设置一个侦听器。消息被发送到队列，但它们没有被系统“B”处理。

这是错误的方法吗？对于这种类型的功能来说，总线是否矫枉过正？

系统A：

public class Program
{
    static void Main(string[] args)
    {
        var container = new UnityContainer();

        var bus = Configure.With()
            .UnityBuilder(container)
            .JsonSerializer()
            .Log4Net()
            .MsmqTransport()
            .UnicastBus()
            .SendOnly();

        while(true)
        {
            Console.WriteLine("Send a message");
            var message = new Message(Console.ReadLine());
            bus.Send(message);
        }
    }
}

系统 B：

class Program
{
    static void Main(string[] args)
    {
        var container = new UnityContainer();

        var bus = Configure.With()
            .UnityBuilder(container)
            .JsonSerializer()
            .Log4Net()
            .MsmqTransport()
            .UnicastBus()
            .LoadMessageHandlers()
            .CreateBus()
            .Start();

        Console.WriteLine("Waiting for messages...");

        while(true)
        {

        }
    }
}

public class MessageHandler : IHandleMessages<Message>
{
    public void Handle(Message message)
    {
        Console.WriteLine(message.Data);
    }
}

public class Message : IMessage
{
    public Message()
    {

    }

    public Message(string data)
    {
        Data = data;
    }

    public string Data { get; set; }
}
4

1 回答 1

5

在 MessageEndpointMappings 中，您需要按如下方式对其进行更新：

  1. 将 DLL 替换为包含您的消息的程序集的名称（例如“消息”）
  2. 将端点更改为系统 B 正在读取的队列的名称（您可以通过查看私有队列下的 MSMQ 管理单元来检查队列名称）。
<add Messages="Messages" Endpoint="SystemB" />

NServiceBus 3 根据宿主程序集的命名空间自动创建队列名称。

此外，您可能希望查看使用NServiceBus.Host来托管您的处理程序，而不是您自己的控制台应用程序。

于 2012-04-17T10:25:48.563 回答