zoukankan      html  css  js  c++  java
  • .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现在还不能自动移除不可用的服务,能伸不能缩,很尴尬。这个么,时间有限,放在下一篇文章去写。这一篇文章能讲清楚服务调用,并由此能理解什么是服务发现,我觉得就达标。

    声明:未经作者同意必须保留此段声明,且在文章页面明显位置给出原文连接,否则视为侵权。
    本文原创发表于博客园,作者为暮城倾心。欢迎转载。Donation(扫码支持作者)↓

    微信
    支付宝
  • 相关阅读:
    TP6框架中如何无刷新上传文件
    TP6框架设置验证码的宽度和高度后,验证码显示不全
    TP6模板缓存问题
    TP6管理后台实战第五天文章管理
    20211027技术人为什么建议写博客
    TP6管理后台实战第六天系统管理
    博客园自定义菜单
    xcat无法连接服务器
    lsf安装后配置
    xcat网络无盘启动——添加自定义安装包
  • 原文地址:https://www.cnblogs.com/muchengqingxin/p/15035171.html
Copyright © 2011-2022 走看看