azure - ASP.NET Core Web 应用程序作为 Azure 服务总线使用者/接收者

Question

我是 Azure 服务总线的新手，刚刚按照下面链接中的 MS 指南操作，运行了 2 个 .NET Core 控制台应用程序。一个作为发送者，另一个作为接收者/消费者。

https://learn.microsoft.com/en-us/azure/service-bus-messaging/service-bus-dotnet-get-started-with-queues

我现在需要的是弄清楚如何配置 .NET Core MVC Web 应用程序，以从队列接收消息。

最终，我想要得到的是 2 个 .NET Core MVC Web 应用程序，它们都可以将消息添加到队列中，并且都能够从队列中接收消息。一个网站可能会向另一个网站的队列添加一条消息，当该网站拾取/使用该消息时，它可能需要将消息发送回原始网站。

我可以接受 Web 应用程序中的“添加到队列”端(因为当用户发生某些事件时会发生这种情况)，但我的困惑在于接收者/消费者端。如何配置 Web 应用程序以(尽可能立即)拾取到达特定服务总线队列的任何消息进行处理？

Answer 1

我建议看看 eShopOnContainers - Microservices Architecture and Containers based Reference Application GitHub 项目并从那里开始。他们为此实现了一个小框架(请参阅项目内的 Microsoft.eShopOnContainers.BuildingBlocks.EventBusServiceBus )。

这就是 Catalog Service 内部的样子:

protected virtual void ConfigureEventBus(IApplicationBuilder app)
{
    var eventBus = app.ApplicationServices.GetRequiredService<IEventBus>();
    eventBus.Subscribe<OrderStatusChangedToAwaitingValidationIntegrationEvent, OrderStatusChangedToAwaitingValidationIntegrationEventHandler>();
    eventBus.Subscribe<OrderStatusChangedToPaidIntegrationEvent, OrderStatusChangedToPaidIntegrationEventHandler>();
}