springboot之配置多个数据源

多数据源应用场景

使用mabatis框架+druid数据源
当业务量达到一定量的时候，DataBase需要合理配置数据库资源，即把高频访问的数据放在主库上，低频访问的数据放在从库上，从而达到服务器CPU的合理应用。

image.png

多数据源应用

准备两个数据库，taotao和pms

image.png

新建springboot工程

选择web与mybatis

pom文件

<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.enowsh</groupId>
    <artifactId>boot-mybatis</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <packaging>jar</packaging>

    <name>boot-mybatis</name>
    <description>Demo project for Spring Boot</description>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.2.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
            <exclusions>
                <exclusion>
                    <groupId>ch.qos.logback</groupId>
                    <artifactId>logback-classic</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>1.3.2</version>
        </dependency>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <scope>runtime</scope>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-tomcat</artifactId>
            <scope>provided</scope>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid</artifactId>
            <version>1.0.9</version>
        </dependency>
        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-databind</artifactId>
            <version>2.9.5</version>
        </dependency>
        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-log4j12</artifactId>
            <version>1.7.25</version>
        </dependency>
        <dependency>
            <groupId>com.github.pagehelper</groupId>
            <artifactId>pagehelper</artifactId>
            <version>3.4.2</version>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>


</project>

工程结构

image.png

application.properties配置文件

#多个数据源配置
#master数据源配置
master.datasource.url=jdbc:mysql://localhost:3306/pms?characterEncoding=utf-8
master.datasource.username=root
master.datasource.password=wyx2020
master.datasource.driverClassName=com.mysql.jdbc.Driver 

#cluster数据源配置
cluster.datasource.url=jdbc:mysql://localhost:3306/taotao?characterEncoding=utf-8
cluster.datasource.username=root
cluster.datasource.password=wyx2020
cluster.datasource.driverClassName=com.mysql.jdbc.Driver

主从数据源的配置-使用java代码

主数据源配置

package com.enowsh.boot_mybatis.config.dataSource;

import com.alibaba.druid.pool.DruidDataSource;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;

import javax.sql.DataSource;
import java.io.IOException;

/**
 * @author:wong
 */
@Configuration
//扫描mapper接口包
@MapperScan(basePackages = "com.enowsh.boot_mybatis.mapper.master",sqlSessionFactoryRef = "masterSqlSessionFactory")
public class MasterDataSourceConfig {

    @Value("${master.datasource.url}")
    private String masterDataSourceUrl;

    @Value("${master.datasource.username}")
    private String masterDatasourceUsername;

    @Value("${master.datasource.password}")
    private String masterDatasourcePassword;

    @Value("${master.datasource.driverClassName}")
    private String masterDatasourceDriverClassName;

    //定义dataSource的bean
    @Bean(name = "masterDataSource")
    @Primary //primary注解标志如果有多类同类bean候选，则优先考虑该bean，即主数据源
    public DataSource masterDataSource(){
        DruidDataSource dataSource = new DruidDataSource();
        dataSource.setUsername(masterDatasourceUsername);
        dataSource.setPassword(masterDatasourcePassword);
        dataSource.setDriverClassName(masterDatasourceDriverClassName);
        dataSource.setUrl(masterDataSourceUrl);
        return dataSource;
    }

