C# Academy · leksjon

Frister, kansellering og interceptorer

Bruk tidsavbrudd med frister, viderefør CancellationToken, og legg til tverrgående funksjonalitet via gRPC-interceptorer.

Leksjon 4 av 412 trinn

Frister, kansellering og interceptorer er en gratis leksjon i C# Academy på CoddyKit. Dette er leksjon 4 av 4. Du kan lese hele leksjonen gratis nedenfor – og deretter øve praktisk i nettleseren med en innebygd kodeeditor og en AI-veileder som er tilgjengelig døgnet rundt. Den er en del av læringsløpet i C# Academy, og fremdriften din synkroniseres mellom nettet og CoddyKit-appen. Kurset i C# Academy inneholder totalt 4 leksjoner.

Pålitelighet i gRPC: tidsfrister og kansellering

Produksjonstjenester med gRPC må håndtere to kritiske hensyn for pålitelighet: tidsfrister (hvor lenge klienten vil vente) og kansellering (å stoppe arbeid tidlig). Til sammen hindrer de ressursutarming og kaskadefeil.

Angi en tidsfrist for et kall

En tidsfrist er et absolutt tidspunkt innen hvilket kallet må være fullført. Angi den med CallOptions. Hvis den overskrides, mottar serveren en kansellering, og klienten får StatusCode.DeadlineExceeded.

var deadline = DateTime.UtcNow.AddSeconds(5);

var reply = await client.GetOrderAsync(
    new GetOrderRequest { Id = 42 },
    deadline: deadline);

// Or via CallOptions:
var options = new CallOptions(deadline: deadline);
var reply2 = await client.GetOrderAsync(
    new GetOrderRequest { Id = 42 }, options);

Håndtere DeadlineExceeded på klienten

Fang RpcException og kontroller statuskoden for å skille en utløpt tidsfrist fra andre feil.

try
{
    var reply = await client.GetOrderAsync(
        new GetOrderRequest { Id = 42 },
        deadline: DateTime.UtcNow.AddSeconds(3));
}
catch (RpcException ex) when (ex.StatusCode == StatusCode.DeadlineExceeded)
{
    Console.WriteLine("Call timed out");
}
catch (RpcException ex)
{
    Console.WriteLine($"gRPC error: {ex.Status.Detail}");
}

Overholde tidsfrister på serveren

Serveren bør kontrollere context.CancellationToken under langvarig arbeid. Når tidsfristen utløper, kanselleres dette tokenet automatisk.

public override async Task<ReportResponse> GenerateReport(
    ReportRequest request,
    ServerCallContext context)
{
    var ct = context.CancellationToken;

    // Pass ct to every async call — work stops when deadline hits
    var data = await _db.FetchLargeDatasetAsync(request.Filters, ct);
    var report = await _reportEngine.BuildAsync(data, ct);

    ct.ThrowIfCancellationRequested(); // explicit check before CPU work
    return MapToResponse(report);
}

Videreføring av CancellationToken

Viderefør alltid serverens CancellationToken gjennom hele kjeden av asynkrone kall. Hvis det ignoreres, fortsetter kansellerte kall å bruke ressurser unødvendig.

// GOOD: token flows through the call chain
await _db.Products.AsNoTracking()
    .Where(p => p.IsActive)
    .ToListAsync(context.CancellationToken); // cancels if client disconnects

// BAD: ignores cancellation
await _db.Products.ToListAsync(); // keeps running after deadline

gRPC-interceptorer: konseptet

Interceptorer er gRPCs motstykke til ASP.NET Core-middleware – de kjører før og etter RPC-kall og kan inspisere eller endre forespørsler, svar og unntak. De egner seg godt til logging, autentisering og retry-logikk.

Opprette en interceptor på serversiden

Arv fra Interceptor og overstyr metoden for RPC-typen du vil avskjære. Kall continuation for å gå videre til den faktiske behandleren.

using Grpc.Core.Interceptors;

public class LoggingInterceptor : Interceptor
{
    private readonly ILogger<LoggingInterceptor> _logger;
    public LoggingInterceptor(ILogger<LoggingInterceptor> l) => _logger = l;

    public override async Task<TResponse> UnaryServerHandler<TRequest, TResponse>(
        TRequest request,
        ServerCallContext context,
        UnaryServerMethod<TRequest, TResponse> continuation)
    {
        _logger.LogInformation("gRPC call: {Method}", context.Method);
        var sw = System.Diagnostics.Stopwatch.StartNew();
        var response = await continuation(request, context);
        _logger.LogInformation("Completed in {Ms}ms", sw.ElapsedMilliseconds);
        return response;
    }
}

Registrere serverinterceptorer

Registrer interceptorer globalt (for alle tjenester) eller per tjeneste i Program.cs. DI-beholderen løser konstruktøravhengighetene.

// Globally for all gRPC services:
builder.Services.AddGrpc(opt =>
    opt.Interceptors.Add<LoggingInterceptor>());

// Or per service:
builder.Services.AddGrpc();
builder.Services.AddSingleton<LoggingInterceptor>();

