确保 .NET Core BackgroundService 初始化完成后再处理接口请求


在JOC开发框架中,在现代应用程序开发中,确保后台服务在完成初始化后再处理接口请求是至关重要的。在 .NET Core 中,我们可以通过使用 BackgroundService 来实现长期运行的后台任务。但是,如何确保在后台服务完成初始化后再开始处理接口请求呢?本文将详细介绍如何通过自定义中间件和 TaskCompletionSource 来实现这一功能。

1. 创建 BackgroundService 并使用 TaskCompletionSource

首先,我们需要定义一个 BackgroundService 并使用 TaskCompletionSource 来跟踪初始化状态。

C# 全选
using System;
using System.Threading;
using System.Threading.Tasks;
using Microsoft.Extensions.Hosting;
using Microsoft.Extensions.Logging;

public class MyBackgroundService : BackgroundService
{
    private readonly ILogger<MyBackgroundService> _logger;
    private readonly TaskCompletionSource<bool> _initializationTcs;

    public MyBackgroundService(ILogger<MyBackgroundService> logger, TaskCompletionSource<bool> initializationTcs)
    {
        _logger = logger;
        _initializationTcs = initializationTcs;
    }

    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        _logger.LogInformation("MyBackgroundService is starting.");

        // 模拟初始化工作
        await Task.Delay(5000, stoppingToken);

        // 标记初始化完成
        _initializationTcs.TrySetResult(true);

        _logger.LogInformation("MyBackgroundService has finished initialization.");

        // 继续执行其他后台任务
        while (!stoppingToken.IsCancellationRequested)
        {
            _logger.LogInformation("MyBackgroundService is doing work.");
            await Task.Delay(5000, stoppingToken); // 模拟其他工作
        }

        _logger.LogInformation("MyBackgroundService is stopping.");
    }
}

2. 创建初始化等待中间件

接下来,我们创建一个自定义中间件,确保在 BackgroundService 完成初始化之前不处理任何接口请求。

C# 全选
using Microsoft.AspNetCore.Http;
using System.Threading.Tasks;
using System.Threading;

public class InitializationMiddleware
{
    private readonly RequestDelegate _next;
    private readonly Task _initializationTask;

    public InitializationMiddleware(RequestDelegate next, Task initializationTask)
    {
        _next = next;
        _initializationTask = initializationTask;
    }

    public async Task InvokeAsync(HttpContext context)
    {
        await _initializationTask; // 等待初始化完成
        await _next(context); // 处理下一个中间件
    }
}

3. 在 Startup.cs 中注册中间件和服务

Startup.cs 中配置服务和中间件,以确保初始化等待中间件被正确注册。

C# 全选
using Microsoft.AspNetCore.Builder;
using Microsoft.AspNetCore.Hosting;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;
using System.Threading.Tasks;

public class Startup
{
    public void ConfigureServices(IServiceCollection services)
    {
        var initializationTcs = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
        services.AddSingleton(initializationTcs);
        services.AddHostedService<MyBackgroundService>();

        services.AddControllers();
    }

    public void Configure(IApplicationBuilder app, IWebHostEnvironment env, TaskCompletionSource<bool> initializationTcs)
    {
        if (env.IsDevelopment())
        {
            app.UseDeveloperExceptionPage();
        }

        // 注册初始化等待中间件
        app.UseMiddleware<InitializationMiddleware>(initializationTcs.Task);

        app.UseRouting();

        app.UseEndpoints(endpoints =>
        {
            endpoints.MapControllers();
        });
    }
}

总结

通过创建自定义中间件 InitializationMiddleware,可以确保在 BackgroundService 完成初始化之前不处理任何接口请求。这个中间件会等待 TaskCompletionSource 的任务完成,然后再继续处理请求。这样可以确保所有接口调用在 MyBackgroundService 完成初始化后才被处理,从而保证服务的稳定性和可靠性。

 

 

版权声明:本文为YES开发框架网发布内容,转载请附上原文出处连接
张国生
上一篇:C# Dictionary<string,string> TryGetValue不要区分大小写,不区分大小写的字典
下一篇:在Vue 3项目中使用TypeScript和Pinia进行持久化状态管理和初始化操作
评论列表

发表评论

评论内容
昵称:
关联文章

确保 .NET Core BackgroundService 初始化完成处理接口请求
使用.NET 6开发TodoList应用(11)——使用FluentValidation和MediatR实现接口请求验证
使用.NET 6开发TodoList应用(10)——实现DELETE请求以及HTTP请求幂等性
使用.NET 6开发TodoList应用(19)——处理OPTION和HEAD请求
.net core MVC 使用 jquery ajax请求 Post json
ASP.NET Core统一接口返回模型
使用.NET 6开发TodoList应用(9)——实现PUT请求
.NET Core发布IIS部署无法访问静态文件
.NET Core ResponseCache 浏览器缓存
.NET Core生成没有Nuget的dll文件
使用.NET 6开发TodoList应用(7)——使用AutoMapper实现GET请求
使用.NET 6开发TodoList应用(6)——使用MediatR实现POST请求
.NET Core 自定义中间件 Middleware
使用.NET 6开发TodoList应用(8)——实现全局异常处理
ABP VNext框架中Winform终端的开发和客户端授权信息的处理
.NET IIS第一次访问慢,程序池被回收问题,IIS初始化(启用预加载)
.NET5 ASP.NET Core 添加API限流
.NET Core 实现动态代理做AOP(面向切面编程)
API接口主从表数据(Master-Detail),从表数据的两种处理方式
.NET Core中的鉴权授权正确方式(.NET5)

联系我们
联系电话:15090125178(微信同号)
电子邮箱:garson_zhang@163.com
站长微信二维码
微信二维码