关于spring cloud config的基本使用,前面的博客中已经说过了,如果不了解的话,请先看以前的博客
spring cloud config整合gitlab搭建分布式的配置中心
spring cloud config分布式配置中心的高可用
今天,我们的重点是如何实现数据源的热部署。
1、在客户端配置数据源
- @RefreshScope
- @Configuration// 配置数据源
- public class DataSourceConfigure {
- @Bean
- @RefreshScope// 刷新配置文件
- @ConfigurationProperties(prefix="spring.datasource") // 数据源的自动配置的前缀
- public DataSource dataSource(){
- return DataSourceBuilder.create().build();
- }
- }
通过上面的几个步骤,就可以实现在gitlab上修改配置文件,刷新后,服务器不用重启,新的数据源就会生效。
2、自定义数据源的热部署
当我们使用spring boot集成druid,我们需要手动来配置数据源,代码如下:
- package com.chhliu.springcloud.config;
- import java.sql.SQLException;
- import javax.sql.DataSource;
- import org.springframework.beans.factory.annotation.Value;
- import org.springframework.cloud.context.config.annotation.RefreshScope;
- import org.springframework.context.annotation.Bean;
- import org.springframework.context.annotation.Configuration;
- import org.springframework.context.annotation.Primary;
- import com.alibaba.druid.pool.DruidDataSource;
- import lombok.extern.slf4j.Slf4j;
- /**
- *
- * 描述:如果不使用代码手动初始化DataSource的话,监控界面的SQL监控会没有数据("是spring boot的bug???")
- * @author chhliu
- * 创建时间:2017年2月9日 下午7:33:08
- * @version 1.2.0
- */
- @Slf4j
- @Configuration
- @RefreshScope
- public class DruidConfiguration {
- @Value("${spring.datasource.url}")
- private String dbUrl;
- @Value("${spring.datasource.username}")
- private String username;
- @Value("${spring.datasource.password}")
- private String password;
- @Value("${spring.datasource.driverClassName}")
- private String driverClassName;
- @Value("${spring.datasource.initialSize}")
- private int initialSize;
- @Value("${spring.datasource.minIdle}")
- private int minIdle;
- @Value("${spring.datasource.maxActive}")
- private int maxActive;
- @Value("${spring.datasource.maxWait}")
- private int maxWait;
- @Value("${spring.datasource.timeBetweenEvictionRunsMillis}")
- private int timeBetweenEvictionRunsMillis;
- @Value("${spring.datasource.minEvictableIdleTimeMillis}")
- private int minEvictableIdleTimeMillis;
- @Value("${spring.datasource.validationQuery}")
- private String validationQuery;
- @Value("${spring.datasource.testWhileIdle}")
- private boolean testWhileIdle;
- @Value("${spring.datasource.testOnBorrow}")
- private boolean testOnBorrow;
- @Value("${spring.datasource.testOnReturn}")
- private boolean testOnReturn;
- @Value("${spring.datasource.poolPreparedStatements}")
- private boolean poolPreparedStatements;
- @Value("${spring.datasource.maxPoolPreparedStatementPerConnectionSize}")
- private int maxPoolPreparedStatementPerConnectionSize;
- @Value("${spring.datasource.filters}")
- private String filters;
- @Value("${spring.datasource.connectionProperties}")
- private String connectionProperties;
- @Value("${spring.datasource.useGlobalDataSourceStat}")
- private boolean useGlobalDataSourceStat;
- @Bean //声明其为Bean实例
- @Primary //在同样的DataSource中,首先使用被标注的DataSource
- @RefreshScope
- public DataSource dataSource(){
- DruidDataSource datasource = new DruidDataSource();
- 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 (SQLException e) {
- log.error("druid configuration initialization filter: "+ e);
- }
- datasource.setConnectionProperties(connectionProperties);
- return datasource;
- }
- }
通过上面的示例,也可以实现数据源的动态刷新。接下来,我们就来看看,spring cloud config是怎么来实现数据源的热部署的。
从前面的博客中,我们不难发现,要想实现动态刷新,关键点就在post refresh的请求上,那我们就从刷新配置文件开始。
当我们post刷新请求的时候,这个请求会被actuator模块拦截,这点从启动的日志文件中就可以看出
- Mapped "{[/refresh || /refresh.json],methods=[POST]}" onto public java.lang.Object org.springframework.cloud.endpoint.GenericPostableMvcEndpoint.invoke()
接下来,我们就来看actuator定义的EndPoint,然后我们就找到了RefreshEndpoint这个类,该类的源码如下:
- @ConfigurationProperties(prefix = "endpoints.refresh", ignoreUnknownFields = false)
- @ManagedResource
- public class RefreshEndpoint extends AbstractEndpoint<Collection<String>> {
- private ContextRefresher contextRefresher;
- public RefreshEndpoint(ContextRefresher contextRefresher) {
- super("refresh");
- this.contextRefresher = contextRefresher;
- }
- @ManagedOperation
- public String[] refresh() {
- Set<String> keys = contextRefresher.refresh();
- return keys.toArray(new String[keys.size()]);
- }
- @Override
- public Collection<String> invoke() {
- return Arrays.asList(refresh());
- }
- }
从上面的源码,我们可以看到,重点在ContextRefresher这个类上,由于这个类太长了,下面把这个类的部分源码贴出来:
- private RefreshScope scope;
- public ContextRefresher(ConfigurableApplicationContext context, RefreshScope scope) {
- this.context = context;
- this.scope = scope;
- }
- public synchronized Set<String> refresh() {
- Map<String, Object> before = extract(
- this.context.getEnvironment().getPropertySources());// 1、before,加载提取配置文件
- addConfigFilesToEnvironment();// 2、将配置文件加载到环境中
- Set<String> keys = changes(before,
- extract(this.context.getEnvironment().getPropertySources())).keySet();// 3、替换原来环境变量中的值
- this.context.publishEvent(new EnvironmentChangeEvent(keys));// 4、发布变更事件,
- this.scope.refreshAll();
- return keys;
- }
从上面的代码不难看出,重点经历了4个步骤,上面代码中已标注。
http://blog.csdn.net/liuchuanhong1/article/details/75446850
相关推荐
"Spring Cloud Config实现...同时,我们也学习了如何使用自定义的数据源实现方式来实现热部署。 使用Spring Cloud Config实现Datasource热部署可以帮助我们快速地更新和部署配置信息,从而提高系统的可用性和灵活性。
总结来说,Spring Cloud Config提供了集中化的外部配置管理,而Spring Cloud Bus则扩展了Spring Cloud Config的功能,实现了配置的动态刷新。本文从源码角度解读了Config Server的初始化过程、配置获取处理以及Bus的...
Spring Cloud Config 配置文件加密方式 Spring Cloud Config 是一个基于云计算的配置中心,它提供了对应用程序配置的集中管理和加密。配置文件加密是 Spring Cloud Config 的一个重要特性,它可以保护敏感数据不被...
赠送jar包:spring-cloud-alibaba-sentinel-datasource-2021.1.jar; 赠送原API文档:spring-cloud-alibaba-sentinel-datasource-2021.1-javadoc.jar; 赠送源代码:spring-cloud-alibaba-sentinel-datasource-2021....
为了在Spring Cloud服务中使用Flowable,我们需要编写服务接口和实现,用于启动、查询、参与等工作流操作。例如,我们可以创建一个`WorkflowService`,提供`startProcessInstanceByKey`方法来根据流程定义的key启动...
在初学SpringCloud的过程中,与Oracle数据库的连接是构建分布式系统的一个重要环节。SpringCloud作为一个微服务框架,提供了丰富的服务治理功能,而数据库作为数据存储的核心,与SpringBoot的集成使得我们可以轻松...
6、MYSQL(执行springcloud-producer目录src/main/resources/templates/datasource.text中的建表语句) #### 使用说明 项目运行顺序: 1、 springcloud-register, 2、 springcloud-config-native或者springcloud-...
在Spring Cloud生态系统中,整合MyBatis作为持久层框架是一个常见的需求。这允许开发者利用Spring Cloud的强大服务发现和治理功能,结合MyBatis的灵活数据库操作能力,构建微服务架构的应用程序。以下将详细介绍如何...
赠送jar包:spring-cloud-alibaba-sentinel-datasource-2021.1.jar; 赠送原API文档:spring-cloud-alibaba-sentinel-datasource-2021.1-javadoc.jar; 赠送源代码:spring-cloud-alibaba-sentinel-datasource-2021....
"Spring动态切换datasource实现mysql多主多从"是针对大型分布式系统中数据读写分离、负载均衡的一种常见策略。该技术使得应用程序能够在运行时根据业务需求灵活地选择不同的数据源,从而提高系统的可扩展性和可用性...
2020最新版SpringCloud(H版&alibaba)框架开发教程全套完整版从入门到精通(121-150讲)
Spring Cloud Config满足了以上所有需求,可以实现配置中心的功能。 二、配置中心的实现 配置中心微服务使用Spring Boot框架来实现,pom.xml文件中需要添加以下依赖项: * spring-cloud-starter-netflix-eureka-...
1. **服务发现**:Spring Cloud Connectors通过读取环境变量或配置文件,自动发现应用部署在云环境中的服务实例。 2. **自动配置**:一旦服务被发现,Connectors会自动生成相应的配置,将这些配置注入到Spring应用...
Spring Cloud是实现微服务架构的一套框架,它提供了许多工具和服务,以简化微服务的开发和管理。Spring Cloud基于Spring Boot,使得创建和配置微服务变得简单易行。Spring Boot是一个快速开发框架,用于简化Spring...
Spring Cloud集成MyBatis-Plus是一项常见的微服务开发任务,旨在利用MyBatis-Plus的便利性增强Spring Cloud应用的数据访问能力。MyBatis-Plus是MyBatis的扩展库,它简化了许多常见的MyBatis操作,如CRUD操作、条件...
3. **Eureka目录**:服务注册与发现是Spring Cloud的基础,Eureka是实现这一功能的组件,这里可能会有Eureka Server的配置和客户端代码。 4. **Ribbon目录**:Ribbon是客户端负载均衡器,用于在服务间进行请求分发,...
Spring Cloud 是一系列框架的有序集合,它利用了Spring Boot的开发便利性巧妙地简化了分布式系统基础设施的开发,如服务发现注册、配置中心、消息总线、负载均衡、断路器、数据监控等,并且都基于Spring Boot实现。...
4. **Spring Cloud Config**:配置管理工具,允许开发者在外部存储配置,便于在多环境中灵活切换。 5. **Spring Cloud Bus**:消息总线,可以用来实现配置的实时刷新,提高系统的响应速度。 在实际开发中,数据库...
该项目为自己使用maven搭建的一个初始的SpringCloud项目,该项目用于节约搭建时间。 已发布于Gitee。 软件架构 项目内容包括三部分: (1)父工程 (2)子工程orderService (3)子工程userService 安装和启动教程...