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

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

服务发现

同样Nuget安装一下Consul:

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

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

.Net Core微服务入门全纪录(三)——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, 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("/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,以上代码就完成了服务列表的获取。

浏览器测试一下:

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

随便停止2个服务:

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

继续访问:

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


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

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

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

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

Blocking Queries

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

内容版权声明:除非注明,否则皆为本站原创文章。

转载注明出处:https://www.heiqu.com/wppxww.html