利用SpringBoot实现多数据源的两种方式总结

前言

公司项目有连接多个不同数据库的需求，特研究了一下，根据网上的资料，造了一个基于aop方式的数据源切换*，但继续探索，突然发现有开源的多数据源管理启动器。不过，本篇两种方式都会介绍。

基于dynamic-datasource实现多数据源

dynamic-datasource介绍

dynamic-datasource-spring-boot-starter 是一个基于springboot的快速集成多数据源的启动器。

其支持 jdk 1.7+, springboot 1.4.x 1.5.x 2.x.x

dynamic-datasource特性

• 支持 数据源分组 ，适用于多种场景 纯粹多库 读写分离 一主多从 混合模式。
• 支持数据库敏感配置信息 加密 enc()。
• 支持每个数据库独立初始化表结构schema和数据库database。
• 支持无数据源启动，支持懒加载数据源（需要的时候再创建连接）。
• 支持 自定义注解 ，需继承ds(3.2.0+)。
• 提供并简化对druid，hikaricp，beecp，dbcp2的快速集成。
• 提供对mybatis-plus，quartz，shardingjdbc，p6sy，jndi等组件的集成方案。
• 提供 自定义数据源来源 方案（如全从数据库加载）。
• 提供项目启动后 动态增加移除数据源 方案。
• 提供mybatis环境下的 纯读写分离 方案。
• 提供使用 spel动态参数 解析数据源方案。内置spel，session，header，支持自定义。
• 支持 多层数据源嵌套切换 。（servicea >>> serviceb >>> servicec）。
• 提供 基于seata的分布式事务方案。
• 提供 本地多数据源事务方案。 附：不能和原生spring事务混用。
  

我们目前只探讨使用dynamic-datasource进行数据源切换，其他请自行搜索

dynamic-datasource的相关约定

• dynamic-datasource只做 切换数据源 这件核心的事情，并不限制你的具体操作，切换了数据源可以做任何crud。
• 配置文件所有以下划线 _ 分割的数据源 首部 即为组的名称，相同组名称的数据源会放在一个组下。
• 切换数据源可以是组名，也可以是具体数据源名称。组名则切换时采用负载均衡算法切换。
• 默认的数据源名称为 master ，你可以通过 spring.datasource.dynamic.primary 修改。
• 方法上的注解优先于类上注解。
• ds支持继承抽象类上的ds，暂不支持继承接口上的ds。
  

 引入dynamic-datasource依赖

<dependency>
  <groupid>com.baomidou</groupid>
  <artifactid>dynamic-datasource-spring-boot-starter</artifactid>
  <version>${version}</version>
</dependency>

配置数据源

spring:
  datasource:
    dynamic:
      primary: mysql #设置默认的数据源或者数据源组,默认值即为master
      strict: false #严格匹配数据源,默认false. true未匹配到指定数据源时抛异常,false使用默认数据源
      datasource:
        mysql:
          url: jdbc:mysql://xx.xx.xx.xx:3306/dynamic
          username: root
          password: 123456
          driver-class-name: com.mysql.jdbc.driver # 3.2.0开始支持spi可省略此配置
        pgsql:
          url: enc(xxxxx) # 内置加密
          username: enc(xxxxx)
          password: enc(xxxxx)
          driver-class-name: org.postgresql.driver

使用 @ds 切换数据源

@ds 可以注解在方法上或类上，同时存在就近原则 方法上注解 优先于 类上注解。

注解	结果
不使用@ds注解	默认数据源，即primary: mysql
@ds(“dsname”)	dsname可以为组名也可以为具体某个库的名称

@ds使用实例

@service
@ds("mysql")
public class userserviceimpl implements userservice {

  @autowired
  private jdbctemplate jdbctemplate;

  // 不使用@ds注解则代表使用默认数据源
  // 如果类上存在，则使用类上标注的数据源
  public list selectall() {
    return  jdbctemplate.queryforlist("select * from user");
  }
  
  @override
  @ds("pgsql")
  // 方法上注解 优先于 类上注解，即使类上标注也优先采用方法上的标注
  public list selectbycondition() {
    return  jdbctemplate.queryforlist("select * from user where age >10");
  }
}

基于aop手动实现多数据源

本次代码参考 https://github.com/mianshenglee/my-example/tree/master/multi-datasource/dynamic-datasource ，因源码不满足的需求，因此我在此基础做了修改。

项目工程结构

项目依赖

