.NET Core(.NET6)中gRPC注册到Consul详解

{"Logging": {"LogLevel": {"Default":"Information","Microsoft.AspNetCore":"Warning"     }   },"AllowedHosts":"*","Kestrel": {"EndpointDefaults": {"Protocols":"Http2"     }   },"Consul": {     "consulAddress": "http://127.0.0.1:8500",     "serviceName": "api_gRPC",     "currentIp": "127.0.0.1",     "currentPort": "5246"   } }

///<summary>/// Consul注册///</summary>publicstaticclass ConsulRegister     {//服务注册publicstatic IApplicationBuilder UseConsul(this IApplicationBuilder app, IConfiguration configuration)         {// 获取主机生命周期管理接口var lifetime = app.ApplicationServices.GetRequiredService<IHostApplicationLifetime>();              ConsulClient client=new ConsulClient(c =>             {                 c.Address=new Uri(configuration["Consul:consulAddress"]);                 c.Datacenter="dc1";             });string ip = configuration["ip"];//优先接收变量的值string port = configuration["port"];//优先接收变量的值string currentIp = configuration["Consul:currentIP"];string currentPort = configuration["Consul:currentPort"];              ip=string.IsNullOrEmpty(ip) ? currentIp : ip;//当前程序的IP             port =string.IsNullOrEmpty(port) ? currentPort : port;//当前程序的端口string serviceId = $"service:{ip}:{port}";//服务ID，一个服务是唯一的//服务注册             client.Agent.ServiceRegister(new AgentServiceRegistration()             {                 ID= serviceId,//唯一的                 Name = configuration["Consul:serviceName"],//组名称-Group                 Address = ip,//ip地址                 Port =int.Parse(port),//端口                 Tags =newstring[] {"api站点" },                 Check=new AgentServiceCheck()                 {                     Interval= TimeSpan.FromSeconds(10),//多久检查一次心跳                     GRPC = $"{ip}:{port}",//gRPC注册特有                     GRPCUseTLS=false,//支持http                     Timeout = TimeSpan.FromSeconds(5),//超时时间                     DeregisterCriticalServiceAfter = TimeSpan.FromSeconds(5)//服务停止多久后注销服务                }              }).Wait();//应用程序终止时,注销服务             lifetime.ApplicationStopping.Register(() =>             {                 client.Agent.ServiceDeregister(serviceId).Wait();             });return app;         }     }

using GrpcDemo.Service.Services;using GrpcDemo.Service.Utils;var builder = WebApplication.CreateBuilder(args);// Additional configuration is required to successfully run gRPC on macOS.// For instructions on how to configure Kestrel and gRPC clients on macOS, visithttps://go.microsoft.com/fwlink/?linkid=2099682// Add services to the container.builder.Services.AddGrpc();var app = builder.Build(); IConfiguration _configuration= builder.Configuration;// Configure the HTTP request pipeline. app.MapGrpcService<GreeterService>(); app.MapGrpcService<OrderService>(); app.MapGrpcService<HealthCheckService>(); app.MapGet("/", () =>"Communication with gRPC endpoints must be made through a gRPC client. To learn how to create a client, visit: https://go.microsoft.com/fwlink/?linkid=2086909");app.UseConsul(_configuration); app.Run();

syntax ="proto3";  package grpc.health.v1;  message HealthCheckRequest {string service =1; }  message HealthCheckResponse {enum ServingStatus {         UNKNOWN=0;         SERVING=1;         NOT_SERVING=2;     }     ServingStatus status=1; }  service Health {     rpc Check(HealthCheckRequest) returns (HealthCheckResponse);      rpc Watch(HealthCheckRequest) returns (stream HealthCheckResponse); }

publicclass HealthCheckService : Health.HealthBase     {publicoverride Task<HealthCheckResponse> Check(HealthCheckRequest request, ServerCallContext context)         {             Console.WriteLine($"This is {nameof(HealthCheckService)} Check");//TODO:检查逻辑return Task.FromResult(new HealthCheckResponse() { Status = HealthCheckResponse.Types.ServingStatus.Serving });         }publicoverrideasync Task Watch(HealthCheckRequest request, IServerStreamWriter<HealthCheckResponse> responseStream, ServerCallContext context)         {//TODO:检查逻辑await responseStream.WriteAsync(new HealthCheckResponse()             { Status= HealthCheckResponse.Types.ServingStatus.Serving });         }     }

using GrpcDemo.Service.Services;using GrpcDemo.Service.Utils;var builder = WebApplication.CreateBuilder(args);// Additional configuration is required to successfully run gRPC on macOS.// For instructions on how to configure Kestrel and gRPC clients on macOS, visithttps://go.microsoft.com/fwlink/?linkid=2099682// Add services to the container.builder.Services.AddGrpc();//配置获取var app = builder.Build(); IConfiguration _configuration= builder.Configuration;// Configure the HTTP request pipeline. app.MapGrpcService<GreeterService>(); app.MapGrpcService<OrderService>();app.MapGrpcService<HealthCheckService>(); app.MapGet("/", () =>"Communication with gRPC endpoints must be made through a gRPC client. To learn how to create a client, visit: https://go.microsoft.com/fwlink/?linkid=2086909");  app.UseConsul(_configuration); app.Run();