2023-09-15  阅读(31)
原文作者:王伟王胖胖 原文地址:https://blog.csdn.net/wangwei19871103/article/details/105637787

基本流程图

202309152312179201.png

请求流程

首先SpringMVC请求会分发到test处理方法:

202309152312217962.png
然后一直执行,直到这里被LoadBalancerInterceptor拦截:

202309152312223473.png

拦截处理

其实就是把拦截的地址取出来,然后常见一个新的请求,让负载均衡客户端去执行。

202309152312237454.png

LoadBalancerRequestFactory的createRequest

是一个lambda表达式,最终肯定是会被调用,最后还是用ClientHttpRequestExecution去执行,但是请求是包装过的ServiceRequestWrapper实例:

202309152312247895.png

RibbonLoadBalancerClient的execute

接着看负载均衡客户端怎么执行,这里前面是serviceName服务名,里面变成了serviceId了,好奇怪。

202309152312255116.png
最后到这里,先获取负载均衡器,然后选择一个要请求的服务器,封装成RibbonServer,最后调用执行:

202309152312266167.png

getLoadBalancer根据服务名获取ILoadBalancer类型的负载均衡器

内部是根据SpringClientFactory来获取的。

202309152312272728.png

SpringClientFactory的getInstance

感觉是要去容器拿ILoadBalancer类型的实例。

202309152312278049.png

2023091523122839410.png
最后要得到一个AnnotationConfigApplicationContext,然后去里面拿。

2023091523122939511.png

NamedContextFactory的createContext

其实第一次是拿不到的,contexts里没有缓存,所以要创建一个AnnotationConfigApplicationContext

2023091523123009812.png
这个熟悉吧,就是注解的上下文创建,然后注册一些配置类RibbonClientConfigurationEurekaRibbonClientConfiguration,然后刷新返回。所以这里比较迷惑的地方就是你找不到这两个类在自动配置的时候注册,居然是在这里,藏的好深啊。

    	protected AnnotationConfigApplicationContext createContext(String name) {
    		AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext();
    		if (this.configurations.containsKey(name)) {
    			for (Class<?> configuration : this.configurations.get(name)
    					.getConfiguration()) {
    				context.register(configuration);
    			}
    		}
    		//会注册EurekaRibbonClientConfiguration
    		for (Map.Entry<String, C> entry : this.configurations.entrySet()) {
    			if (entry.getKey().startsWith("default.")) {
    				for (Class<?> configuration : entry.getValue().getConfiguration()) {
    					context.register(configuration);
    				}
    			}
    		}
    		context.register(PropertyPlaceholderAutoConfiguration.class,
    				this.defaultConfigType);//注册RibbonClientConfiguration
    		context.getEnvironment().getPropertySources().addFirst(new MapPropertySource(
    				this.propertySourceName,
    				Collections.<String, Object>singletonMap(this.propertyName, name)));
    		if (this.parent != null) {
    			// Uses Environment from parent as well as beans
    			context.setParent(this.parent);
    			// jdk11 issue
    			// https://github.com/spring-cloud/spring-cloud-netflix/issues/3101
    			context.setClassLoader(this.parent.getClassLoader());
    		}
    		context.setDisplayName(generateDisplayName(name));
    		context.refresh();
    		return context;
    	}

注意RibbonClientConfiguration

这里要注意this.defaultConfigType其实是SpringClientFactory构造函数放入的RibbonClientConfiguration,这个比较隐蔽,居然不是自动配置的时候注册进来的。

2023091523123075413.png
当然这两个配置类注册进来后,注解上下文刷新就会有很多其他的bean实例初始化啦,下篇讲。

好了,今天就到这里了,希望对学习理解有帮助,大神看见勿喷,仅为自己的学习理解,能力有限,请多包涵。


Java 面试宝典是大明哥全力打造的 Java 精品面试题,它是一份靠谱、强大、详细、经典的 Java 后端面试宝典。它不仅仅只是一道道面试题,而是一套完整的 Java 知识体系,一套你 Java 知识点的扫盲贴。

它的内容包括:

  • 大厂真题:Java 面试宝典里面的题目都是最近几年的高频的大厂面试真题。
  • 原创内容:Java 面试宝典内容全部都是大明哥原创,内容全面且通俗易懂,回答部分可以直接作为面试回答内容。
  • 持续更新:一次购买,永久有效。大明哥会持续更新 3+ 年,累计更新 1000+,宝典会不断迭代更新,保证最新、最全面。
  • 覆盖全面:本宝典累计更新 1000+,从 Java 入门到 Java 架构的高频面试题,实现 360° 全覆盖。
  • 不止面试:内容包含面试题解析、内容详解、知识扩展,它不仅仅只是一份面试题,更是一套完整的 Java 知识体系。
  • 宝典详情:https://www.yuque.com/chenssy/sike-java/xvlo920axlp7sf4k
  • 宝典总览:https://www.yuque.com/chenssy/sike-java/yogsehzntzgp4ly1
  • 宝典进展:https://www.yuque.com/chenssy/sike-java/en9ned7loo47z5aw

目前 Java 面试宝典累计更新 400+ 道,总字数 42w+。大明哥还在持续更新中,下图是大明哥在 2024-12 月份的更新情况:

想了解详情的小伙伴,扫描下面二维码加大明哥微信【daming091】咨询

同时,大明哥也整理一套目前市面最常见的热点面试题。微信搜[大明哥聊 Java]或扫描下方二维码关注大明哥的原创公众号[大明哥聊 Java] ,回复【面试题】 即可免费领取。

阅读全文