Ribbon源码深度解析

这篇具有很好参考价值的文章主要介绍了Ribbon源码深度解析。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

① 目前,我看的Ribbon的源码版本是spring-cloud-netflix-ribbon-2.2.6.RELEASE,但是网上没有找到该版本源代码,只能查看jar下编译后的代码,方法的跳转和搜索不太方便…,以上是题外话,继续:首先可以找到META-INF/spring.factories文件,查看该文件中配置了哪些自动装配类,刚好只有一个,如下图所示:
Ribbon源码深度解析,ribbon,spring cloud,后端,java
② 进入RibbonAutoConfiguration类中,查看整体结构,如下图所示:
Ribbon源码深度解析,ribbon,spring cloud,后端,java
比较核心的类有这么几个:
SpringClientFactory:提供了SpringClientFactory#getInstance()方法,可以获取 Ribbon的一些组件,如IClient、ILoadBalancer、IClientConfig等。
LoadBalancerClient:Ribbon用于发起远程调用,
Spring在实例化RibbonAutoConfiguration之前,会先加载LoadBalancerAutoConfiguration类,因为它是被@AutoConfigureBefore注解所修饰的,再看看LoadBalancerAutoConfiguration类,如下图所示:
Ribbon源码深度解析,ribbon,spring cloud,后端,java
在LoadBalancerAutoConfiguration类中,有一个属性注入:restTemplates,该成员属性实际上是被@LoadBalanced和@Autowired(required = false) 注解共同修饰,意思是在Spring容器中找到所有的RestTemplate,并且被注入的RestTemplate必须也是被@LoadBalanced注解修饰才行。因此,我们如果自己注入的RestTemplate想要有负载均衡作用,必须加上@LoadBalanced注解。
再具体说说为什么我们自己注入的RestTemplate加上@LoadBalanced就可以实现负载均衡的功能:在LoadBalancerAutoConfiguration类中,还有一个类,当然它是一段λ表达式,实际上它也是SmartInitializingSingleton接口的实现类SmartInitializingSingleton#afterSingletonsInstantiated()方法,该方法在Spring实例化了所有的单例bean之后,会调用该方法。也就是在LoadBalancerAutoConfiguration#loadBalancedRestTemplateInitializerDeprecated()方法中,注入了List restTemplateCustomizers方法入参,遍历restTemplateCustomizers,调用 RestTemplateCustomizer#customize()方法,传入RestTemplate对象(其中也就包括我们自己定义的RestTemplate对象),对RestTemplate对象做处理,加入请求的拦截器(算是一种“增强“),如下图所示:
Ribbon源码深度解析,ribbon,spring cloud,后端,java
继续往下看,在LoadBalancerAutoConfiguration类中,其实就注入了RestTemplateCustomizer对象,它其实也是一段λ表达式,在这段λ表达式中只干了一件事:往RestTemplate中添加了一个LoadBalancerInterceptor,看名字,就知道它才是实现负债均衡最核心的功能(如下如所示):
Ribbon源码深度解析,ribbon,spring cloud,后端,java
并且,在注入LoadBalancerInterceptor的时候,实际上是调用了它的有参构造,传入了两个参数,即:LoadBalancerClient和LoadBalancerRequestFactory,看看LoadBalancerInterceptor类,如下图所示:
Ribbon源码深度解析,ribbon,spring cloud,后端,java
而LoadBalancerClient类,实际上是在RibbonAutoConfiguration类中注入的,如下图所示:
Ribbon源码深度解析,ribbon,spring cloud,后端,java
③ 这样的话,整个链路就很清晰:我们在使用我们自己定义的RestTemplate的时候,只要加上@LoadBalanced注解,Spring就会拿到我们定义的RestTemplate对象,再从Spring容器中拿到LoadBalancerInterceptor对象,并且加到RestTemplate的成员属性interceptors中,最终LoadBalancerInterceptor就会实现客户端的负载均衡功能,当然最终的实现,是依赖于LoadBalancerClient类。
④ 具体看看调用链路,以RestTemplate#getForObject()方法为例:具体看图:
Ribbon源码深度解析,ribbon,spring cloud,后端,java
再看看RestTemplate#execute()方法:
Ribbon源码深度解析,ribbon,spring cloud,后端,java
再看看RestTemplate#doExecute()方法:
Ribbon源码深度解析,ribbon,spring cloud,后端,java
先看一下RestTemplate#createRequest()方法:
Ribbon源码深度解析,ribbon,spring cloud,后端,java
createRequest ()方法实际上是调用RestTemplate父类HttpAccessor#createRequest ()方法,再看看HttpAccessor#getRequestFactory()方法,具体如下图所示:
Ribbon源码深度解析,ribbon,spring cloud,后端,java
在该方法中,会创建InterceptingClientHttpRequestFactory,并且传入interceptors,其中,interceptors就包含了之前注入的LoadBalancerInterceptor对象。回到InterceptingHttpAccessor父类HttpAccessor#createRequest()方法中:
Ribbon源码深度解析,ribbon,spring cloud,后端,java
查看AbstractClientHttpRequestFactoryWrapper#createRequest()方法,它实际上是抽象方法,具体实现在其实现类中,即InterceptingClientHttpRequestFactory:
Ribbon源码深度解析,ribbon,spring cloud,后端,java
再看看InterceptingClientHttpRequestFactory#createRequest()方法:
Ribbon源码深度解析,ribbon,spring cloud,后端,java
最终返回的是InterceptingClientHttpRequest对象,并且传入了interceptors。再回到RestTemplate#doExecute()方法,如下图所示:
Ribbon源码深度解析,ribbon,spring cloud,后端,java
再看看AbstractClientHttpRequest#execute()方法:
Ribbon源码深度解析,ribbon,spring cloud,后端,java
再看看AbstractClientHttpRequest#executeInternal()方法:
Ribbon源码深度解析,ribbon,spring cloud,后端,java
再看看AbstractBufferingClientHttpRequest#executeInternal()方法,这是一个抽象方法,具体看实现类,由上文可知,实际上就是InterceptingClientHttpRequest类,如下图所示:
Ribbon源码深度解析,ribbon,spring cloud,后端,java
再看看InterceptingClientHttpRequest#executeInternal()方法:
Ribbon源码深度解析,ribbon,spring cloud,后端,java
由上图可知,interceptors是不为空的,因此,遍历interceptors,最终会调用到LoadBalancerInterceptor#intercept()方法,如下图所示:
Ribbon源码深度解析,ribbon,spring cloud,后端,java
最终调用的是RibbonLoadBalancerClient#execute()方法,如下图所示:
Ribbon源码深度解析,ribbon,spring cloud,后端,java
后续调用到的RibbonLoadBalancerClient#execute()方法,其它的重载方法就不用再看了,无非是拿到了Server后,拿到ip/port,进行地址以及请求体的拼接,最终发起远程HTTP的调用,拿到Response返回罢了。我们核心要看的当然是RibbonLoadBalancerClient#getServer()方法,看其是如何得到一个服务节点进行调用的:
Ribbon源码深度解析,ribbon,spring cloud,后端,java
再看ZoneAwareLoadBalancer#chooseServer()方法,为啥是ZoneAwareLoadBalancer类而不是其他的呢,具体看RibbonClientConfiguration配置类可知:
Ribbon源码深度解析,ribbon,spring cloud,后端,java
接着上文,继续看ZoneAwareLoadBalancer#chooseServer()方法,如下如所示:
Ribbon源码深度解析,ribbon,spring cloud,后端,java
这里的ZoneAwareLoadBalancer.getLoadBalancerStats().getAvailableZones().size() 是不大于1的,所以看ZoneAwareLoadBalancer父类的chooseServer()方法:
Ribbon源码深度解析,ribbon,spring cloud,后端,java
会发现,调用到了this.rule.choose()方法。这个有默认的rule,具体也是看RibbonClientConfiguration配置类,如果我们用Nacos做注册中心,则可以注入NacosRule类到Spring中去,如果是这个类的话,看NacosRule#choose()方法:
Ribbon源码深度解析,ribbon,spring cloud,后端,java
以上,就是ribbon源码的简单解析,如有错误,恳请批评指正!文章来源地址https://www.toymoban.com/news/detail-827121.html

