स्टार्टअप ASP.NET कोर में एसिंक्रोनस कोड: GetAwaiter ()। GetResult () के आसपास आने के 4 तरीके।

कार्य कार्य के बारे में पृष्ठभूमि

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 (), लेकिन Microsoft नहीं है

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: स्वास्थ्य जांच और कुबेरनेट की कहानी

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

जाँच - परिणाम