重新启动失败的背景服务

Question

因此，我拥有这样的背景服务，看起来像这样。

public class MyBackgroundService: BackgroundService
{ 
    public MyBackgroundService(){}

    protected override Task ExecuteAsync(CancellationToken stoppingToken)
    {
        new Thread(() => new MessageHandler().Process(stoppingToken).Start();
        return Task.CompletedTask;
    }      
}

如果过程方法会引发例外，那么无论如何是否可以尝试重新启动 背景服务或创建新的MessageHandler并运行过程？

编辑，反馈和谷歌搜索后，我想这样的事情

protected override Task ExecuteAsync(CancellationToken cancellationToken)
{       
    Task.Run(() => RunConsumer(cancellationToken)).Start();
    return Task.CompletedTask;
}

private void RunConsumer(CancellationToken cancellationToken)
{
    while (true)
    {
        using var scope = _serviceScopeFactory.CreateScope();
        var myConsumer = scope.ServiceProvider.GetRequiredService<IMyConsumer>();

        Task.Run(() => { new Thread(() => myConsumer.Start()).Start(); })
        .ContinueWith(t =>
        {
            if (t.IsFaulted) {/* Log t.Exception and retry x times */}
            if (t.IsCompleted) {/* Should not not happen in my case */}
        });

    }
}

Answer 1

您可以像这样编写主循环：

protected override Task ExecuteAsync(CancellationToken cancellationToken)
{
    while(!cancellationToken.IsCancellationRequested) 
    {
        try {
            await RunConsumer(cancellationToken);
        }
        catch (Exception e)
        {
            // log exception
        }
        await Task.Delay(TimeSpan.FromSeconds(30)); // To prevent restarting too often
    }
    return Task.CompletedTask;
}

关键点是

• 通过检查concellationToken.iscancellationRequested，该服务将在请求时停止，例如，当该过程优雅地结束时，
• 请捕获所有例外并忽略它，并忽略它，因此可以再次运行任务。
• task.delay确保该过程不会经常重新启动。

在runco​​nsumer中，您可以使用

await Task.Run(() => new MessageHandler().Process(stoppingToken).Start());

它通常最好使用异步/等待，因此您不必手动进行延续和错误检查。