    //定义sqlSessionFactory的bean
    @Bean(name = "masterSqlSessionFactory")
    @Primary
    //使用@Qualifier注解同样是注入bean，但该注入方式是查找bean的name
    //@Autowired注入是根据bean的类型来查找bean注入
    public SqlSessionFactory masterSqlSessionFactory(@Qualifier("masterDataSource") DataSource dataSource) throws Exception {
        SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();
        sqlSessionFactoryBean.setDataSource(dataSource);
        //扫描mapper.xml文件
        sqlSessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/master/*.xml"));
        return sqlSessionFactoryBean.getObject();
    }
}

其中类头上需要扫描mapper的接口包，将接口bean注入到容器
@Primary注解：如果有多个同类型的bean配置，则优先配置该bean，即主数据源的bean
@Qualifier("beanName")注解：与@Autowired不同的是，Qualifer是根据bean的name来查找bean，Autowired是根据类型查找，由于有多个数据源的bean，所以若使用Autowired则会查找到多个同类型的bean，不能识别，这时，需要使用Qualifer根据bean的名称注入
sqlSessionFactoryBean设置mapper的Location是指设置mapper.xml文件的location

从数据源参考主数据源

package com.enowsh.boot_mybatis.config.dataSource;

import com.alibaba.druid.pool.DruidDataSource;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;

import javax.sql.DataSource;
import java.io.IOException;

/**
 * @author:wong
 */
@Configuration
//扫描mapper接口包
@MapperScan(basePackages = "com.enowsh.boot_mybatis.mapper.cluster",sqlSessionFactoryRef = "clusterSqlSessionFactory")
public class ClusterDataSourceConfig {

    @Value("${cluster.datasource.url}")
    private String clusterDataSourceUrl;

    @Value("${cluster.datasource.username}")
    private String clusterDatasourceUsername;

    @Value("${cluster.datasource.password}")
    private String clusterDatasourcePassword;

    @Value("${cluster.datasource.driverClassName}")
    private String clusterDatasourceDriverClassName;

    //定义dataSource的bean
    @Bean(name = "clusterDataSource")
    public DataSource clusterDataSource(){
        DruidDataSource dataSource = new DruidDataSource();
        dataSource.setUsername(clusterDatasourceUsername);
        dataSource.setPassword(clusterDatasourcePassword);
        dataSource.setDriverClassName(clusterDatasourceDriverClassName);
        dataSource.setUrl(clusterDataSourceUrl);
        return dataSource;
    }

    //定义sqlSessionFactory的bean
    @Bean(name = "clusterSqlSessionFactory")
    //使用@Qualifier注解同样是注入bean，但该注入方式是查找bean的name
    //@Autowired注入是根据bean的类型来查找bean注入
    public SqlSessionFactory clusterSqlSessionFactory(@Qualifier("clusterDataSource") DataSource dataSource) throws Exception {
        SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();
        sqlSessionFactoryBean.setDataSource(dataSource);
        //扫描mapper.xml文件
        sqlSessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/cluster/*.xml"));
        return sqlSessionFactoryBean.getObject();
    }
}

编写service程序测试

package com.enowsh.boot_mybatis.service.impl;

import com.enowsh.boot_mybatis.mapper.cluster.TbUserMapper;
import com.enowsh.boot_mybatis.mapper.master.PmsUserMapper;
import com.enowsh.boot_mybatis.pojo.PmsResult;
import com.enowsh.boot_mybatis.pojo.PmsUser;
import com.enowsh.boot_mybatis.pojo.TbUser;
import com.enowsh.boot_mybatis.service.MutiDataSourceService;
import com.sun.org.apache.bcel.internal.generic.IF_ACMPEQ;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.ArrayList;
import java.util.List;

/**
 * @author:wong
 */
@Service
@Transactional
public class MutiDataSourceServiceImpl implements MutiDataSourceService {
    @Autowired
    private TbUserMapper tbUserMapper;

    @Autowired
    private PmsUserMapper pmsUserMapper;

    @Override
    public PmsResult findDifferentUser(long pmsId, long taotaoId) {
        PmsUser pmsUser = pmsUserMapper.selectByPrimaryKey(pmsId);
        TbUser tbUser = tbUserMapper.selectByPrimaryKey(taotaoId);
        if (pmsUser==null||tbUser==null)
            return PmsResult.build(400,"用户查询失败");
        List list=new ArrayList();
        list.add(pmsUser);
        list.add(tbUser);
        return PmsResult.ok(list);
    }
}

controller程序

package com.enowsh.boot_mybatis.controller;

import com.enowsh.boot_mybatis.pojo.PmsResult;
import com.enowsh.boot_mybatis.service.MutiDataSourceService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

import javax.annotation.security.PermitAll;

/**
 * @author:wong
 */
@Controller
public class MutiDataSourceController {
    @Autowired
    private MutiDataSourceService mutiDataSourceService;

    @RequestMapping("/muti/{taotaoId}/{pmsId}")
    @ResponseBody
    public PmsResult findUser(@PathVariable long taotaoId, @PathVariable long pmsId){
        PmsResult pmsResult = mutiDataSourceService.findDifferentUser(pmsId, taotaoId);
        return pmsResult;
    }
}

测试结果

image.png

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 212,686评论 6赞 492
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 90,668评论 3赞 385
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 158,160评论 0赞 348
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 56,736评论 1赞 284
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 65,847评论 6赞 386
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 50,043评论 1赞 291
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 39,129评论 3赞 410
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 37,872评论 0赞 268
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 44,318评论 1赞 303
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 36,645评论 2赞 327
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 38,777评论 1赞 341
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 34,470评论 4赞 333
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 40,126评论 3赞 317
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 30,861评论 0赞 21
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 32,095评论 1赞 267
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 46,589评论 2赞 362
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 43,687评论 2赞 351

springboot之配置多个数据源

多数据源应用场景

多数据源应用

准备两个数据库，taotao和pms

新建springboot工程

pom文件

工程结构

application.properties配置文件

主从数据源的配置-使用java代码

主数据源配置

从数据源参考主数据源

编写service程序测试

controller程序

测试结果

推荐阅读更多精彩内容