Kode asynchronous di Startup ASP.NET Core: 4 cara untuk berkeliling GetAwaiter (). GetResult ()

Latar belakang tentang tugas pekerjaan

services
      .AddAuthentication()
      .AddJwtBearer(); 

public static AuthenticationBuilder AddJwtAuthentication(this AuthenticationBuilder builder, AuthJwtOptions options)
{
    var signingKeys = new List<SecurityKey>();

    var jwtBearerOptions = new JwtBearerOptions {Authority = options?.Authority};
    
    new JwtBearerPostConfigureOptions().PostConfigure(string.Empty, jwtBearerOptions);
    try
    {
        var config = jwtBearerOptions.ConfigurationManager
            .GetConfigurationAsync(new CancellationTokenSource(options?.AuthorityTimeoutInMs ?? 5000).Token)
            .GetAwaiter().GetResult();
        var providerSigningKeys = config.SigningKeys;
        signingKeys.AddRange(providerSigningKeys);
    }
    catch (Exception)
    {
        // ignored
    }

    builder
        .AddJwtBearer(options =>
        {
            options.TokenValidationParameters = new TokenValidationParameters
            {
                // ...
                IssuerSigningKeys = signingKeys,
                // ...
            };
        });
    return builder;
}

Saya terganggu oleh GetAwaiter (). GetResult (), tetapi Microsoft tidak

public override void Load() => LoadAsync().ConfigureAwait(false).GetAwaiter().GetResult();

Peran tugas asinkron dalam memulai layanan web

Masalah: perlu untuk memulai layanan web sehingga memproses permintaan kliennya, tetapi ada serangkaian operasi (yang relatif) lama, yang tanpanya layanan tidak dapat menanggapi klien, atau jawabannya tidak akan benar.

• Validasi konfigurasi sangat diketik.
• Mengisi cache.
• Koneksi awal ke database atau layanan lain.
• Pemuatan JIT dan perakitan (pemanasan layanan).
• Migrasi Basis Data. Ini adalah salah satu contoh Andrew Lock, tetapi dia sendiri mengakui bahwa bagaimanapun juga, operasi ini tidak diinginkan ketika memulai layanan .

Solusi # 1: solusi kerja yang dapat membingungkan ahli waris

public class Program
{
   public static async Task Main(string[] args)
   {
       IWebHost webHost = CreateWebHostBuilder(args).Build();

       using (var scope = webHost.Services.CreateScope())
       {
           //   
           var myService = scope.ServiceProvider.GetRequiredService<MyService>();

           await myService.DoAsyncJob();
       }

       await webHost.RunAsync();
   }

   public static IWebHostBuilder CreateWebHostBuilder(string[] args) =>
       WebHost.CreateDefaultBuilder(args)
           .UseStartup<Startup>();
}

Solusi # 2: sematkan operasi asinkron dalam DI

public interface IStartupTask
{
    Task ExecuteAsync(CancellationToken cancellationToken = default);
}

public static class ServiceCollectionExtensions
{
    public static IServiceCollection AddStartupTask<T>(this IServiceCollection services)
        where T : class, IStartupTask
        => services.AddTransient<IStartupTask, T>();
}

public static class StartupTaskWebHostExtensions
{
    public static async Task RunWithTasksAsync(this IWebHost webHost, CancellationToken cancellationToken = default)
    {
        //      DI
        var startupTasks = webHost.Services.GetServices<IStartupTask>();

        //   
        foreach (var startupTask in startupTasks)
        {
            await startupTask.ExecuteAsync(cancellationToken);
        }

        //    
        await webHost.RunAsync(cancellationToken);
    }
}

await CreateWebHostBuilder(args).Build().Run();

await CreateWebHostBuilder(args).Build().RunWithTasksAsync();

Solusi # 3: bagi mereka yang beralih ke ASP.NET Core 3.x

public class WebHost
{
    public virtual async Task StartAsync(CancellationToken cancellationToken = default)
    {
        // ... initial setup
        await Server.StartAsync(hostingApp, cancellationToken).ConfigureAwait(false);

        // Fire IApplicationLifetime.Started
        _applicationLifetime?.NotifyStarted();

        // Fire IHostedService.Start
        await _hostedServiceExecutor.StartAsync(cancellationToken).ConfigureAwait(false);

        // ...remaining setup
    }
}

public class WebHost
{
    public virtual async Task StartAsync(CancellationToken cancellationToken = default)
    {
        // ... initial setup

        // Fire IHostedService.Start
        await _hostedServiceExecutor.StartAsync(cancellationToken).ConfigureAwait(false);

        // ... more setup
        await Server.StartAsync(hostingApp, cancellationToken).ConfigureAwait(false);

        // Fire IApplicationLifetime.Started
        _applicationLifetime?.NotifyStarted();

        // ...remaining setup
    }
}

Solusi # 4: kisah pemeriksaan kesehatan dan Kubernet

, , , . Kestrel , , « ».

Selalu tentukan kesiapan pemeriksaan.

Jika Anda tidak memiliki probe kesiapan, pod Anda menjadi titik akhir layanan hampir secara instan. Jika aplikasi Anda terlalu lama bersiap untuk menerima permintaan masuk, permintaan klien untuk layanan ini juga akan memulai pod yang belum siap menerima koneksi masuk. Akibatnya, klien akan menerima kesalahan "Sambungan ditolak".

public class LongTaskHostedService : IHostedService
{
    public async Task StartAsync(CancellationToken cancellationToken)
    {
            Console.WriteLine("Long task started...");
            await Task.Delay(5000, cancellationToken);
            Console.WriteLine("Long task finished.");
    }

    public Task StopAsync(CancellationToken cancellationToken)
    {...}
}

temuan