我有一个消费者,配置如下
.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
2条答案
按热度按时间brccelvz1#
使用
ConfigureConsumer
:字符串
并完全移除空构造函数。
pkln4tw62#
我在这个帖子中找到了解决方案
Link
需要将消费者添加到配置和AddMassTransitHostedService
这是最终的工作配置:
字符串