在SpringBoot中添加多数据源使用MyBatis-Plus实现读写分离。
上一篇文章中,我们搭建了《MySQL主从复制》。在本篇文章我们将使用MyBatis-Plus的多数据源功能,在接口对数据库进行写入操作时切换到主数据库进行写入数据,对数据进行读取的时候切换到从数据库进行读取,来实现数据库的读写分离,缓解数据库的读写压力。
项目配置
项目的创建这里就直接省略了,大家只看pom.xml
所用到的依赖。
maven依赖
<!-- mysql的依赖 -->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>8.0.13</version>
</dependency>
<!-- mybatis-plus的依赖 -->
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-boot-starter</artifactId>
<version>3.5.1</version>
</dependency>
<!-- mybatis-plus集成多数据源需要的依赖 -->
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>dynamic-datasource-spring-boot-starter</artifactId>
<version>3.5.0</version>
</dependency>
配置文件
编辑application.yml
文件添加多数据源信息:
spring:
datasource:
dynamic:
# 指定主数据源
primary: master
strict: false
datasource:
# 主数据库也是默认数据源 负责写入操作
# master是自定义的数据源名称
master:
# springboot 内置的连接池
type: com.zaxxer.hikari.HikariDataSource
# jdbc驱动
driverClassName: com.mysql.cj.jdbc.Driver
url: jdbc:mysql://192.168.5.200:3306/iot-test?serverTimezone=GMT%2B8&useUnicode=true&characterEncoding=utf-8&useSSL=false
username: root
password: AbCdEfG12345!
# 从数据库 负责读操作 slave_1是自定义的数据源名称
slave_1:
type: com.zaxxer.hikari.HikariDataSource
driverClassName: com.mysql.cj.jdbc.Driver
url: jdbc:mysql://192.168.5.201:3306/iot-test?serverTimezone=GMT%2B8&useUnicode=true&characterEncoding=utf-8&useSSL=false
username: root
password: AbCdEfG12345!
hikari:
# 最小空闲连接数
minimum-idle: 5
# 连接空闲超时时间
idle-timeout: 600000
# 最大连接池大小
maximum-pool-size: 10
# 自动提交事务
auto-commit: true
# 连接池名称
pool-name: MyHikariCP
# 连接的最大生命周期
max-lifetime: 1800000
# 连接超时时间
connection-timeout: 30000
# 连接测试查询语句
connection-test-query: SELECT 1
日志信息
当配置完数据库时,启动项目可以看到控制台会输出如下的内容:
master - Starting...
master - Start completed.
slave_1 - Starting...
slave_1 - Start completed.
dynamic-datasource - add a datasource named [master] success
dynamic-datasource - add a datasource named [slave_1] success
dynamic-datasource initial loaded [2] datasource,primary datasource named [master]
@DS注解解析
在MyBatis-Plus中,@DS
是一个用于数据源切换的注解。该注解可以作用在方法或类上。
作用在方法上
@DS("slave_1")
public Users getUserByUsername(String username) {
// 方法体
}
@DS注解接收一个String类型的参数"数据源名称"
,当调用该查询方法时,MyBatis-Plus将自动切换到数据源名称为slave_1
的数据库上进行查询操作。
作用在类上
@DS("slave_1")
@Service
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements UserService {
// 类的属性与方法
}
@DS注解用于类UserServiceImpl
上,并指定了要使用的数据源名称。这意味着在执行该类中的所有方法时,都将使用指定的数据源。
@DS注解采用就近原则,如果方法和类上都被@DS所注解,那么方法的优先级大于类,只会走被方法所指定的数据源。
不使用@DS注解修饰
如果我们的类或者方法上面并没有使用@DS注解,则对数据库的所有操作都将走指定的默认数据源master
。
原文始发于微信公众号(青檬小栈):SpringBoot集成MySQL多数据源做读写分离
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。
文章由极客之音整理,本文链接:https://www.bmabk.com/index.php/post/233463.html