ASP.NET 核心服务未创建 RabbitMQ 队列

Question

作为 MassTransit 和 RabbitMQ 的新用户，我目前正在尝试让我的 ASP.NET 核心服务与 MassTransit 一起工作。

使用此 documentation 部分来配置 MassTransit 和 ASP.NET Core 我无法使其正常工作。

目前（部分）Startup.cs 看起来像

 services.AddMassTransit(x =>
            {
                x.AddConsumer<MailConsumer>();
                x.AddConsumer<MailFailedConsumer>();

                x.AddBus(provider => ConfigureBus(provider, rabbitMqConfigurations));
            });


private IBusControl ConfigureBus(
                            IServiceProvider provider,
                            RabbitMqConfigSection rabbitMqConfigurations) => Bus.Factory.CreateUsingRabbitMq(
                            cfg =>
                            {
                                var host = cfg.Host(
                                    rabbitMqConfigurations.Host,
                                    "/",
                                    hst =>
                                    {
                                        hst.Username(rabbitMqConfigurations.Username);
                                        hst.Password(rabbitMqConfigurations.Password);
                                    });

                                cfg.ReceiveEndpoint(host, $"{typeof(MailSent).Namespace}.{typeof(MailSent).Name}", endpoint =>
                                {
                                    endpoint.Consumer<MailConsumer>(provider);
                                });

                                cfg.ReceiveEndpoint(host, $"{typeof(MailSentFailed).Namespace}.{typeof(MailSentFailed).Name}", endpoint =>
                                {
                                    endpoint.Consumer<MailFailedConsumer>(provider);
                                });
                            });

交换是在 RabbitMQ 启动时自动创建的，但没有队列绑定到我期望的交换。

调用我的 API 端点后，我可以在交换器上看到 activity，但当然消费者什么都不做，因为没有队列。

我遗漏了什么（明显的）部分？

Answer 1

好的，我找到问题了。在编写文档时，它按照文档中的描述工作。 IServiceCollection 接口有几个 AddMassTransit 扩展名，令人困惑。

AddMassTransit 重载，它接受总线实例，按描述工作。

AddMassTransit 重载，接受 Action<IServiceCollectionConfigurator> 只做必要的注册。

您需要添加一行：

services.AddMassTransitHostedService();

您的代码将起作用。

ASP.NET 核心服务未创建 RabbitMQ 队列

ASP.NET Core service not creating RabbitMQ queue

c#

asp.net

masstransit

rabbitmq