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
Semplificare la dichiarazione del namespace in C#
Eseguire uno scroll all'interno di una pagina Blazor
Usare l'option pattern per gestire la configurazione in ASP.NET Core
Compilare automaticamente applicazioni .NET 6 con le pipeline di Azure DevOps e GitHub Action
Welcome back to .NET
Gestire il polimorfismo delle proprietà durante la serializzazione con System.Text.Json
Caricare automaticamente i dati delle relazioni in EF Core 6
Creare l'effetto floating label per gli input con Bootstrap 5
Compilare un'applicazione .NET Core con una GitHub Action
Creare un'istanza di Azure Service Bus con ARM
Ottimizzare la concorrenza dinamicamente con le Azure Function
Utilizzare proprietà di tipo DateOnly con EF Core 6
I più letti di oggi
- Utilizzare la parola chiave var con lambda expression e method group in C# 10
- ecco tutte le novità pubblicate sui nostri siti questa settimana: https://aspit.co/wkly buon week-end!
- devConf 2022 - Online
- Log streaming di una Azure Container App
- Agenda di #devconf22 del 26/05 quasi al completo! Ce n'è per tutti i gusti: #dotnet, #aspnetcore, #blazor, #terraform, #githubAltre informazioni e iscrizioni su => https://aspit.co/devconf-22