BackgroundService QueueHostedService

如何解决BackgroundService QueueHostedService

我正在尝试使用 BackgroundService 和 IBackgroundTaskQueue 来让服务监视队列以完成工作。我从这里的 MS 文档中的示例开始：https://docs.microsoft.com/en-us/aspnet/core/fundamentals/host/hosted-services?view=aspnetcore-5.0&tabs=visual-studio#queued-background-tasks

我的问题是我的 QueueHostedService 似乎从未启动过。我的断点都没有被击中。现在，我使用相同的“MonitorLoop”概念来排队工作，即开始并正常工作以对记录进行排队，但它们永远不会出队，并且 QueueHostedService 中的任何内容都没有被命中（构造函数、ExecuteAsync、BackgroundProcessing）。

据我所知，我的示例代码与文档完全相同，但进行了以下修改： 监视器循环是异步的，但它启动良好，所以我认为这不是问题所在。 QueueHostedService 和 BackgroundTaskQueue 与它们的示例完全相同。 在我看来，添加的服务几乎相同：

 /// <summary>
 /// Create host and services
 /// </summary>
 /// <param name="args"></param>
 /// <returns></returns>
 public static IHostBuilder CreateHostBuilder(string[] args) =>
     Host.CreateDefaultBuilder(args)
         .ConfigureServices((hostContext,services) =>
         {
             services.Configure<sqlSettingsModel>(Configuration.GetSection(key: sqlSettingsModel.sqlSettingsKey));                                        
             services.AddSingleton<MonitorLoop>();
             services.AddHostedService<QueuedHostedService>();
             services.AddSingleton<IBackgroundTaskQueue,BackgroundTaskQueue>();
             services.AddSingleton<IsqlDataAccessService,sqlDataAccessService>();
             })
            .UseSerilog();
    }

这是我在 Program.cs 中的 Main 方法的样子：

/// <summary>
/// Start run loop
/// </summary>
/// <param name="args"></param>
public static async Task<int> Main(string[] args)
{
    Log.Logger = new LoggerConfiguration()               
       .Enrich.FromLogContext()               
       .Writeto.Async(a => a.Console(
           outputTemplate: "[{Timestamp:HH:mm:ss} {Level:u3}] {Message:lj} {Properties:j}{NewLine}{Exception}"))
       .Writeto.Async(a => 
           a.File("WorkerService.log",rollingInterval: RollingInterval.Day,outputTemplate: "[{Timestamp:HH:mm:ss} {Level:u3}] {Message:lj} {Properties:j}{NewLine}{Exception}"))
       .CreateLogger();
    try
    {
        Log.information("Starting Worker");
        var host = CreateHostBuilder(args).Build();                
        var monitorLoop = host.Services.GetrequiredService<MonitorLoop>();
        await monitorLoop.StartMonitorLoopAsync();
    }
    catch (Exception err)
    {
        Log.Fatal(err,"Host terminated unexpectedly");
    }
    finally
    {
        Log.CloseAndFlush();
    }
    return 1;
}

解决方法

代码创建了一个主机，但从不运行它。它只检索 MonitorLoop 服务并在其上运行一个方法。

public static void Main(string[] args)
{
    CreateHostBuilder(args).Build().Run();
}

文档示例通过调用 Run 来运行主机。不等待对 monitorLoop.StartMonitorLoop 的调用，否则将无法调用 Run

public static void Main(string[] args)
{
    var host =CreateHostBuilder(args).Build();
    
    var monitorLoop = host.Services.GetRequiredService<MonitorLoop>();
    monitorLoop.StartMonitorLoop();

    host.Run();
}