app.MapGrpcService<OrderService>()
   .AddInterceptor<LoggingInterceptor>();

Klientinterceptorer

Klientinterceptorer omslutter utgående kall – nyttig for å legge til autentiseringsheadere, retry-logikk eller korrelasjons-ID-er uten å endre hvert kallsted.

public class AuthInterceptor : Interceptor
{
    private readonly ITokenProvider _tokens;
    public AuthInterceptor(ITokenProvider t) => _tokens = t;

    public override AsyncUnaryCall<TResponse> AsyncUnaryCall<TRequest, TResponse>(
        TRequest request,
        ClientInterceptorContext<TRequest, TResponse> context,
        AsyncUnaryCallContinuation<TRequest, TResponse> continuation)
    {
        var headers = context.Options.Headers ?? new Metadata();
        headers.Add("authorization", $"Bearer {_tokens.GetToken()}");
        var newContext = new ClientInterceptorContext<TRequest, TResponse>(
            context.Method, context.Host,
            context.Options.WithHeaders(headers));
        return continuation(request, newContext);
    }
}

// Attach to channel:
var invoker = channel.Intercept(new AuthInterceptor(tokenProvider));
var client = new OrderService.OrderServiceClient(invoker);

Unntaksinterceptor

En interceptor for unntak på serversiden konverterer ubehandlede unntak til RpcExceptions, slik at interne detaljer ikke lekker ut til klientene.

public class ExceptionInterceptor : Interceptor
{
    public override async Task<TResponse> UnaryServerHandler<TRequest, TResponse>(
        TRequest request,
        ServerCallContext context,
        UnaryServerMethod<TRequest, TResponse> continuation)
    {
        try
        {
            return await continuation(request, context);
        }
        catch (NotFoundException ex)
        {
            throw new RpcException(new Status(StatusCode.NotFound, ex.Message));
        }
        catch (Exception ex)
        {
            throw new RpcException(new Status(StatusCode.Internal, "Internal error"));
        }
    }
}

Hurtigsjekk

Hva skjer når et gRPC-kall overskrider tidsfristen?

Oppsummering: tidsfrister, kansellering og interceptorer

Viktigste punkter:

  • Angi alltid tidsfrister for klientkall for å hindre ubegrenset venting
  • Kontroller context.CancellationToken på serveren og send det videre til alle asynkrone kall
  • Interceptorer håndterer tverrgående hensyn (logging, autentisering, feilkartlegging) uten å fylle tjenestekoden med slik logikk
  • Serverinterceptorer: overstyr Unary/Stream-handlermetoder og kall continuation
  • Klientinterceptorer: kobles til kanalens invoker-kjede
Gratis å komme i gang

Lær deg C# med en AI-veileder – gratis

Skriv og kjør ekte kode i nettleseren, få umiddelbar hjelp fra en AI-veileder som er tilgjengelig døgnet rundt, og fortsett der du slapp – på nettet eller i appen.

Kurs
93
Leksjoner
346

Ofte stilte spørsmål

Er leksjonen «Frister, kansellering og interceptorer» gratis?

Ja – hele teksten i «Frister, kansellering og interceptorer» er gratis å lese her på nettet. For å øve interaktivt med en innebygd kodeeditor og en AI-veileder som er tilgjengelig døgnet rundt, og for å låse opp resten av C# Academy-kurset, kan du oppgradere til CoddyKit PRO. Kurset i C# Academy inneholder totalt 4 leksjoner.

Hva lærer jeg i «Frister, kansellering og interceptorer»?

Bruk tidsavbrudd med frister, viderefør CancellationToken, og legg til tverrgående funksjonalitet via gRPC-interceptorer. Du øver på C# Academy med praktisk kode som du kjører direkte i nettleseren, mens en AI-veileder som er tilgjengelig døgnet rundt, svarer på spørsmålene dine mens du jobber deg gjennom leksjonen.

Trenger jeg erfaring for å begynne med C# Academy?

Ingen tidligere erfaring er nødvendig. C# Academy på CoddyKit er lagt opp for både nybegynnere og viderekomne, så De kan begynne her eller helt fra start og lære i Deres eget tempo. Dette er leksjon 4 av 4.

Hvor lang tid tar leksjonen «Frister, kansellering og interceptorer»?

De fleste CoddyKit-leksjoner tar omtrent 5–10 minutter. Hver leksjon er kort og interaktiv, slik at De gjør jevne fremskritt og kan fortsette akkurat der De slapp – både på nettet og i appen.

Kan jeg skrive og kjøre kode i denne C# Academy-leksjonen?

Ja. Alle C# Academy-leksjoner har en innebygd kodeeditor, slik at De kan skrive og kjøre ekte kode direkte i nettleseren og få umiddelbar tilbakemelding fra AI – uten lokal konfigurering.

Alle leksjonene i dette kurset

  1. Grunnleggende om gRPC og Protobuf
  2. Unary- og serverstrømmende RPC-er
  3. Klient- og toveis strømming
  4. Frister, kansellering og interceptorer
← Tilbake til C# Academy