使用 MassTransit 将服务注入队列消费者

Question

我有一个配置如下的消费者

.ConfigureServices((hostContext, services) =>
{
    services.AddMassTransit(cfg =>
    {
        cfg.AddConsumer <Consumers>();
        cfg.UsingRabbitMq((context, cfgss) =>
        {
            cfgss.Host(new Uri("rabbitmq://localhost/"), hostss =>
            {
                hostss.Username("guest");
                hostss.Password("guest");
            });

            cfgss.ReceiveEndpoint("Queue_Name", configureEndpoint =>
            {
                //configureEndpoint.ConfigureConsumer<Consumers>(context);
                configureEndpoint.Consumer<Consumers>();
            });

            cfgss.ConfigureEndpoints(context);
        });
    });
})

服务是在 ContainerBuilder 上使用 Autofac 创建的，EventService 是应该注入到消费者中的服务

var host = new HostBuilder()
    .UseServiceProviderFactory(new AutofacServiceProviderFactory())
    .ConfigureHostConfiguration(configHost => { configHost.SetBasePath(Directory.GetCurrentDirectory()); })
    .ConfigureAppConfiguration((hostContext, configApp) =>
    {
        configApp.AddJsonFile("appsettings.json", optional: false);
    })
    .ConfigureContainer<ContainerBuilder>(builder =>
    {
        builder.RegisterType<EventService>().As<IService>();
}

这就是消费者

public Consumers() { }
    
public Consumers(IService EventService)
{
    _eventsService = EventService;
}

public Task Consume(ConsumeContext<Msg> context)
{
    _eventsService.ProcessInternal(context.Message);
    return Task.CompletedTask;
}

每当收到消息时，都会调用空构造函数，但 _eventsService 为 null

Answer 1

您应该使用

ConfigureConsumer

：

cfgss.ReceiveEndpoint("Queue_Name", configureEndpoint =>
{
    configureEndpoint.ConfigureConsumer<Consumers>(context);
});

并完全删除空构造函数。