<?xml version="1.0" encoding="utf-8"?>
<project xmlns="http://maven.apache.org/pom/4.0.0" xmlns:xsi="http://www.w3.org/2001/xmlschema-instance"
         xsi:schemalocation="http://maven.apache.org/pom/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelversion>4.0.0</modelversion>
    <parent>
        <groupid>org.springframework.boot</groupid>
        <artifactid>spring-boot-starter-parent</artifactid>
        <version>2.2.2.release</version>
        <relativepath/> <!-- lookup parent from repository -->
    </parent>
    <groupid>me.mason.demo</groupid>
    <artifactid>dynamic-datasource</artifactid>
    <version>0.0.1-snapshot</version>
    <name>dynamic-datasource</name>
    <description>demo project for dynamic datasource</description>

    <properties>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>
        <!--spring boot-->
        <dependency>
            <groupid>org.springframework.boot</groupid>
            <artifactid>spring-boot-starter-web</artifactid>
        </dependency>
        <dependency>
            <groupid>org.springframework.boot</groupid>
            <artifactid>spring-boot-configuration-processor</artifactid>
        </dependency>
        <dependency>
            <groupid>com.alibaba</groupid>
            <artifactid>druid-spring-boot-starter</artifactid>
            <version>1.1.9</version>
        </dependency>
        <dependency>
            <groupid>org.springframework.boot</groupid>
            <artifactid>spring-boot-starter-jdbc</artifactid>
        </dependency>
        <dependency>
            <groupid>org.springframework.boot</groupid>
            <artifactid>spring-boot-starter-aop</artifactid>
        </dependency>
        <!--mysql 驱动-->
        <dependency>
            <groupid>mysql</groupid>
            <artifactid>mysql-connector-java</artifactid>
            <scope>runtime</scope>
        </dependency>
        <!--mybatis-plus-->
        <dependency>
            <groupid>com.baomidou</groupid>
            <artifactid>mybatis-plus-boot-starter</artifactid>
            <version>3.3.0</version>
        </dependency>
        <dependency>
            <groupid>org.projectlombok</groupid>
            <artifactid>lombok</artifactid>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupid>org.springframework.boot</groupid>
            <artifactid>spring-boot-starter-test</artifactid>
            <scope>test</scope>
            <exclusions>
                <exclusion>
                    <groupid>org.junit.vintage</groupid>
                    <artifactid>junit-vintage-engine</artifactid>
                </exclusion>
            </exclusions>
        </dependency>

    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupid>org.springframework.boot</groupid>
                <artifactid>spring-boot-maven-plugin</artifactid>
            </plugin>
        </plugins>
    </build>

</project>

配置文件

server.port=8080
server.servlet.context-path=/dd

logging.level.root=info
logging.level.me.mason.demo.dynamicdatasource.mapper=debug

# mybatis-plus
mybatis-plus.type-aliases-package=me.mason.demo.dynamicdatasource.entity
# 默认位置，可不配置
#mybatis-plus.mapper-locations=classpath*:/mapper/*.xml
mybatis.mapper-locations=classpath*:/mapper/*.xml
# 使用数据库自增id
mybatis-plus.global-config.db-config.id-type=auto

# master
spring.datasource.master.driver-class-name=com.mysql.cj.jdbc.driver
spring.datasource.master.url=jdbc:mysql://10.0.1.243:3306/scheduling?usessl=false&servertimezone=gmt%2b8&characterencoding=utf-8
spring.datasource.master.username=root
spring.datasource.master.password=123456

# slave
spring.datasource.slave.driver-class-name=com.mysql.cj.jdbc.driver
spring.datasource.slave.url=jdbc:mysql://10.0.1.243:3306/scheduling1?usessl=false&servertimezone=gmt%2b8&characterencoding=utf-8
spring.datasource.slave.username=root
spring.datasource.slave.password=123456

自定义注解

// 标记注解可使用在方法与类上
@target({elementtype.method,elementtype.type})
@retention(retentionpolicy.runtime)
public @interface ds {
	// 默认值为master
    string value() default datasourceconstants.ds_key_master;
}

编写datasourceconstants

/**
 * 数据源常量
 **/
public class datasourceconstants {
    /**
     * master数据源
     */
    public static final string ds_key_master = "master";
    /**
     * slave数据源
     */
    public static final string ds_key_slave = "slave";
}

动态数据源名称上下文处理

/**
 * 动态数据源名称上下文处理
 **/