到了这里,关于Ribbon源码深度解析的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • 【Spring Cloud 四】Ribbon负载均衡

    【Spring Cloud一】微服务基本知识 【Spring Cloud 三】Eureka服务注册与服务发现 目前公司项目使用的注册中心主要是Spring Cloud Alibaba的Nacos做的注册中心和配置中心。并且Nacos使用了Ribbon作为默认的负载均衡器。但是相当于将Ribbon的负载均衡给透明化了,日常开发明面上是看不到

    2024年02月14日
    浏览(50)
  • 【Spring Cloud系列】- Ribbon详解与实战

    在前面的文章 Eureka详解与实战、Eureka Client应用、RestTemplate详解及其负载均衡几篇文章中,已经介绍了Spring Cloud基本应用,本文将从讲解在进程层面的负载均衡,在Spring Cloud中如何使用Ribbon做系统应用层面的负载均衡使用。 Ribbon 是netflix 公司开源的基于客户端的负载均衡组件

    2024年02月15日
    浏览(41)
  • 【Spring Cloud】Nacos及Ribbon组件的使用

    🎉🎉欢迎来到我的CSDN主页!🎉🎉 🏅我是Java方文山,一个在CSDN分享笔记的博主。📚📚 🌟推荐给大家我的专栏《Spring Cloud》。🎯🎯 👉点击这里,就可以查看我的主页啦!👇👇 Java方文山的个人主页 🎁如果感觉还不错的话请给我点赞吧!🎁🎁 💖期待你的加入,一起

    2024年01月25日
    浏览(64)
  • Spring Cloud之负载均衡与服务调用(Ribbon)

    目录 Ribbon 简介 负载均衡 简介 负载均衡方式 服务端负载均衡 工作原理 特点 客户端负载均衡 工作原理 特点 对比 实现 负载均衡策略 切换负载均衡策略 定制负载均衡策略 超时与重试 单个服务配置 全局配置 服务调用 示例         Ribbon 是 Netflix 公司发布的开源组件,其

    2024年02月08日
    浏览(51)
  • Ribbon:Spring Cloud负载均衡与服务调用组件

    负载均衡? Ribbon实现服务调用? Ribbon实现负载均衡? 切换负载均衡策略? 定制负载均衡策略? 负载均衡 负载均衡(Load Balance),将用户的请求平分到多个服务器上运行,以扩展服务器带宽、增强数据处理能力、增加吞吐量、提高网络的可用性和灵活性的目的。 服务端负载

    2024年02月03日
    浏览(46)
  • 【Spring Cloud】Ribbon 中的几种负载均衡策略

    负载均衡通常有两种实现手段,一种是服务端负载均衡器,另一种是客户端负载均衡器,而我们今天的主角 Ribbon 就属于后者——客户端负载均衡器。 服务端负载均衡器的问题是,它提供了更强的流量控制权,但无法满足不同的消费者希望使用不同负载均衡策略的需求,而使

    2024年02月15日
    浏览(61)
  • Spring Cloud - Ribbon 负载均衡原理、负载策略、懒加载

    目录 ​编辑 一、Ribbon 负载均衡原理 1.1、前言 1.2、负载均衡的工作流程 二、负载均衡策略 2.1、策略原理 2.2、负载均衡自定义方式 三、Ribbon 加载方式 ps:案例是上一章所讲的 “根据订单id查询订单的同时,把订单所属的用户信息一起返回”  。 上一章我们讲到 order-servi

    2024年02月09日
    浏览(37)
  • 【Spring Cloud】Ribbon 实现负载均衡的原理,策略以及饥饿加载

    在前文《深入理解 Eureka 注册中心的原理、服务的注册与发现》中,介绍了如何使用 Eureka 实现服务的注册与拉取,并且通过添加 @LoadBalanced 注解实现了负载均衡。这种自动化的背后隐藏着许多疑问: 服务是在何时进行拉取的? 负载均衡是如何实现的? 负载均衡的原理和策略

    2024年02月07日
    浏览(47)
  • 【springcloud 微服务】Spring Cloud Ribbon 负载均衡使用策略详解

    目录 一、前言 二、什么是Ribbon 2.1 ribbon简介 2.1.1  ribbon在负载均衡中的角色

    2024年02月02日
    浏览(64)
  • Spring Boot 中的 Spring Cloud Ribbon:什么是它,原理及如何使用

    在分布式系统中,服务之间的通信是非常重要的。在大型的分布式系统中,有许多服务需要相互通信,而这些服务可能会部署在多个服务器上。为了实现服务之间的通信,开发人员需要编写大量的代码来处理负载均衡、故障转移和服务发现等问题。为了简化这个过程,Spring

    2024年02月12日
    浏览(40)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包