c# asp.net core等待长时间运行的任务在一段时间后停止

Question

最近我在 StackOverflow 上问了一个关于 asp.net core 中长时间运行的后台任务的问题。从那时起，我从https://docs.microsoft.com/cs-cz/aspnet/core/fundamentals/host/hosted-services?view=aspnetcore-5.0&tabs=visual-studio 开始尝试一切，如果我做我所做的，它会在某个时候停止。即使我将它包装在 IServiceProvider.CreateScope 中并等待它，它也会停止。唯一我仍然没有尝试并且我试图避免它的事情是创建专用的.net 应用程序，它只会读取队列并执行它应该做的事情。而且我认为为它创建队列有点矫枉过正，我只想在后台异步运行它，但它只是停止了。抱歉，如果这是一些愚蠢的错误，但这是我的第一个 asp.net 项目，我正在修复这个问题一周。

这是队列版本

public class QueuedHostedService : BackgroundService
    {
        private readonly IServiceProvider _serviceProvider;
        private readonly IBackgroundTaskQueue _queue;
        private readonly ILogger<QueuedHostedService> _logger;

        public QueuedHostedService(IServiceProvider serviceProvider, IBackgroundTaskQueue queue, ILogger<QueuedHostedService> logger)
        {
            _serviceProvider = serviceProvider;
            _queue = queue;
            _logger = logger;
        }

        protected override async Task ExecuteAsync(CancellationToken stoppingToken)
        {
            await BackgroundProcessing(stoppingToken);
        }

        private async Task BackgroundProcessing(CancellationToken stoppingToken)
        {
            while (!stoppingToken.IsCancellationRequested)
            {
                var workItem = await _queue.DequeueAsync(stoppingToken);

                try
                {
                    var scope = _serviceProvider.CreateScope();
                    var scrapeUrl = scope.ServiceProvider.GetRequiredService<IScopedScrapeUrl>();
                    // The scrape Sound Cloud Task is taking hours
                    await scrapeUrl.ScrapeSoundCloud(workItem);
                }catch(Exception ex)
                {
                    _logger.LogError($"Error occurred executing {nameof(workItem)},\n{ex}");
                }
            }
        }

        public override async Task StopAsync(CancellationToken stoppingToken)
        {
            _logger.LogInformation("Consume Scoped Scrape Url Hosted Service is stopping.");

            await base.StopAsync(stoppingToken);
        }

public class BackgroundScrapeQueue : IBackgroundTaskQueue
    {
        private readonly Channel<Scrape> _queue;
        private readonly ILogger<BackgroundScrapeQueue> _logger;

        public BackgroundScrapeQueue(ILogger<BackgroundScrapeQueue> logger)
        {
            var options = new BoundedChannelOptions(100)
            {
                FullMode = BoundedChannelFullMode.Wait
            };
            _queue = Channel.CreateBounded<Scrape>(options);
            _logger = logger;
        }

        public async ValueTask<Scrape> DequeueAsync(CancellationToken stoppingToken)
        {
            var workItem = await _queue.Reader.ReadAsync(stoppingToken);

            return workItem;
        }

        public async ValueTask QueueBackgroundWorkItemAsync(Scrape scrape)
        {
            if(scrape == null)
            {
                _logger.LogError("Invalid Scrape for queue");
                return;
            }

            await _queue.Writer.WriteAsync(scrape);
        }
    }

    public interface IBackgroundTaskQueue
    {
        ValueTask QueueBackgroundWorkItemAsync(Scrape scrape);

        ValueTask<Scrape> DequeueAsync(CancellationToken stoppingToken);
    }

Answer 1

它会在某个时间停止。即使我将它包装在 IServiceProvider.CreateScope 中并等待它，它也会停止。

是的。这就是内存后台服务的问题。它们可以随时停止，因为它们托管在 ASP.NET 进程中，该进程确定在请求完成时关闭是安全的。 ASP.NET 实际上会请求关闭，然后等待一段时间让服务完成，但还有一个计时器，如果它们在 10 分钟左右没有完成，它们将被强制退出。

底线是shutdowns are normal。任何假定它可以在 ASP.NET 中无限期运行的代码本质上都是错误的。

唯一我仍然没有尝试并且我正在努力避免它的事情是创建专门的 .net 应用程序，它只会读取队列并执行它应该做的事情。

那是only reliable solution。