详解spring cloud config实现datasource的热部署

2023-09-17 20:24:05 287

关于springcloudconfig的基本使用，前面的博客中已经说过了，如果不了解的话，请先看以前的博客

springcloudconfig整合gitlab搭建分布式的配置中心

springcloudconfig分布式配置中心的高可用

今天，我们的重点是如何实现数据源的热部署。

1、在客户端配置数据源

@RefreshScope
@Configuration//配置数据源
publicclassDataSourceConfigure{

@Bean
@RefreshScope//刷新配置文件
@ConfigurationProperties(prefix="spring.datasource")//数据源的自动配置的前缀
publicDataSourcedataSource(){
returnDataSourceBuilder.create().build();
}
}

通过上面的几个步骤，就可以实现在gitlab上修改配置文件，刷新后，服务器不用重启，新的数据源就会生效。

2、自定义数据源的热部署

当我们使用springboot集成druid，我们需要手动来配置数据源，代码如下：

packagecom.chhliu.springcloud.config;
importjava.sql.SQLException;
importjavax.sql.DataSource;
importorg.springframework.beans.factory.annotation.Value;
importorg.springframework.cloud.context.config.annotation.RefreshScope;
importorg.springframework.context.annotation.Bean;
importorg.springframework.context.annotation.Configuration;
importorg.springframework.context.annotation.Primary;
importcom.alibaba.druid.pool.DruidDataSource;
importlombok.extern.slf4j.Slf4j;

/**
*
*描述：如果不使用代码手动初始化DataSource的话，监控界面的SQL监控会没有数据("是springboot的bug???")
*@authorchhliu
*创建时间：2017年2月9日下午7:33:08
*@version1.2.0
*/
@Slf4j
@Configuration
@RefreshScope
publicclassDruidConfiguration{
@Value("${spring.datasource.url}")
privateStringdbUrl;
@Value("${spring.datasource.username}")
privateStringusername;
@Value("${spring.datasource.password}")
privateStringpassword;
@Value("${spring.datasource.driverClassName}")
privateStringdriverClassName;
@Value("${spring.datasource.initialSize}")
privateintinitialSize;
@Value("${spring.datasource.minIdle}")
privateintminIdle;
@Value("${spring.datasource.maxActive}")
privateintmaxActive;
@Value("${spring.datasource.maxWait}")
privateintmaxWait;
@Value("${spring.datasource.timeBetweenEvictionRunsMillis}")
privateinttimeBetweenEvictionRunsMillis;
@Value("${spring.datasource.minEvictableIdleTimeMillis}")
privateintminEvictableIdleTimeMillis;
@Value("${spring.datasource.validationQuery}")
privateStringvalidationQuery;
@Value("${spring.datasource.testWhileIdle}")
privatebooleantestWhileIdle;
@Value("${spring.datasource.testOnBorrow}")
privatebooleantestOnBorrow;
@Value("${spring.datasource.testOnReturn}")
privatebooleantestOnReturn;
@Value("${spring.datasource.poolPreparedStatements}")
privatebooleanpoolPreparedStatements;
@Value("${spring.datasource.maxPoolPreparedStatementPerConnectionSize}")
privateintmaxPoolPreparedStatementPerConnectionSize;
@Value("${spring.datasource.filters}")
privateStringfilters;
@Value("${spring.datasource.connectionProperties}")
privateStringconnectionProperties;
@Value("${spring.datasource.useGlobalDataSourceStat}")
privatebooleanuseGlobalDataSourceStat;

@Bean//声明其为Bean实例
@Primary//在同样的DataSource中，首先使用被标注的DataSource
@RefreshScope
publicDataSourcedataSource(){
DruidDataSourcedatasource=newDruidDataSource();
datasource.setUrl(this.dbUrl);
datasource.setUsername(username);
datasource.setPassword(password);
datasource.setDriverClassName(driverClassName);

//configuration
datasource.setInitialSize(initialSize);
datasource.setMinIdle(minIdle);
datasource.setMaxActive(maxActive);
datasource.setMaxWait(maxWait);
datasource.setTimeBetweenEvictionRunsMillis(timeBetweenEvictionRunsMillis);
datasource.setMinEvictableIdleTimeMillis(minEvictableIdleTimeMillis);
datasource.setValidationQuery(validationQuery);
datasource.setTestWhileIdle(testWhileIdle);
datasource.setTestOnBorrow(testOnBorrow);
datasource.setTestOnReturn(testOnReturn);
datasource.setPoolPreparedStatements(poolPreparedStatements);
datasource.setMaxPoolPreparedStatementPerConnectionSize(maxPoolPreparedStatementPerConnectionSize);
datasource.setUseGlobalDataSourceStat(useGlobalDataSourceStat);
try{
datasource.setFilters(filters);
}catch(SQLExceptione){
log.error("druidconfigurationinitializationfilter:"+e);
}
datasource.setConnectionProperties(connectionProperties);
returndatasource;
}
}

通过上面的示例，也可以实现数据源的动态刷新。接下来，我们就来看看，springcloudconfig是怎么来实现数据源的热部署的。

从前面的博客中，我们不难发现，要想实现动态刷新，关键点就在postrefresh的请求上，那我们就从刷新配置文件开始。
当我们post刷新请求的时候，这个请求会被actuator模块拦截，这点从启动的日志文件中就可以看出


Mapped"{[/refresh||/refresh.json],methods=[POST]}"ontopublicjava.lang.Objectorg.springframework.cloud.endpoint.GenericPostableMvcEndpoint.invoke()

接下来，我们就来看actuator定义的EndPoint，然后我们就找到了RefreshEndpoint这个类，该类的源码如下：

@ConfigurationProperties(prefix="endpoints.refresh",ignoreUnknownFields=false)
@ManagedResource
publicclassRefreshEndpointextendsAbstractEndpoint>{
privateContextRefreshercontextRefresher;
publicRefreshEndpoint(ContextRefreshercontextRefresher){
super("refresh");
this.contextRefresher=contextRefresher;
}
@ManagedOperation
publicString[]refresh(){
Setkeys=contextRefresher.refresh();
returnkeys.toArray(newString[keys.size()]);
}
@Override
publicCollectioninvoke(){
returnArrays.asList(refresh());
}
}

从上面的源码，我们可以看到，重点在ContextRefresher这个类上，由于这个类太长了，下面把这个类的部分源码贴出来：

privateRefreshScopescope;
publicContextRefresher(ConfigurableApplicationContextcontext,RefreshScopescope){
this.context=context;
this.scope=scope;
}
publicsynchronizedSetrefresh(){
Mapbefore=extract(
this.context.getEnvironment().getPropertySources());//1、before，加载提取配置文件
addConfigFilesToEnvironment();//2、将配置文件加载到环境中
Setkeys=changes(before,
extract(this.context.getEnvironment().getPropertySources())).keySet();//3、替换原来环境变量中的值
this.context.publishEvent(newEnvironmentChangeEvent(keys));//4、发布变更事件，
this.scope.refreshAll();
returnkeys;
}

从上面的代码不难看出，重点经历了4个步骤，上面代码中已标注。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。

详解spring cloud config实现datasource的热部署

热门推荐

随机推荐