رمز غير متزامن في Startup ASP.NET Core: 4 طرق للتنقل GetAwaiter (). GetResult ()

خلفية عن مهمة العمل

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;
}

أنا منزعج من GetAwaiter (). GetResult () ، لكن مايكروسوفت ليست كذلك

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

دور المهام غير المتزامنة في بدء خدمة ويب

المشكلة: من الضروري بدء تشغيل خدمة الويب بحيث تعالج طلبات عملائها ، ولكن هناك مجموعة من بعض العمليات المطولة (نسبيًا) ، والتي بدونها إما لا تستطيع الخدمة الاستجابة للعميل ، أو ستكون إجاباتها غير صحيحة.

• التحقق من صحة التكوينات المكتوبة بشدة.
• تعبئة ذاكرة التخزين المؤقت.
• اتصال أولي بقاعدة البيانات أو الخدمات الأخرى.
• JIT وتحميل التجميع (الاحماء الخدمة).
• ترحيل قاعدة البيانات. هذا أحد أمثلة أندرو لوك ، لكنه يعترف بنفسه أنه بعد كل شيء ، هذه العملية غير مرغوب فيها عند بدء الخدمة .

الحل # 1: حل عملي يمكن أن يربك الورثة

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>();
}

الحل رقم 2: دمج العمليات غير المتزامنة في 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();

الحل رقم 3: لأولئك الذين تحولوا إلى 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
    }
}

الحل # 4: قصة الفحص الصحي و Kubernetes

, , , . Kestrel , , « ».

حدد دائمًا مسبار الجاهزية.

إذا لم يكن لديك مسبار جاهز ، تصبح قرونك نقاط نهاية للخدمات على الفور تقريبًا. إذا كان التطبيق الخاص بك يستغرق وقتًا طويلاً في التحضير لقبول الطلبات الواردة ، فإن طلبات العملاء للخدمة ستبدأ أيضًا في تشغيل حوامل غير جاهزة لقبول الاتصالات الواردة. نتيجة لذلك ، سيتلقى العملاء خطأ "تم رفض الاتصال".

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)
    {...}
}

الموجودات