public class dynamicdatasourcecontextholder {

    /**
     * 动态数据源名称上下文
     */
    private static final threadlocal<string> datasource_context_key_holder = new threadlocal<>();

    /**
     * 设置数据源
     * @param key
     */
    public static void setcontextkey(string key){
        datasource_context_key_holder.set(key);
    }

    /**
     * 获取数据源名称
     * @return
     */
    public static string getcontextkey(){
        string key = datasource_context_key_holder.get();
        return key == null?datasourceconstants.ds_key_master:key;
    }

    /**
     * 删除当前数据源名称
     */
    public static void removecontextkey(){
        datasource_context_key_holder.remove();
    }
}

获取当前动态数据源方法

/**
 * 动态数据源
 **/
public class dynamicdatasource extends abstractroutingdatasource {

    @override
    protected object determinecurrentlookupkey() {
        return dynamicdatasourcecontextholder.getcontextkey();
    }
}

动态数据源配置

/**
 * 动态数据源配置
 **/
@enableautoconfiguration(exclude = { datasourceautoconfiguration.class })
@configuration
// 此处我们
//@propertysource("classpath:config/jdbc.properties")
@mapperscan(basepackages = "me.mason.demo.dynamicdatasource.mapper")
public class dynamicdatasourceconfig {
    @bean(datasourceconstants.ds_key_master)
    // 需要与配置文件中对应
    @configurationproperties(prefix = "spring.datasource.master")
    public druiddatasource masterdatasource() {
        return druiddatasourcebuilder.create().build();
    }

    @bean(datasourceconstants.ds_key_slave)
    @configurationproperties(prefix = "spring.datasource.slave")
    public druiddatasource slavedatasource() {
        return druiddatasourcebuilder.create().build();
    }

    @bean
    @primary
    public dynamicdatasource dynamicdatasource() {
        map<object, object> datasourcemap = new hashmap<>(2);
        datasourcemap.put(datasourceconstants.ds_key_master, masterdatasource());
        datasourcemap.put(datasourceconstants.ds_key_slave, slavedatasource());
        //设置动态数据源
        dynamicdatasource dynamicdatasource = new dynamicdatasource();
        dynamicdatasource.settargetdatasources(datasourcemap);
        dynamicdatasource.setdefaulttargetdatasource(masterdatasource());
        return dynamicdatasource;
    }

}

aop切面

/**
 * 切面
 */
@aspect
@component
//@order(-10)
public class dynamicdatasourceaspect {
	// 以在类上使用了@service作为切入点
    @pointcut("@within(org.springframework.stereotype.service)")
    public void datasourcepointcut() {
    }

    @around("datasourcepointcut()")
    public object around(proceedingjoinpoint joinpoint) throws throwable {
        methodsignature signature = (methodsignature) joinpoint.getsignature();
        class<?> aclass = class.forname(signature.getdeclaringtype().getname());
        // 方法优先，如果方法上存在注解，则优先使用方法上的注解
        if (signature.getmethod().isannotationpresent(ds.class)) { dynamicdatasourcecontextholder.setcontextkey(signature.getmethod().getannotation(ds.class).value());
            // 其次类优先，如果类上存在注解，则使用类上的注解
        }else  if (aclass.isannotationpresent(ds.class)) { dynamicdatasourcecontextholder.setcontextkey(aclass.getannotation(ds.class).value());
            // 如果都不存在，则使用默认
        }   else {
 dynamicdatasourcecontextholder.setcontextkey(datasourceconstants.ds_key_master);
        }
        try {
            return joinpoint.proceed();
        } finally {
            dynamicdatasourcecontextholder.removecontextkey();
        }
    }
}

编写testuser实体

@data
@tablename("test_user")
public class testuser implements serializable {

    private static final long serialversionuid = 1l;

    /** id */
    private long id;
    /** 姓名 */
    private string name;
    /** 手机号 */
    private string phone;
    /** 职称职别 */
    private string title;
    /** 邮箱 */
    private string email;
    /** 性别 */
    private string gender;
    /** 出生时间 */
    private date dateofbirth;
    /** 1:已删除,0:未删除 */
    private integer deleted;
    /** 创建时间 */
    private date syscreatetime;
    /** 创建人 */
    private string syscreateuser;
    /** 更新时间 */
    private date sysupdatetime;
    /** 更新人 */
    private string sysupdateuser;
    /** 版本号 */
    private long recordversion;

    public testuser() {
    }

}

