如何在 ASP.Net core 3.1 API 中启动 BackgroundService

Question

我已尝试关注this tutorial，了解如何创建后台工作人员。

大部分内容对我没有用，所以我没有包括在内。我不需要排队。我只需要让这个后台工作人员每 X 小时在后台运行一次 我的工人看起来像这样。不幸的是，它似乎从不调用 ExecuteAsync 方法

public class EnergySolutionBackgroundWorker : BackgroundService
{       
    private readonly ILogger<EnergySolutionBackgroundWorker> _logger;

    public EnergySolutionBackgroundWorker(ILogger<EnergySolutionBackgroundWorker> logger)
    {         
        _logger = logger;
    }

    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        _logger.LogInformation("{Type} is now running in the background.", nameof(BackgroundWorker));

        await BackgroundProcessing(stoppingToken);
    }

    public override Task StopAsync(CancellationToken cancellationToken)
    {
        _logger.LogCritical("The {Type} is stopping due to a host shutdown.", nameof(BackgroundWorker));

        return base.StopAsync(cancellationToken);
    }

    private async Task BackgroundProcessing(CancellationToken stoppingToken)
    {
        while (!stoppingToken.IsCancellationRequested)
        {
            try
            {
                await Task.Delay(new TimeSpan(0, 0, 1), stoppingToken);

                // Doing some tasks
            }
            catch (Exception ex)
            {
                _logger.LogCritical("An error occurred when publishing a book. Exception: {@Exception}", ex);
            }
        }
    }        
}

在 Startup.cs 我有以下内容：

public void ConfigureServices(IServiceCollection services)
    {
        services.AddControllers();

        services.AddHostedService<EnergySolutionBackgroundWorker>();
    }

据我了解，这应该足以让它在启动期间自动启动后台工作程序，但事实并非如此。我做错了什么？

Answer 1

1. 您可以在启动功能中添加计时器。 定时后台任务使用 System.Threading.Timer 类。计时器触发任务的 DoWork 方法。计时器在 StopAsync 上禁用，并在服务容器在 Dispose 上释放时释放：

internal class TimedHostedService : IHostedService, IDisposable
{
    private readonly ILogger _logger;
    private Timer _timer;

    public TimedHostedService(ILogger<TimedHostedService> logger)
    {
        _logger = logger;
    }

    public Task StartAsync(CancellationToken cancellationToken)
    {
        _logger.LogInformation("Timed Background Service is starting.");

        _timer = new Timer(DoWork, null, TimeSpan.Zero, 
            TimeSpan.FromSeconds(5));

        return Task.CompletedTask;
    }

    private void DoWork(object state)
    {
        _logger.LogInformation("Timed Background Service is working.");
    }

    public Task StopAsync(CancellationToken cancellationToken)
    {
        _logger.LogInformation("Timed Background Service is stopping.");

        _timer?.Change(Timeout.Infinite, 0);

        return Task.CompletedTask;
    }

    public void Dispose()
    {
        _timer?.Dispose();
    }
}

1. 有一个reference

Answer 2

我相信我找到了答案！在第一次调用 API 之前不会运行 Startup.cs。在我的一个控制器中调用一个简单的测试方法后，调用了 BackgroundProcessing 方法 这有点烦人，因为我希望以后可以创建一个后台工作程序，将大量数据加载到内存中，而不是在第一次调用时发生