Spring Cloud客户端负载均衡 - Ribbon

作者&投稿:夕厕 (若有异议请与网页底部的电邮联系)
~

注册restTemplate

使用restTemplate发送GET请求

通过@LoadBalanced注解可知该注解用来给restTemplate做标记,使用客户端负载均衡进行配置,搜索LoadBalancerClient类

ServiceInstanceChooser用来根据serviceId进行选择服务

通过以上得知,客户端负载均衡器应具备的几种能力

LoadBalancerAutoConfiguration为实现客户端负载均衡器的自动化配置类

该配置类需要满足两个条件

在示例中没有retryTemplate,则会创建一个LoadBalancerInterceptor对象

在LoadBalancerInterceptor的构造方法中注入了LoadBalancerClient的实现

当一个被@LoadBalance标注的RestTemplate向外发送Http请求时,会被interceptor拦截,调用execute发起实际请求

LoadBalancerClient的具体实现为org.springframework.cloud.netflix.ribbon.RibbonLoadBalancerClient

execute方法

首先根据传入的serviceId获取具体的服务实例

根据getServer接口,可知并没有使用choose函数,而是使用了ribbon本身的chooseServer函数

在ribbonClientConfiguration中可知默认采用了ZoneAwareLoadBalancer实现负载均衡器

回到RibbonBalancerClient的execute函数

通过ZoneAwareLoadBalancer的chooseServer获取负载均衡策略分配到的服务实例后,将其包装成RibbonServer对象,RibbonServer对象除了包含服务实例对象外,还包含serviceId等信息,然后使用该对象回调LoadBalancerInteceptor请求拦截器中LoadBalancerRequest的apply函数,向一个实际的具体服务发起请求

ServiceInstance对象是对服务的抽象定义,包含了每个服务实例需要提供一些基础信息

而RibbonServer就是ServiceInstance的实现,除了Server实例,还包含了serviceId,是否使用https,和一个map的元数据

在LoadBalanceRequest的工厂方法中

传入了一个ServiceRequestWrapper对象

在LoadBalanceRequest的工厂方法中的execute具体执行时,会调用InteceptingClientHttpRequest下的execute函数

而这里面的request.getUri则会调用ServiceRequestWrapper中LoadBalancerClient的getUri函数,至此构建了一个服务治理环境的访问URI,完成代理访问

AbstractLoadBalancer

是ILoadBalancer的抽象实现,定义了服务的分组枚举类,实现了chooseServer,参数key为null,表示在选择具体服务实例时忽略key的条件判断

LoadBalancerStats用来记录负载均衡器中哥哥服务实例的属性和统计信息

getServerList根据分组类型来获取不同的服务实例列表

BaseLoadBalancer

是ribbon负载均衡器的基础实现类,在该类中定义了很多关于负载均衡器相关的基础内容

定义了所有服务清单和正常清单

定义了检查服务实例操作的执行策略对象,默认为SerialPingStrategy

SerialPingStrategy默认采用遍历方式,性能欠佳,如有需要,可以实现IPingStrategy并重写pingServers方法

定义了负载均衡的处理IRule对象,负载均衡策略委托给IRule,而默认的实现为RoundRobinRule

启动ping任务

是BaseLoadBalancer的拓展,该负载均衡器提供了运行期间动态更新服务实例清单的能力,在成员定义中可发现

T在类名中限定为Server的子类

ServerList提供了两个抽象方法

在spring cloud整合ribbon和eureka的包下搜索EurekaRibbonClientConfiguration

DiscoveryEnabledNIWSServerList内部获取serverlist通过内部私有函数obtainServersViaDiscovery

对服务进行遍历,如果状态为UP,转换成DiscoveryEnabledServer对象,组织成list返回。

DiscoveryEnabledNIWSServerList从eureka中拿到server列表后,继续通过DomainExtractingServerList的setZone进行处理,加入了一些必要属性

更新服务待续,没看明白

ZoneAwareLoadBalancer继承自DynamicServerListLoadBalancer并重写了setServerListForZones

个性化配置




城固县13579346164: 看Spring - cloud怎样使用Ribbon
桓心济学: 关注下spring cloud是如何进行客户端负责均衡. 看怎么调用到负载均衡的,怎么定义负载均衡的,然后是怎么实现的?第一个其实可以不用关心,调用的地方应该很多,找到一个地方来说明怎么调用的即可. 第二个,可以猜下,最主要的应该...

城固县13579346164: 如何调用spring cloud微服务 -
桓心济学: spring-cloud调用服务有两种方式,一种是百Ribbon+RestTemplate, 另外一种是Feign.Ribbon是一个基于度HTTP和TCP客户端的负载均衡器,其实版feign也使用了ribbon, 只要使用@FeignClient时,权ribbon就会自动使用.

城固县13579346164: 微服务之架构技术选型与设计 -
桓心济学: 本文主要介绍了架构技术选型与设计-微服务选型,Spring cloud 实现采用的技术,希望对您的学习有所帮助. 架构技术选型与设计-DUBBODubbo,是阿里巴巴服务化治理的核心框架,并被广泛应...

城固县13579346164: 如何使用Spring Boot/Spring Cloud 实现微服务应用 -
桓心济学: Spring Cloud介绍 Spring Cloud是一个基于Spring Boot实现的云应用开发工具,它为基于JVM的云应用开发中的配置管理、服务发现、断路器、智能路由、微代理、控制总线、全局锁、决策竞选、分布式会话和集群状态管理等操作提供了一种简...

城固县13579346164: 如何使用Spring Cloud -
桓心济学: Spring Cloud项目的既定目标在于为Spring开发人员提供一整套易于使用的工具集,从而保证其轻松构建起自己需要的分布式系统方案.为了实现这一目标,Spring Cloud以Netflix OSS堆栈为基础将大量实现堆栈加以整合并打包.这些堆栈而后...

城固县13579346164: spring cloud,基于什么实现 -
桓心济学: Spring Cloud的子项目,大致可分成两类,一类是对现有成熟框架”Spring Boot化”的封装和抽象,也是数量最多的项目;第二类是开发了一部分分布式系统的基础设施的实现,如Spring Cloud Stream扮演的就是kafka, ActiveMQ这样的角色....

城固县13579346164: java培训有哪些课程?
桓心济学: JavaSE&Java新特性MySQL&Oracle&存储过程JDBCHTML&CSS&JavaScript&jQueryBootstrap&layUIXMLServlet&Jsp&EL&JSTLAjaxSVN&GITUMLJUnitLog4jSpringMVCStruts2SpringHibernateMyBatisHTML5&CSS3新增微服务系列课程微服...

城固县13579346164: 微服务框架 spring cloud 和 dubbo 有什么区别 -
桓心济学: 其中配置管理Dubbo是不具备的,当然可以借助Zookeeper实现,但是不推荐.Spring Cloud提供的方案是Spring Cloud Config,再加上Spring Cloud Bus可以实现配置的广播动态刷新. 服务注册和发现作为基础的能力Dubbo是有的,默认大概...

城固县13579346164: 写springcloud 遇到过什么困难 -
桓心济学: 1.在feign中使用熔断器hystrix,但是一直不起作用.因为在D版本的Spring Cloud中,它没有默认打开. 解决:在yml文件中加入 feign:hystrix:enabled: true 注意yml中不识别tab的空格. 做完以上工作,重启服务即可. 2.feign hystrix dashboard 断...

本站内容来自于网友发表,不代表本站立场,仅表示其个人看法,不对其真实性、正确性、有效性作任何的担保
相关事宜请发邮件给我们
© 星空见康网