testusermapper

@repository
public interface testusermapper extends basemapper<testuser> {

    /**
     * 自定义查询
     * @param wrapper 条件构造器
     * @return
     */
    list<testuser> selectall(@param(constants.wrapper) wrapper<testuser> wrapper);
}

testuserservice

@service
//@ds(datasourceconstants.ds_key_slave)
public class testuserservice {
    @autowired
    private testusermapper testusermapper;

    /**
     * 查询master库user
     * @return
     */
//    @ds(datasourceconstants.ds_key_master)
    public list<testuser> getmasteruser(){
        querywrapper<testuser> querywrapper = new querywrapper<>();
        return testusermapper.selectall(querywrapper.isnotnull("name"));
    }

    /**
     * 查询slave库user
     * @return
     */
//    @ds(datasourceconstants.ds_key_master)
    public list<testuser> getslaveuser(){
        return testusermapper.selectlist(null);
    }
}

testusercontroller

@restcontroller
@requestmapping("/user")
public class testusercontroller {
    @autowired
    private testuserservice testuserservice;
    /**
     * 查询全部
     */
    @getmapping("/listall")
    public object listall() {
        int initsize = 2;
        map<string, object> result = new hashmap<>(initsize);
        list<testuser> masteruser = testuserservice.getmasteruser();
        result.put("masteruser", masteruser);
        list<testuser> slaveuser = testuserservice.getslaveuser();
        result.put("getslaveuser", slaveuser);
        return responseresult.success(result);
    }

}

mapperxml

<?xml version="1.0" encoding="utf-8" ?>
<!doctype mapper
        public "-//mybatis.org//dtd mapper 3.0//en"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="me.mason.demo.dynamicdatasource.mapper.testusermapper">
    <select id="selectall" resulttype="me.mason.demo.dynamicdatasource.entity.testuser">
        select * from test_user
        <if test="ew!=null">
          ${ew.customsqlsegment}
        </if>
    </select>
</mapper>

启动测试

不使用注解

@service
//@ds(datasourceconstants.ds_key_slave)
public class testuserservice {
    @autowired
    private testusermapper testusermapper;


    /**
     * 查询master库user
     * @return
     */
//    @ds(datasourceconstants.ds_key_master)
    public list<testuser> getmasteruser(){
        querywrapper<testuser> querywrapper = new querywrapper<>();
        return testusermapper.selectall(querywrapper.isnotnull("name"));
    }

    /**
     * 查询slave库user
     * @return
     */
//    @ds(datasourceconstants.ds_key_master)
    public list<testuser> getslaveuser(){
        return testusermapper.selectlist(null);
    }

}

效果

该代码优先级与使用框架效果一致，即不使用注解将默认使用master数据库，方法上存在注解优先使用方法上标注的注解。

已知master 6条数据， slave4条数据

访问 http://127.0.0.1:8080/dd/user/listall 查看效果

类上使用注解

@service
@ds(datasourceconstants.ds_key_slave)
public class testuserservice {
    @autowired
    private testusermapper testusermapper;


    /**
     * 查询master库user
     * @return
     */
//    @ds(datasourceconstants.ds_key_master)
    public list<testuser> getmasteruser(){
        querywrapper<testuser> querywrapper = new querywrapper<>();
        return testusermapper.selectall(querywrapper.isnotnull("name"));
    }

    /**
     * 查询slave库user
     * @return
     */
//    @ds(datasourceconstants.ds_key_master)
    public list<testuser> getslaveuser(){
        return testusermapper.selectlist(null);
    }
}

效果

方法上使用注解

@service
@ds(datasourceconstants.ds_key_slave)
public class testuserservice {
    @autowired
    private testusermapper testusermapper;
    /**
     * 查询master库user
     * @return
     */
    @ds(datasourceconstants.ds_key_slave)
    public list<testuser> getmasteruser(){
        querywrapper<testuser> querywrapper = new querywrapper<>();
        return testusermapper.selectall(querywrapper.isnotnull("name"));
    }
    /**
     * 查询slave库user
     * @return
     */
    @ds(datasourceconstants.ds_key_master)
    public list<testuser> getslaveuser(){
        return testusermapper.selectlist(null);
    }
}

效果

总结

到此这篇关于利用springboot实现多数据源的两种方式的文章就介绍到这了,更多相关springboot实现多数据源内容请搜索以前的文章或继续浏览下面的相关文章希望大家以后多多支持！