我要评论前提项目架构：springboot+mybatis-plus-druid
方式一、基于dynamic-datasource-spring-boot-starter实现（配置简单）
1、添加依赖
<!--引入多数据源需要的依赖包--> <dependency> <groupid>com.baomidou</groupid> <artifactid>dynamic-datasource-spring-boot-starter</artifactid> <version>3.1.1</version> </dependency>
2、在application.yml中配置多数据源
spring:
application:
name: zhangjiadayuan-server
datasource:
type: com.alibaba.druid.pool.druiddatasource
# druid的其他属性配置
druid:
# 初始化时建立物理连接的个数
initial-size: 10
# 连接池的最小空闲数量
min-idle: 5
# 连接池最大连接数量
max-active: 20
# 获取连接时最大等待时间，单位毫秒
max-wait: 60000
# 申请连接的时候检测，如果空闲时间大于timebetweenevictionrunsmillis，执行validationquery检测连接是否有效。
test-while-idle: true
# 既作为检测的间隔时间又作为testwhileidel执行的依据
time-between-eviction-runs-millis: 60000
# 销毁线程时检测当前连接的最后活动时间和当前时间差大于该值时，关闭当前连接(配置连接在池中的最小生存时间)
min-evictable-idle-time-millis: 30000
# 用来检测数据库连接是否有效的sql 必须是一个查询语句(oracle中为 select 1 from dual)
validation-query: select 1 from dual
# 申请连接时会执行validationquery检测连接是否有效,开启会降低性能,默认为true
test-on-borrow: false
# 归还连接时会执行validationquery检测连接是否有效,开启会降低性能,默认为true
test-on-return: false
# 是否缓存preparedstatement, 也就是pscache,pscache对支持游标的数据库性能提升巨大，比如说oracle,在mysql下建议关闭。
pool-prepared-statements: false
# 置监控统计拦截的filters，去掉后监控界面sql无法统计，stat: 监控统计、slf4j:日志记录、wall: 防御sql注入
filters: stat,wall,slf4j
# 要启用pscache，必须配置大于0，当大于0时，poolpreparedstatements自动触发修改为true。在druid中，不会存在oracle下pscache占用内存过多的问题，可以把这个数值配置大一些，比如说100
max-pool-prepared-statement-per-connection-size: -1
# 合并多个druiddatasource的监控数据
use-global-data-source-stat: true
# 通过connectproperties属性来打开mergesql功能；慢sql记录
connect-properties: druid.stat.mergesql=true;druid.stat.slowsqlmillis=5000
web-stat-filter:
# 是否启用statfilter默认值true
enabled: true
# 添加过滤规则
url-pattern: /*
# 忽略过滤的格式
exclusions: /druid/*,*.js,*.gif,*.jpg,*.png,*.css,*.ico
stat-view-servlet:
# 是否启用statviewservlet默认值true
enabled: true
# 访问路径为/druid时，跳转到statviewservlet
url-pattern: /druid/*
# 是否能够重置数据
reset-enable: false
# 需要账号密码才能访问控制台，默认为root http://localhost:8585/druid/
login-username: root
login-password: 123456
# ip白名单
allow: 127.0.0.1
# ip黑名单（共同存在时，deny优先于allow）
deny:
dynamic:
primary: master #设置默认的数据源或者数据源组
strict: false #严格匹配数据源，默认为false，true未匹配到数据源时会抛出异常，false使用默认数据源
datasource:
master:
# 数据源基本配置
username: root
password: root123
url: jdbc:mysql://127.0.0.1:3306/zhangjiadayuan?useunicode=true&characterencoding=utf-8&usessl=false&servertimezone=asia/shanghai
# driver-class需要注意mysql驱动的版本(com.mysql.cj.jdbc.driver 或 com.mysql.jdbc.driver)
driver-class-name: com.mysql.cj.jdbc.driver
slave:
# 数据源基本配置
username: root
password: root123
url: jdbc:mysql://127.0.0.1:3306/zhangjiadayuan2?useunicode=true&characterencoding=utf-8&usessl=false&servertimezone=asia/shanghai
# driver-class需要注意mysql驱动的版本(com.mysql.cj.jdbc.driver 或 com.mysql.jdbc.driver)
driver-class-name: com.mysql.cj.jdbc.driver3、排除掉druid的数据源自动配置类
在启动类中需要排除掉druiddatasourceautoconfigure.class，就是取消druid的数据源的自动配置类。
import com.alibaba.druid.spring.boot.autoconfigure.druiddatasourceautoconfigure;
import org.mybatis.spring.annotation.mapperscan;
import org.springframework.boot.springapplication;
import org.springframework.boot.autoconfigure.springbootapplication;
import org.springframework.boot.autoconfigure.jdbc.datasourceautoconfiguration;
import org.springframework.context.annotation.componentscan;
@springbootapplication(exclude = {datasourceautoconfiguration.class, druiddatasourceautoconfigure.class})
@componentscan("cn.zhang.*")
@mapperscan("cn.zhang.mapper")
public class application {
public static void main(string[] args) {
springapplication.run(application.class,args);
}
}4、切换数据源
使用@ds("数据源名字")切换数据源，@ds注解可以用在方法上或类上，同时存在就近原则，方法上注解优先于类上；没有使用@ds默认使用默认数据源。
方式二、基于自定义注解
1、配置文件配置多数据源
spring:
datasource:
druid:
db1:
driver-class-name: com.mysql.jdbc.driver
url: jdbc:mysql://127.0.0.1:3306/db1?allowmultiqueries=true&useunicode=true&characterencoding=utf-8&usessl=false&servertimezone=asia/shanghai&zerodatetimebehavior=convert_to_null&autoreconnect=true
username: root
password: 123456
db2:
driver-class-name: com.mysql.jdbc.driver
url: jdbc:mysql://127.0.0.1:3306/db2?allowmultiqueries=true&useunicode=true&characterencoding=utf-8&usessl=false&servertimezone=asia/shanghai&zerodatetimebehavior=convert_to_null&autoreconnect=true
username: root
password: 123456
test-on-borrow: true2、定义数据源配置类
该类的作用就是初始化数据源datasource实例，以及初始化sqlsessionfactory实例。这里需要注意的是必须使用mybatissqlsessionfactorybean来获取会话工厂sqlsessionfactory，不然的话，basemapper中的生成动态sql的方法就不能使用了。
@configuration(basepackages = mybatisconfig.base_package, sqlsessiontemplateref = "sqlsessiontemplate")
public class datasourceconfigurer {
//mapper模式下的接口层
static final string base_package = "cn.zhang.mapper";
public static final string classpath_mapping_xml = "classpath*:mapper/*.xml";
/**
* 配置数据源
*
* @return
*/
@bean(name = "db1")
@primary
@configurationproperties(prefix = "spring.datasource.druid.db1")
public datasource db1() {
return druiddatasourcebuilder.create().build();
}
/**
* 配置数据源
*
* @return
*/
@bean(name = "db2")
@configurationproperties(prefix = "spring.datasource.druid.db2")
public datasource db2() {
return druiddatasourcebuilder.create().build();
}
@bean(name = "dynamicdatasource")
public datasource dynamicdatasource() {
dynamicroutingdatasource dynamicroutingdatasource = new dynamicroutingdatasource();
map<object, object> datasourcemap = new hashmap<object, object>(2);
datasourcemap.put(datasourcekey.master.getname(), db1());
datasourcemap.put(datasourcekey.slave.getname(), db2());
dynamicroutingdatasource.setdefaulttargetdatasource(dcs());
dynamicroutingdatasource.settargetdatasources(datasourcemap);
dynamicdatasourcecontextholder.datasourcekeys.addall(datasourcemap.keyset());
return dynamicroutingdatasource;
}
@bean
public sqlsessionfactory sqlsessionfactory() throws exception {
//mybatisplus使用的是mybatissqlsessionfactory
mybatissqlsessionfactorybean sqlsessionfactorybean = new mybatissqlsessionfactorybean();
sqlsessionfactorybean.setdatasource(dynamicdatasource());
//此处设置为了解决找不到mapper文件的问题
sqlsessionfactorybean.setmapperlocations(new pathmatchingresourcepatternresolver().getresources(classpath_mapping_xml));
return sqlsessionfactorybean.getobject();
}
@bean
public sqlsessiontemplate sqlsessiontemplate() throws exception {
return new sqlsessiontemplate(sqlsessionfactory());
}
/**
* 事务
*
* @return
*/
@bean
public platformtransactionmanager transactionmanager() {
return new datasourcetransactionmanager(dynamicdatasource());
}/**
* 该类继承自 abstractroutingdatasource 类，
* 在访问数据库时会调用该类的 determinecurrentlookupkey() 方法获取数据库实例的 key
*/
public class dynamicroutingdatasource extends abstractroutingdatasource {
@override
protected object determinecurrentlookupkey() {
logger.info("current datasource is : {}", dynamicdatasourcecontextholder.getdatasourcekey());
return dynamicdatasourcecontextholder.getdatasourcekey();
}
}public class dynamicdatasourcecontextholder {
private static threadlocal<object> context_holder = threadlocal.withinitial(() -> datasourcekey.dcs.getname());
public static list<object> datasourcekeys = new arraylist<object>();
public static void setdatasourcekey(string key){
context_holder.set(key);
}
public static object getdatasourcekey(){
return context_holder.get();
}
public static void cleardatasourcekey(){
context_holder.remove();
}
public static boolean containdatasourcekey(string key){
return datasourcekeys.contains(key);
}
}public enum datasourcekey {
master("db1"),
slave("db2");
private string name;
public string getname() {
return name;
}
public void setname(string name) {
this.name = name;
}
private datasourcekey(string name) {
this.name = name;
}
}3、自定义注解和定义切面
//该注解只是作用在方法上，这里默认的数据源是db1
@target({elementtype.method, elementtype.type})
@retention(retentionpolicy.runtime)
@documented
public @interface targetdatasource {
string value() default "db1";
}切面顾名思义就是拦击标注自定义注解@targetdatasource注解的方法，并且根据注解指定的数据源的key切换数据源。
@aspect
@component
public class dynamicdatasourceaspect {
private logger logger = loggerfactory.getlogger(dynamicdatasourceaspect.class);
@before("@annotation(targetdatasource)")
public void switchdatasource(joinpoint joinpoint, targetdatasource targetdatasource) {
if (!dynamicdatasourcecontextholder.containdatasourcekey(targetdatasource.value().getname())) {
logger.error("datasource [{}] doesn't exist, use default datasource [{}]", targetdatasource.value());
} else {
dynamicdatasourcecontextholder.setdatasourcekey(targetdatasource.value().getname());
logger.info("switch datasource to [{}] in method [{}]", dynamicdatasourcecontextholder.getdatasourcekey(), joinpoint.getsignature());
}
}
@after("@annotation(targetdatasource)")
public void restoredatasource(joinpoint joinpoint, targetdatasource targetdatasource) {
dynamicdatasourcecontextholder.cleardatasourcekey();
logger.info("restore datasource to [{}] in method [{}]", dynamicdatasourcecontextholder.getdatasourcekey(), joinpoint.getsignature());
}
}4、使用切换数据源
//也可用与service方法或类上
@targetdatasource("db2")
string getclassstudent(@param("open_id") string openid);到此这篇关于springboot项目配置多数据源的两种方式详解的文章就介绍到这了,更多相关springboot配置多数据源内容请搜索代码网以前的文章或继续浏览下面的相关文章希望大家以后多多支持代码网！
发表评论