.NetCore快速上手Consul，留给自己一点思考的空间

{
  "ConsulConfig": {
    "ServiceName": "WebApi1",
    "ServiceIP": "localhost",
    "ServicePort": 6000,
    "HealthCheck": "/healthcheck",
    "ConsulAddress": "http://localhost:8500"}
}

        public voidConfigure(IApplicationBuilder app, IWebHostEnvironment env)
        {
            if(env.IsDevelopment())
            {
                app.UseDeveloperExceptionPage();
            }

            app.UseRouting();
            //添加consul服务注册
app.UseConsul();

            app.UseEndpoints(endpoints =>{
                endpoints.MapControllers();
            });
        }

    public static classConsulExtensions
    {
        public static IApplicationBuilder UseConsul(thisIApplicationBuilder app)
        {
            //获取consul配置实例
            var consulConfig = app.ApplicationServices.GetRequiredService<IOptions<ConsulOptions>>().Value;
            //获取应用程序声明周期事件
            var lifetime = app.ApplicationServices.GetRequiredService<IHostApplicationLifetime>();
            var consulClient = new ConsulClient(c =>{
                //consul服务注册地址
                c.Address = newUri(consulConfig.ConsulAddress);
            });

            //服务注册配置
            var registration = newAgentServiceRegistration()
            {
                ID =Guid.NewGuid().ToString(),
                Name = consulConfig.ServiceName,//服务名称
                Address = consulConfig.ServiceIP,//服务IP
                Port = consulConfig.ServicePort,//服务端口
                Check = newAgentServiceCheck()
                {
                    DeregisterCriticalServiceAfter = TimeSpan.FromSeconds(5),//服务启动后多久注册服务
                    Interval = TimeSpan.FromSeconds(10),//健康检查时间间隔
                    HTTP = $"http://{consulConfig.ServiceIP}:{consulConfig.ServicePort}{consulConfig.HealthCheck}",//健康检查地址
                    Timeout = TimeSpan.FromSeconds(5)//超时时间
}
            };

            //服务注册
consulClient.Agent.ServiceRegister(registration).Wait();

            //应用程序结束时  取消注册
            lifetime.ApplicationStopping.Register(() =>{
                consulClient.Agent.ServiceDeregister(registration.ID).Wait();
            });

            returnapp;
        }
    }

    [Route("[controller]")]
    [ApiController]
    public classHealthCheckController : ControllerBase
    {
        /// <summary>
        ///健康检查接口
        /// </summary>
        /// <returns></returns>
[HttpGet]
        public IActionResult Get() =>Ok();
    }

[HttpGet]
        [Route("/consul")]
        public voidReuestConsul()
        {
            //获取Consul配置地址
            var consulAddress = _configuration["ConsulAddress"]?.ToString();
            using (var consulClient = new ConsulClient(x => x.Address = newUri(consulAddress)))
            {
                //获取根据服务注册名称webApi1  获取consul注册的服务
                var services = consulClient.Catalog.Service("WebApi1").Result.Response;
                if (services != null &&services.Any())
                {
                    //模拟随机一台进行请求，这里只是测试，可以选择合适的负载均衡框架
                    Random r = newRandom();
                    int index =r.Next(services.Count());
                    var service =services.ElementAt(index);
                    using (HttpClient client = newHttpClient())
                    {
                        //请求服务WebApi1
                        var response = client.GetAsync($"http://{service.ServiceAddress}:{service.ServicePort}/api/values").Result;
                        string result =response.Content.ReadAsStringAsync().Result;
                    }
                }
            }
        }