怎么在SpringBoot中利用nacos对数据源进行动态刷新-创新互联
怎么在SpringBoot中利用nacos对数据源进行动态刷新?相信很多没有经验的人对此束手无策,为此本文总结了问题出现的原因和解决方法,通过这篇文章希望你能解决这个问题。
专注于为中小企业提供成都网站设计、网站建设服务,电脑端+手机端+微信端的三站合一,更高效的管理,为中小企业德阳免费做网站提供优质的服务。我们立足成都,凝聚了一批互联网行业人才,有力地推动了超过千家企业的稳健成长,帮助中小企业通过网站建设实现规模扩充和转变。第一步:重写DruidAbstractDataSource类
这里为什么要重写这个类:因为DruidDataSource数据源在初始化后,就不允许再重新设置数据库的url和userName
public void setUrl(String jdbcUrl) { if (StringUtils.equals(this.jdbcUrl, jdbcUrl)) { return; } // 重写的时候,需要将这个判断注释掉,否则会报错 // if (inited) { // throw new UnsupportedOperationException(); // } if (jdbcUrl != null) { jdbcUrl = jdbcUrl.trim(); } this.jdbcUrl = jdbcUrl; // if (jdbcUrl.startsWith(ConfigFilter.URL_PREFIX)) { // this.filters.add(new ConfigFilter()); // } } public void setUsername(String username) { if (StringUtils.equals(this.username, username)) { return; } // 重写的时候,需要将这个判断注释掉,否则会报错 // if (inited) { // throw new UnsupportedOperationException(); // } this.username = username; }
重写的时候包路径不能变,只有这样类加载的时候才会优先加载重写后的类
第二步:配置动态获取nacos配置信息
package com.mp.demo.config; import com.alibaba.druid.pool.DruidDataSource; import lombok.Data; import lombok.extern.slf4j.Slf4j; 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; @Slf4j @Configuration @RefreshScope @Data 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.driver-class-name}") private String driverClassName; @Bean @RefreshScope public DruidDataSource dataSource() { DruidDataSource datasource = new DruidDataSource(); datasource.setUrl(this.dbUrl); datasource.setUsername(username); datasource.setPassword(password); datasource.setDriverClassName(driverClassName); return datasource; } }
这里要注意增加@RefreshScope
注解
第三步:手动刷新数据源
@GetMapping("/refresh") public String refresh() throws SQLException { DruidDataSource master = SpringUtils.getBean("dataSource"); master.setUrl(druidConfiguration.getDbUrl()); master.setUsername(druidConfiguration.getUsername()); master.setPassword(druidConfiguration.getPassword()); master.setDriverClassName(druidConfiguration.getDriverClassName()); master.restart(); return userName + "<>" + jdbcUrl+"----------"+druidConfiguration.getDbUrl(); }
看完上述内容,你们掌握怎么在SpringBoot中利用nacos对数据源进行动态刷新的方法了吗?如果还想学到更多技能或想了解更多相关内容,欢迎关注创新互联行业资讯频道,感谢各位的阅读!
网页题目:怎么在SpringBoot中利用nacos对数据源进行动态刷新-创新互联
URL链接:http://scyanting.com/article/eosgi.html