{"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();