为什么工作服务模板没有作为 systemd 正常关闭？

如何解决为什么工作服务模板没有作为 systemd 正常关闭？

我使用工作器服务模板创建了一个新项目并添加了两行。

worker 停止后的额外日志输出：

    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        while (!stoppingToken.IsCancellationRequested)
        {
            _logger.Loginformation("Worker running at: {time}",DateTimeOffset.Now);
            await Task.Delay(1000,stoppingToken);
        }
        _logger.Loginformation("Worker stopped."); // <---- extra log output
    }

Program.cs 中的一个用于 systemd 支持：

    public static IHostBuilder CreateHostBuilder(string[] args) =>
        Host.CreateDefaultBuilder(args)
            .UseSystemd() // <---- systemd support
            .ConfigureServices((hostContext,services) =>
            {
                services.AddHostedService<Worker>();
            });

我可以在我的 ubuntu 服务器上启动和停止服务，但是在 journalctl 输出中没有出现额外的日志行：

worker[25468]: WorkerService.Worker[0] Worker running at: 02/10/2021 23:07:34 +01:00
systemd[1]: Stopping Long running service/daemon created from .NET worker template...
worker[25468]: Microsoft.Hosting.Lifetime[0] Application is shutting down...
// here I would expect "Worker stopped."
systemd[1]: Stopped Long running service/daemon created from .NET worker template.

如何确保我的后台服务在服务停止之前运行完成？

我发现了这个非常相似的问题，不幸的是它没有令人满意的答案： .NET core BackgroundService does not shut down gracefully as daemon

但我不敢相信这没有简单的答案。

更新：

我找到了一种优雅地关闭服务的方法。 我没有等待 stoppingToken 中的 ExecuteAsync() 被触发，而是检查一个标志，即服务是否应该停止运行，该标志在 StopAsync() 方法中设置。使用 ManualResetEvent 然后我可以决定服务是否应该等待后台服务完成其工作并正常关闭，或者是否应该在给定的超时后强制关闭。 这可能不是最优雅的方式，但它似乎是我想要的。

    private bool _stopRunning;
    private ManualResetEvent _mre;
    private int _graceperiod = 5000;
    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        _stopRunning = false;
        _mre = new ManualResetEvent(false);
        int item = 1;
        while (!_stopRunning)
        {
            _logger.Loginformation("Working on item " + item);
            await Task.Delay(3000);
            _logger.Loginformation("still working on item " + item);
            await Task.Delay(3000);
            _logger.Loginformation("Finished working on item " + item);
            item++;
        }

        _logger.Loginformation("Worker stopped.");
        _mre.Set();
    }

    public override async Task StopAsync(CancellationToken cancellationToken)
    {
        _stopRunning = true;
        bool gracefulShutdown = _mre.WaitOne(_graceperiod);
        if (gracefulShutdown)
        {
            _logger.Loginformation("Shut down service gracefully");
        }
        else
        {
            _logger.Loginformation("Force shut down service");
        }
        await base.StopAsync(cancellationToken);
    }

不过我还是想了解一下，stopingToken 应该如何触发。

解决方法

您可以覆盖 StopAsync 类的 BackgroundService 方法。像这样

public override Task StopAsync(CancellationToken cancellationToken)
{
    // add your logging or anything extra here
    return base.StopAsync(cancellationToken);
}