-
.Net Core微服务——Consul(2):自动扩展、服务调用
今天有写文章的时间了,开心。延续上一篇的话题继续,顺便放上一篇的传送门:点这里。
服务调用
既然服务注册已经搞完了,那么现在就开始调用这些注册好的服务。先做一下准备动作,把consul容器跑起来:
打开控制台确认正常:
然后多跑几个应用程序模拟多点部署:
程序跑完以后检察一下服务列表:
戳进去看看:
一切准备就绪,完美。然后进入编码环节。老规矩,直接上码:
public static string Convert(string consulUri, string centerName, string reqUri)
{
ConsulClient client = new ConsulClient(x =>
{
x.Address = new Uri(consulUri);
x.Datacenter = centerName;
});
//获取consul中注册的服务列表
var consulServiceList = client.Agent.Services().Result.Response;
//统一请求地址
Uri uri = new Uri(reqUri);
//取出分组名称
string groupName = uri.Host;
//匹配出对应的服务
var serviceList = consulServiceList.Where(x => x.Value.Service.ToLower().Equals(groupName.ToLower())).ToArray();
//随机访问策略
var service = serviceList[new Random().Next(serviceList.Length)].Value;
return $"{uri.Scheme}://{service.Address}:{service.Port}{uri.PathAndQuery}";
}
上面是自行封装的方法,作用很简单:把通用的请求地址转换为实际发起请求的地址,比如调用起来是这样的:
string realUri = ConsulService.Convert("http://127.0.0.1:8700", "dc1", "http://shenzhen-ma/v1/client/base/index");
发现了么,分组名称“shenzhen-ma”直接替代了具体的ip和端口。这样做真的可以拿到请求结果么?随便写一个测试用的controller:
public async Task<IActionResult> Post()
{
string realUri = ConsulService.Convert("http://127.0.0.1:8700", "dc1", "http://shenzhen-ma/v1/client/base/index");
string result = await Service.Tool.HttpHelper.Get(realUri);
return Ok(result);
}
看请求结果:
5001应用程序请求到了5004的数据。多试几下再看看:
很显然,通过统一的请求地址,实际的请求分发到了不同的节点上。
复盘一波
到刚才,我已经完成了服务调用这个关键步骤。consul做了什么呢?它帮我们把统一的请求地址转换成了真实发生作用的请求地址。未来如果增加了新的服务器,无需调整,它自己就能够发现新的服务——这就是大家广泛理解的服务发现。实际上,这个功能就赋予了我们动态增加节点的能力。能伸能缩,是微服务的一个重要特征。当然,因为没有配置健康检查,我的consul现在还不能自动移除不可用的服务,能伸不能缩,很尴尬。这个么,时间有限,放在下一篇文章去写。这一篇文章能讲清楚服务调用,并由此能理解什么是服务发现,我觉得就达标。
原文链接:https://www.cnblogs.com/muchengqingxin/p/15035171.html
栏目列表
最新更新
nodejs爬虫
Python正则表达式完全指南
爬取豆瓣Top250图书数据
shp 地图文件批量添加字段
爬虫小试牛刀(爬取学校通知公告)
【python基础】函数-初识函数
【python基础】函数-返回值
HTTP请求:requests模块基础使用必知必会
Python初学者友好丨详解参数传递类型
如何有效管理爬虫流量?
2个场景实例讲解GaussDB(DWS)基表统计信息估
常用的 SQL Server 关键字及其含义
动手分析SQL Server中的事务中使用的锁
openGauss内核分析:SQL by pass & 经典执行
一招教你如何高效批量导入与更新数据
天天写SQL,这些神奇的特性你知道吗?
openGauss内核分析:执行计划生成
[IM002]Navicat ODBC驱动器管理器 未发现数据
初入Sql Server 之 存储过程的简单使用
SQL Server -- 解决存储过程传入参数作为s
关于JS定时器的整理
JS中使用Promise.all控制所有的异步请求都完
js中字符串的方法
import-local执行流程与node模块路径解析流程
检测数据类型的四种方法
js中数组的方法,32种方法
前端操作方法
数据类型
window.localStorage.setItem 和 localStorage.setIte
如何完美解决前端数字计算精度丢失与数