.Net Core微服务入门全纪录（三）——Consul-服务注册与发现（下）

概述Tips：本篇已加入系列文章阅读目录，可点击查看更多相关文章。 前言 上一篇【.Net Core微服务入门全纪录（二）——Consul-服务注册与发现（上）】已经成功将我们的服务注册到Consul中，

Tips：本篇已加入系列文章阅读目录，可点击查看更多相关文章。

前言

上一篇【.Net Core微服务入门全纪录（二）——Consul-服务注册与发现（上）】已经成功将我们的服务注册到Consul中，接下来就该客户端通过Consul去做服务发现了。

服务发现

同样Nuget安装一下Consul：

改造一下业务系统的代码：

ServiceHelper.cs：

    public class ServiceHelper : IServiceHelper    {        private Readonly IConfiguration _configuration;        public ServiceHelper(IConfiguration configuration)        {            _configuration = configuration;        }        public async Task<string> Getorder()        {            //string[] serviceUrls = { "http://localhost:9060","http://localhost:9061","http://localhost:9062" };//订单服务的地址，可以放在配置文件或者数据库等等...            var consulClIEnt = new ConsulClIEnt(c =>            {                //consul地址                c.Address = new Uri(_configuration["ConsulSetting:ConsulAddress"]);            });            //consulClIEnt.Catalog.Services().Result.Response;            //consulClIEnt.Agent.Services().Result.Response;            var services = consulClIEnt.Health.Service("OrderService",null,true,null).Result.Response;//健康的服务            string[] serviceUrls = services.Select(p => $"http://{p.Service.Address + ":" + p.Service.Port}").ToArray();//订单服务地址列表            if (!serviceUrls.Any())            {                return await Task.Fromresult("【订单服务】服务列表为空");            }            //每次随机访问一个服务实例            var ClIEnt = new RestClIEnt(serviceUrls[new Random().Next(0,serviceUrls.Length)]);            var request = new RestRequest("/orders",Method.GET);            var response = await ClIEnt.ExecuteAsync(request);            return response.Content;        }        public async Task<string> GetProduct()        {            //string[] serviceUrls = { "http://localhost:9050","http://localhost:9051","http://localhost:9052" };//产品服务的地址，可以放在配置文件或者数据库等等...            var consulClIEnt = new ConsulClIEnt(c =>            {                //consul地址                c.Address = new Uri(_configuration["ConsulSetting:ConsulAddress"]);            });            //consulClIEnt.Catalog.Services().Result.Response;            //consulClIEnt.Agent.Services().Result.Response;            var services = consulClIEnt.Health.Service("ProductService",null).Result.Response;//健康的服务            string[] serviceUrls = services.Select(p => $"http://{p.Service.Address + ":" + p.Service.Port}").ToArray();//产品服务地址列表            if (!serviceUrls.Any())            {                return await Task.Fromresult("【产品服务】服务列表为空");            }            //每次随机访问一个服务实例            var ClIEnt = new RestClIEnt(serviceUrls[new Random().Next(0,serviceUrls.Length)]);            var request = new RestRequest("/products",Method.GET);            var response = await ClIEnt.ExecuteAsync(request);            return response.Content;        }    }

appsettings.Json：

{  "Logging": {    "LogLevel": {      "Default": "information","Microsoft": "Warning","Microsoft.Hosting.lifetime": "information"    }  },"AllowedHosts": "*","ConsulSetting": {    "ConsulAddress": "http://localhost:8500"  }}

OK，以上代码就完成了服务列表的获取。

浏览器测试一下：

随便停止2个服务：

继续访问：

这时候停止的服务地址就获取不到了，客户端依然正常运行。

这时候解决了服务的发现，新的问题又来了...

客户端每次要调用服务，都先去Consul获取一下地址，这不仅浪费资源，还增加了请求的响应时间，这显然让人无法接受。

那么怎么保证不要每次请求都去Consul获取地址，同时又要拿到可用的地址列表呢？
Consul提供的解决方案：——Blocking QuerIEs （阻塞的请求）。详情请见官网：https://www.consul.io/api-docs/features/blocking

Blocking QuerIEs

这是什么意思呢，简单来说就是当客户端请求Consul获取地址列表时，需要携带一个版本号信息，Consul会比较这个客户端版本号是否和Consul服务端的版本号一致，如果一致，则Consul会阻塞这个请求，直到Consul中的服务列表发生变化，或者到达阻塞时间上限；如果版本号不一致，则立即返回。这个阻塞时间默认是5分钟，支持自定义。
那么我们另外启动一个线程去干这件事情，就不会影响每次的用户请求了。这样既保证了客户端服务列表的准确性，又节约了客户端请求服务列表的次数。

继续改造代码：
IServiceHelper增加一个获取服务列表的接口方法：

    public interface IServiceHelper    {        /// <summary>        /// 获取产品数据        /// </summary>        /// <returns></returns>        Task<string> GetProduct();        /// <summary>        /// 获取订单数据        /// </summary>        /// <returns></returns>        Task<string> Getorder();        /// <summary>        /// 获取服务列表        /// </summary>        voID GetServices();    }

ServiceHelper实现接口：

    public class ServiceHelper : IServiceHelper    {        private Readonly IConfiguration _configuration;        private Readonly ConsulClIEnt _consulClIEnt;        private ConcurrentBag<string> _orderServiceUrls;        private ConcurrentBag<string> _productServiceUrls;        public ServiceHelper(IConfiguration configuration)        {            _configuration = configuration;            _consulClIEnt = new ConsulClIEnt(c =>            {                //consul地址                c.Address = new Uri(_configuration["ConsulSetting:ConsulAddress"]);            });        }        public async Task<string> Getorder()        {            if (_productServiceUrls == null)                return await Task.Fromresult("【订单服务】正在初始化服务列表...");            //每次随机访问一个服务实例            var ClIEnt = new RestClIEnt(_orderServiceUrls.ElementAt(new Random().Next(0,_orderServiceUrls.Count())));            var request = new RestRequest("/orders",Method.GET);            var response = await ClIEnt.ExecuteAsync(request);            return response.Content;        }        public async Task<string> GetProduct()        {            if(_productServiceUrls == null)                return await Task.Fromresult("【产品服务】正在初始化服务列表...");            //每次随机访问一个服务实例            var ClIEnt = new RestClIEnt(_productServiceUrls.ElementAt(new Random().Next(0,_productServiceUrls.Count())));            var request = new RestRequest("/products",Method.GET);            var response = await ClIEnt.ExecuteAsync(request);            return response.Content;        }        public voID GetServices()        {            var servicenames = new string[] { "OrderService","ProductService" };            Array.ForEach(servicenames,p =>            {                Task.Run(() =>                {                    //WaitTime默认为5分钟                    var queryOptions = new queryOptions { WaitTime = TimeSpan.FromMinutes(10) };                    while (true)                    {                        GetServices(queryOptions,p);                    }                });            });        }        private voID GetServices(queryOptions queryOptions,string servicename)        {            var res = _consulClIEnt.Health.Service(servicename,queryOptions).Result;                        //控制台打印一下获取服务列表的响应时间等信息            Console.Writeline($"{DateTime.Now}获取{servicename}：queryOptions.WaitIndex：{queryOptions.WaitIndex}  LastIndex：{res.LastIndex}");            //版本号不一致 说明服务列表发生了变化            if (queryOptions.WaitIndex != res.LastIndex)            {                queryOptions.WaitIndex = res.LastIndex;                //服务地址列表                var serviceUrls = res.Response.Select(p => $"http://{p.Service.Address + ":" + p.Service.Port}").ToArray();                if (servicename == "OrderService")                    _orderServiceUrls = new ConcurrentBag<string>(serviceUrls);                else if (servicename == "ProductService")                    _productServiceUrls = new ConcurrentBag<string>(serviceUrls);            }        }    }

Startup的Configure方法中调用一下获取服务列表：

        public voID Configure(IApplicationBuilder app,IWebHostEnvironment env,IServiceHelper serviceHelper)        {            if (env.IsDevelopment())            {                app.UseDeveloperExceptionPage();            }            else            {                app.UseExceptionHandler("/Home/Error");            }            app.UseStaticfiles();            app.UseRouting();            app.UseAuthorization();            app.UseEndpoints(endpoints =>            {                endpoints.MapControllerRoute(                    name: "default",pattern: "{controller=Home}/{action=Index}/{ID?}");            });            //程序启动时 获取服务列表            serviceHelper.GetServices();        }

代码完成，运行测试：

现在不用每次先请求服务列表了，是不是流畅多了？

看一下控制台打印：

这时候如果服务列表没有发生变化的话，获取服务列表的请求会一直阻塞到我们设置的10分钟。

随便停止2个服务：

这时候可以看到，数据被立马返回了。

继续访问客户端网站，同样流畅。
（gif图传的有点问题。。。）

至此，我们就通过Consul完成了服务的注册与发现。
接下来又引发新的思考。。。

每个客户端系统都去维护这一堆服务地址，合理吗？服务的ip端口直接暴露给所有客户端，安全吗？这种模式下怎么做到客户端的统一管理呢？
...

代码放在：https://github.com/xiajingren/NetCoreMicroserviceDemo

未完待续...

总结

以上是内存溢出为你收集整理的.Net Core微服务入门全纪录（三）——Consul-服务注册与发现（下）全部内容，希望文章能够帮你解决.Net Core微服务入门全纪录（三）——Consul-服务注册与发现（下）所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。