Nella pubblicazione precedente abbiamo visto come sia possibile ottenere le funzionalità dell'Health Check all'interno di un servizio gRPC. Oggi vedremo un altro middleware, molto comune nelle Web.API, utilizzato in un'applicazione gRPC, in grado di gestire gli errori in modo tale che la risposta alla chiamata rispetti un formato standardizzato e interpretabile.
Come per tutti i servizi l'implementazione deve partire dal file Program.cs, aggiungendo un servizio Interceptor all'interno delle opzioni di inizializzazione gRPC:
// Add services to the container. builder.Services.AddGrpc(options => { options.Interceptors.Add<LoggerInterceptor>(); });
Prima di analizzare il codice presente in LoggerInterceptor, modifichiamo il servizio GreeterService in modo tale che restituisca un errore, e creiamo un'applicazione console incaricata di effettuare le chiamate.
public override Task<HelloReply> SayHello(HelloRequest request, ServerCallContext context) { throw new NotImplementedException("Errore"); }
Per configurare l'applicazione client dobbiamo ricordarci di importare i file .proto, come specificato nel nostro articolo su gRPC (https://www.aspitalia.com/articoli/asp.net-core5/grpc/usare-grpc-infrastruttura-nostri-servizi-web-p-3.aspx#title_1), successivamente possiamo procedere alla creazione di una nuova istanza GrpcChannel e chiamare l'endpoint modificato in precedenza.
var grpcEndpoint = "https://localhost:7030"; using var channel = GrpcChannel.ForAddress(grpcEndpoint); var c = new Greeter.GreeterClient(channel); try { var o = await c.SayHelloAsync(new HelloRequest { }); } catch (RpcException ex) { Console.WriteLine(ex.Message); }
Come si può notare, la classe dell'errore che riceveremo sarà di tipo RpcException. L'interceptor dovrà dunque intercettare qualsiasi tipo di eccezione che il servizio potrebbe emettere e sostituirla con un istanza di RpcException.
public class LoggerInterceptor : Interceptor { public override async Task<TResponse> UnaryServerHandler<TRequest, TResponse>( TRequest request, ServerCallContext context, UnaryServerMethod<TRequest, TResponse> continuation) { try { return await continuation(request, context); } catch (Exception e) { throw new RpcException(new Status(StatusCode.Cancelled, e.Message)); } } }
Dettaglio degno di nota è la posizione di e.Message: benchè RpcException abbia un costruttore che accetti, come secondo argomento, il messaggio di errore, il client potrà leggere il messaggio solo se inserito all'interno di Status, il quale si occuperà dunque, sia dello stato dell'eccezione che della causa che l'ha generata.
Commenti
Per inserire un commento, devi avere un account.
Fai il login e torna a questa pagina, oppure registrati alla nostra community.
Approfondimenti
Collegare servizi a Azure Container App con i service connector
GitHub Actions e Terraform: l'infrastruttura, dalla definizione al deploy
Impostare il tema light o dark utilizzando i CSS
Leggere la configurazione da Azure KeyVault con logica di retry in ASP.NET Core
Configurare EF Core 6 con le minimal API di ASP.NET
Le novità di Angular 14
Confronto tra moduli in Javascript: ES e commonJS
Gestire il fallimento di uno step in un workflow di GitHub
Creare attributi generici in C#
Migrare un repository git da Azure DevOps a GitHub
Utilizzare .NET Framework con le Azure Function in modalità isolata
Produttività con ASP.NET Core 6