为什么要为事件接口层次结构中的每个级别创建订阅？

Question

我试图通过使用masstransit和azure服务总线来了解如何正确地发布和使用事件。我想使用接口作为我的消息合同，我的事件继承了接口的层次结构。

我的消费者会消费多种类型的活动;根据我的理解，“ReceiveEndpoint”是最佳选择，因为“SubscriptionEndpoint”指定单个消息类型。我知道ASB不支持多态性。

为单个事件接口设置接收端点时，会为层次结构中的每个级别创建一个订阅：

    public interface IBasiestEventInterface { string P1 { get; } }
    public interface IBaserEventInterface : IBasiestEventInterface { string P2 { get; } }
    public interface IBaseEventInterface : IBaserEventInterface { string P3 { get; } }

    public class TheEvent : IBaseEventInterface
    {
        public string P1 { get; } = "A";
        public string P2 { get; } = "B";
        public string P3 { get; } = "C";
    }

    [TestFixture]
    public class MassTransitTests
    {
        [Test]
        public async Task CanBeConsumedAsInterfaceType()
        {
            var semaphore = new SemaphoreSlim(0);

            var publisher = Bus.Factory.CreateUsingAzureServiceBus(c =>
            {
                c.Host(MassTransitTestsHelper.BusConnectionString, h => { });
            });

            var consumer1 = Bus.Factory.CreateUsingAzureServiceBus(c =>
            {
                c.Host(MassTransitTestsHelper.BusConnectionString, h => { });
                c.ReceiveEndpoint("test_receive_endpoint", e =>
                {
                    e.Handler((MessageHandler<IBaseEventInterface>) (_ =>
                    {
                        semaphore.Release();
                        return Task.CompletedTask;
                    }));
                });
            });

            await publisher.StartAsync();
            await consumer1.StartAsync();

            await publisher.Publish<IBaseEventInterface>(new TheEvent());

            (await semaphore.WaitAsync(10.Seconds())).Should().BeTrue();
        }
    }

按预期收到消息。看起来订阅中的“转发”属性与层次结构级别相关。附加订阅的目的是在Azure Service Bus上添加多态事件调度吗？

Answer 1

是的，多态订阅已添加到Azure Service Bus，这就是您看到其他订阅的原因。因此，您可以订阅消费者中的接口并发布您想要的任何类型，并且应该像RabbitMQ一样适当地路由已实现的接口。