.Net Core服务治理Consul自动扩展和服务调用

今天有写文章的时间了,开心。延续上一篇的话题继续,顺便放上一篇的传送门:点这里。

服务调用

既然服务注册已经搞完了,那么现在就开始调用这些注册好的服务。先做一下准备动作,把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现在还不能自动移除不可用的服务,能伸不能缩,很尴尬。这个么,时间有限,放在下一篇文章去写。这一篇文章能讲清楚服务调用,并由此能理解什么是服务发现,我觉得就达标。

到此这篇关于.Net Core服务治理Consul自动扩展和服务调用的文章就介绍到这了。希望对大家的学习有所帮助,也希望大家多多支持我们。

(0)

相关推荐

  • .Net Core微服务网关Ocelot集成Consul

    有consul基础的都知道,consul可以发现新增的服务,剔除掉无效的服务,赋予应用自动伸缩的能力.而ocelot如果集成了consul,那ocelot也能拥有这些能力,还可以自主选择负载均衡策略,灵活性更强. (建议看完前一篇文章再来实践这一篇,不然可能有难度) 上干货. 首先打开上一篇新建好的项目,继续添加nuget包: 然后注册相关服务: public void ConfigureServices(IServiceCollection services) { services.AddOc

  • .Net Core服务治理Consul使用服务发现

    先思考一些问题:它是做什么的.以及怎么使用它.带着这些问题往下走. consul是做什么的 consul用于微服务下的服务治理.服务治理是什么?它包含但不限于:服务发现.服务配置.健康检查.键值存储.安全服务通信.多数据中心等. 为什么需要服务治理?举个例子:最开始的服务比较简单,各服务之间通过API就能访问.后面业务复杂了,服务也跟着复杂了,搞分布式了,而分布式又必然是多服务器部署,这就有一个问题:如果服务之间还是用API访问,那某个服务所在的服务器挂掉以后这个服务就不能用了,也不能自动转移,

  • .Net Core服务治理Consul搭建集群

    延续上一篇的话题继续,顺便放上一篇的传送门:点这里. 集群的必要性 consul本身就是管理集群的,现在还需要给consul搞个集群,这是为啥?因为consul单点也容易挂啊!万一管理集群的consul挂掉了,那么相当于上下游应用都变成了瞎子,看不到也调不到.所以集群的必要性不用我说了吧? Server & Client 生产环境下,可以选择上面两种模式,下面我就简称S端.C端.说说它俩有啥不一样: S端: 1.数量不宜过多,一般推荐3.5个,要求是奇数. 2.持久化保存节点数据. 3.多个S端

  • .Net Core服务治理Consul健康检查

    继续上一篇的话题,顺便放上一篇的传送门:点这里. 健康检查 经过之前的操作,我的consul已经支持自动扩展,并且调用也很靠谱.但是这里有个问题,一旦服务列表里的某个服务挂了,consul并不知道,还是会把实际无效的地址返回给我,就算重启consul容器也无法刷新到最新的状态.所以,咱们要监控服务可用性,主动区分出不可用服务,这种手段,就称之为健康检查. 进入编码环节.老规矩,还是进入到之前我封装好的注册方法,在注册时增加健康检查的内容: client.Agent.ServiceRegister

  • .Net Core服务治理Consul自动扩展和服务调用

    今天有写文章的时间了,开心.延续上一篇的话题继续,顺便放上一篇的传送门:点这里. 服务调用 既然服务注册已经搞完了,那么现在就开始调用这些注册好的服务.先做一下准备动作,把consul容器跑起来: 打开控制台确认正常: 然后多跑几个应用程序模拟多点部署: 程序跑完以后检察一下服务列表: 戳进去看看: 一切准备就绪,完美.然后进入编码环节.老规矩,直接上码: public static string Convert(string consulUri, string centerName, stri

  • Spring Cloud Eureka服务治理的实现

    什么是Spring Cloud Eureka Spring Cloud Eureka 是 Spring Cloud 中的一个组件,它是基于 Netflix Eureka 做了二次封装,主要是负责完成微服务框架中服务治理的功能.Spring Cloud通过为 Eureka 增加了 Spring Boot 风格的自动化配置,我们只需要通过简单的引用依赖和注解就能让 Spring Boot 够将的微服务应用轻松的与 Eureka 服务治理体系进行整合. 服务治理 服务治理是微服务框架中最为核心和基础的

  • 详解springcloud组件consul服务治理

    Consul是一款由HashiCorp公司开源的,用于服务治理的软件,Spring Cloud Consul对其进行了封装.Consul具有如下特点: 服务注册 - 自动注册和取消注册服务实例的网络位置 运行状况检查 - 检测服务实例何时启动并运行 分布式配置 - 确保所有服务实例使用相同的配置 Consul agent有两种运行模式:Server和Client.这里的Server和Client只是Consul集群层面的区分,与搭建在Cluster之上 的应用服务无关. 以Server模式运行的

  • C#使用Consul集群进行服务注册与发现

    前言 我个人觉得,中间件的部署与使用是非常难记忆的:也就是说,如果两次使用中间件的时间间隔比较长,那基本上等于要重新学习使用. 所以,我觉得学习中间件的文章,越详细越好:因为,这对作者而言也是一份珍贵的备忘资料. Consul简介 Consul一个什么,我想大家通过搜索引擎一定可以搜索到:所以,我就不在重复他的官方描述了. 这里,我为大家提供一个更加好理解的描述. Consul是什么? Consul本质上是一个Socket通信中间件. 它主要实现了两个功能,服务注册与发现与自身的负载均衡的集群.

  • SpringCloud微服务架构实战之微服务治理功能的实现

    微服务治理 Spring Cloud 工具套件为微服务治理提供了全面的技术支持.这些治理工具主要包括服务的注册与发现.负载均衡管理.动态路由.服务降级和故障转移.链路跟踪.服务监控等.微服务治理的主要功能组件如下: 注册管理服务组件Eureka,提供服务注册和发现的功能. 负载均衡服务组件Ribbon,提供负载均衡调度管理的功能. 边缘代理服务组件Zuul,提供网关服务和动态路由的功能. 断路器组件Hystrix,提供容错机制.服务降级.故障转移等功能. 聚合服务事件流组件Turbine,可用来

  • PHP程序员简单的开展服务治理架构操作详解(二)

    本文实例讲述了PHP程序员简单的开展服务治理架构操作.分享给大家供大家参考,具体如下: 服务治理 治理的绝笔是服务,在一家公司有玩各种语言的程序员,如何去统一管理他们开发的服务,这是一个问题. 上一章主要讲了下服务治理需要什么,如何实现,这章我们详细的"肢解"一下服务治理的一个非常重要的组员 Thrift 上一章说明他的时候是这样写的 暂时大可理解为可以通过它去调用其他开发语言的方法 本猿人已经写好的服务治理 https://github.com/CrazyCodes/Service-

  • Spring Cloud引入Eureka组件,完善服务治理

    简介 Netflix Eureka 是一款由 Netflix 开源的基于 REST 服务的注册中心,用于提供服务发现功能.Spring Cloud Eureka 是 Spring Cloud Netflix 微服务套件的一部分,基于 Netflix Eureka 进行了二次封装,主要负责完成微服务架构中的服务治理功能. Spring Cloud Eureka 是一个基于 REST 的服务,并提供了基于 Java 的客户端组件,能够非常方便的将服务注册到 Spring Cloud Eureka 中

随机推荐