如何解决从单例运行Dotnet 3.1后台服务
我在StartUp上初始化了一个后台服务,我仅将此服务用于队列使用方。它使用具有订阅者方法的单例服务来处理队列消耗。 作为对StartUp的单例初始化,我希望它只会建立一个连接,但是在我收到的每个队列消息之后,它正在创建一个新的连接。我想知道如何为消费者建立一个连接。 我正在使用dotnet 3.1和rabbitMQClient lib
我的代码如下:
我这样将我的单例注入到我的启动中
public void ConfigureServices(IServiceCollection services)
{
services.AddSingleton<EasyNetQMessageQueuer<RegisterUserResponseEvent>>();
services.AddControllers();
}
public void Configure(IApplicationBuilder app,IWebHostEnvironment env)
{
if (env.IsDevelopment())
{
app.UseDeveloperExceptionPage();
}
app.UseRouting();
app.UseEndpoints(endpoints =>
{
endpoints.MapControllers();
});
app.UseQueueConsumer();
}
此后勤服务来自以下此类:
private static EasyNetQMessageQueuer<RegisterUserResponseEvent> _queuer;
public static IApplicationBuilder UseQueueConsumer(this IApplicationBuilder app)
{
_queuer = app.applicationservices.GetService<EasyNetQMessageQueuer<RegisterUserResponseEvent>>();
var lifetime = app.applicationservices.GetService<IHostApplicationLifetime>();
lifetime.ApplicationStarted.Register(OnStarted);
lifetime.ApplicationStopped.Register(OnStopping);
return app;
}
private static void OnStarted()
{
_queuer.Subscribe();
}
private static void OnStopping()
{
_queuer.disposeConnection();
}
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。