当前位置: 代码网 > it编程>编程语言>Java > @RefreshScope(nacos配置热更新方式)

@RefreshScope(nacos配置热更新方式)

2024年12月11日 Java 我要评论
@refreshscope(nacos配置热更新)源码分析宏观流程解析1.spring对@refreshscopre注解的bean做的事情当调用被@refreshscope注解的bean的属性的get

@refreshscope(nacos配置热更新)

源码分析

宏观流程解析

1.spring对@refreshscopre注解的bean做的事情

  • 当调用被@refreshscope注解的bean的属性的get方法时 则先从本地缓存里面获取
  • 当本地缓存中 不存在当前bean时 则重新创建 此时 会获取 spring中最新环境配置
  • 如果本地缓存中 存在当前 bean则 直接返回对应属性值

2.nacos对@refreshscopre注解的bean做的事情

  • 当配置更改时 nacos服务端会发步一个配置已被更新事件
  • 此时 naocs客户端 会接受到这个事件 接受到以后 会再在spring中发布环境配置刷新事件
  • 然后 对应的监听器 收到以后 则刷新spring环境配置 以及 清空本地缓存

源码解析

@target({ elementtype.type, elementtype.method })
@retention(retentionpolicy.runtime)
@scope("refresh")
@documented
public @interface refreshscope {

	/**
	 * @see scope#proxymode()
	 * @return proxy mode
	 */
	scopedproxymode proxymode() default scopedproxymode.target_class;

}
org.springframework.context.annotation.classpathbeandefinitionscanner#doscan

org.springframework.context.annotation.annotationconfigutils#applyscopedproxymode
-->org.springframework.context.annotation.scopedproxycreator#createscopedproxy
-->org.springframework.aop.scope.scopedproxyutils#createscopedproxy

org.springframework.cloud.context.scope.genericscope#postprocessbeandefinitionregistry

org.springframework.cloud.context.scope.genericscope.lockedscopedproxyfactorybean#setbeanfactory

org.springframework.aop.scope.scopedproxyfactorybean#setbeanfactory

创建代理

------由上可知,被@refreshscope注解的bean被包装为一个

factorybean(org.springframework.cloud.context.scope.genericscope.lockedscopedproxyfactorybean)

由此调用时就会调用getobject()方法,这样就会得到一个代理对象,执行时会获取到目标对象 simplebeantargetsource.gettarget(),以"scopedtarget."开头的bean,接下来看一下该bean的创建时机

创建target

org.springframework.cloud.context.scope.refresh.refreshscope#onapplicationevent

org.springframework.beans.factory.support.abstractbeanfactory#dogetbean

org.springframework.cloud.context.scope.genericscope#get

以上即@refreshscope的相关对象的创建

由上可知,目标类都会存于scope的cache里

nacoscontextrefresher(nacos配置刷新)

public class nacoscontextrefresher
		implements applicationlistener<applicationreadyevent>, applicationcontextaware

{
    public void onapplicationevent(applicationreadyevent event) {
		// many spring context
		if (this.ready.compareandset(false, true)) {
			this.registernacoslistenersforapplications();
		}
	}

}
com.alibaba.cloud.nacos.refresh.nacoscontextrefresher#registernacoslistenersforapplications
--->com.alibaba.cloud.nacos.refresh.nacoscontextrefresher#registernacoslistener

注册监听器,监听nacos配置变化,并发布refreshevent

org.springframework.cloud.endpoint.event.refresheventlistener#onapplicationevent

org.springframework.cloud.context.refresh.contextrefresher#refresh

1.刷新了环境,2清空cache

首先刷新环境

如下,有个前后对比,关键就在addconfigfilestoenvironment()

首先copyenvironment,虽说是copy,这里只保留了一些最基本的配置,如下

第二步,创建spring容器 capture = builder.run();

这里还是走之前的逻辑,具体可参考

nacos(springcloud)配置加载

只是这次创建的两个spring容器都为annotationconfigapplicationcontext,并且用完就关了

我们看一下方法执行之后的environment

之后的逻辑就是对比两个环境进行替换了,这就是刷新环境的大致流程

然后清空cache

总结

以上为个人经验,希望能给大家一个参考,也希望大家多多支持代码网。

(0)

相关文章:

版权声明:本文内容由互联网用户贡献,该文观点仅代表作者本人。本站仅提供信息存储服务,不拥有所有权,不承担相关法律责任。 如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 2386932994@qq.com 举报,一经查实将立刻删除。

发表评论

验证码:
Copyright © 2017-2025  代码网 保留所有权利. 粤ICP备2024248653号
站长QQ:2386932994 | 联系邮箱:2386932994@qq.com