ASP.NET Core AddHostedService 和 AddSingleton 关系

use*_*632 2 .net service dependency-injection

我一起使用 AddSingleton 和 AddHostedService 在后端有一个长时间运行的服务(BackgroundService),同时控制器访问相同的服务来获取数据。这是我发现的:

  1. 如果同时使用 AddSingleton 和 AddHostedService,BackgroundService 将被初始化两次(不是 Singleton)。控制器只能访问在 AddSingleton 中创建的控制器。

调试输出(构造函数调用两次,查看秒数差异)

BGService 构造函数服务 addGame:游戏计数为 1 BGService 构造函数服务 addGame:游戏计数为 1 ExecuteAsync 1 :游戏计数为 1:[ "CONSTRUCTOR GAME AT 10/29/2021 10:37:25 AM(0)" ] ... ... ExecuteAsync 7 :游戏计数为 1:[ "CONSTRUCTOR GAME AT 10/29/2021 10:37:25 AM(0)" ] service addGame:games count is 2 After AddGame: [
"CONSTRUCTOR GAME AT 10/29 /2021 10:37:24 AM(0)", "游戏 0(1)"]

  1. 如果只使用 AddSingleton,它就可以工作。

  2. 如果仅使用 AddHostedService,则后台服务正在运行,但 DI 无法在控制器中工作(异常)。

**> 失败:

Microsoft.AspNetCore.Diagnostics.DeveloperExceptionPageMiddleware 1 执行请求时发生未处理的异常。System.InvalidOperationException:尝试激活“CoreServiceSignalRSample.Controllers.WeatherForecastController”时无法解析类型“CoreServiceSignalRSample.service.IBGService”的服务。
在 Microsoft.Extensions.DependencyInjection.ActivatorUtilities.GetService(IServiceProvider sp,类型 type,Type requiredBy,布尔值 isDefaultParameterRequired)
在 lambda_method(Closure , IServiceProvider , Object[] )**

我的问题是,DI 背景服务的正确方法是什么以及为什么建议使用 AddHostedService

示例代码可以在https://github.com/huangpat/CoreServiceSignalRSample找到。

Startup.cs 配置服务

    services.AddSingleton<IBGService>(new BGService());
    services.AddHostedService<BGService>();
Run Code Online (Sandbox Code Playgroud)

BG服务.cs

private List<string> games;

public BGService()
{
    Console.WriteLine("BGService constructor");
    this.games = new List<string>();
    this.addGame("Constructor Game at " + DateTime.Now.ToString());
}

public async Task<bool> addGame(string fGame)
{
    if (this.games.Count <= 20)
    {
        this.games.Add(fGame.ToUpper() + "(" + Convert.ToString(this.games.Count) + ")");
        Console.WriteLine("service addGame:games count is " + Convert.ToString(this.games.Count));
        return true;
    }
    else
    {
        return false;
    }
}


protected override async Task ExecuteAsync(CancellationToken stoppingToken)
{
    int i = 0;
    while (true)
    {
        i++;
        if (games.Count == 0)
        {
            this.addGame("ExecuteAsync Game at " + DateTime.Now.ToString());
        }
        JsonSerializer js = new JsonSerializer();
        
        Console.WriteLine("ExecuteAsync {1} :games count is {0}:{2}", this.games.Count, i, JsonConvert.SerializeObject(this.games, Formatting.Indented));

        await Task.Delay(1000 * 2 * 5);
    }
    //throw new NotImplementedException();

    /
Run Code Online (Sandbox Code Playgroud)

/ 使用线程池启动集合中的每个游戏 }

Gur*_*ron 7

每个注册都会使用自己的解析规则创建自己的类型描述符(即默认情况下它将使用相应的构造函数)。您可以使用实现工厂注册来解决这个问题:

services.AddSingleton<BGService>();
services.AddSingleton<IBGService>(provider => provider.GetRequiredService<BGService>());
services.AddHostedService<BGService>(provider => provider.GetRequiredService<BGService>());
Run Code Online (Sandbox Code Playgroud)