如何订阅消息？自动/手动订阅如何工作？

Question

我对发布/订阅的概念没有任何疑问，但我无法理解（自动）配置。

场景

1. 我有一个前端服务 (F1)，它执行命令消息 (M1) 的发送。
2. 该命令消息由后端(B1)接收。 B1 进行一些处理，然后对通知消息 M2 进行 PUBLISH。
3. 两个服务（F1 和 F2）应该接收此通知消息并执行其处理/任务。

[F1]＝(M1)＝＞ [B1]＝(M2)＝＞ [F1 和F2]

F1和F2如何订阅B1发布/广播的通知消息M2？

我在 .config 文件或示例代码中找不到实际配置，并且在 NServiceBus 网络广播上找不到有关此内容的文档。

有 IBus.Subscribe 但我看不到如何订阅某个实例。我希望我需要提供一个队列来发送订阅消息，以便我返回可以接收发布/公告。

简而言之

B1 对 M2 执行 PUBLISH。

1. F1和F2如何订阅这条消息？
2. 不使用自动订阅时如何工作？那么从代码或配置？

Answer 1

当您不自动订阅时，您必须在代码中显式地订阅自己。首先在 EndpointConfig 类上指定 IWantCustomInitialization 接口。然后，您告诉 NSB 不要自动订阅：

 NServiceBus.Configure.With()
            .DefaultBuilder()
            .XmlSerializer()
            .MsmqTransport()
            .IsTransactional(true)
            .UnicastBus()
            .DoNotAutoSubscribe()
            .LoadMessageHandlers();

然后在您的订阅者端点中，实现 IWantToRunAtStartup 接口。您可以在那里订阅特定消息，例如：

#region IWantToRunAtStartup Members

    public void Run()
    {
        this.Bus.Subscribe<IProductUpdatedEvent>();
        this.Bus.Subscribe<IProductCreatedEvent>();
    }

    public void Stop()
    {
        this.Bus.Unsubscribe<IProductUpdatedEvent>();
        this.Bus.Unsubscribe<IProductCreatedEvent>();
    }

    #endregion

Answer 2

在 F1 和 F2 的配置文件中，在 UnicastBusConfig 部分的 MessageEndpointMappings 下添加以下条目：

<add Messages="{type of M2}" Endpoint="{queue of B1}" />

然后，您还需要在 F1 和 F2 中为 M2 有一个消息处理程序。当总线看到这一点时，它会自动将订阅消息发送到B1的队列，接收端的总线将存储M2感兴趣的F1和F2的队列名称。

您的场景可能不需要 .DoNotAutoSubscribe() 位。