SpringBoot+Mybatis-Plus实现mysql读写分离方案的示例代码
作者:Abean_Y 发布时间:2024-01-17 02:13:32
标签:SpringBoot,Mybatis-Plus,mysql,读写分离
1. 引入mybatis-plus相关包,pom.xml文件
2. 配置文件application.property增加多库配置
mysql 数据源配置
spring.datasource.primary.jdbc-url=jdbc:mysql://xx.xx.xx.xx:3306/portal?useUnicode=true&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=UTC&characterEncoding=utf8&serverTimezone=GMT%2B8
spring.datasource.primary.username=root
spring.datasource.primary.password=root
spring.datasource.primary.driver-class-name=com.mysql.cj.jdbc.Driver
#mysql slave 数据源配置
spring.datasource.slave.jdbc-url=jdbc:mysql://xx.xx.xx.xx:3306/portal?useUnicode=true&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=UTC&characterEncoding=utf8&serverTimezone=GMT%2B8
spring.datasource.slave.username=root
spring.datasource.slave.password=root
spring.datasource.slave.driver-class-name=com.mysql.cj.jdbc.Driver
3. 配置数据源及注解
数据源配置 MultiDataSourceConfig.Java
/**
* 配置多数据源
*/
@Profile("dev")//开发模式配置文件
@Configuration
@MapperScan(basePackages = "com.csc.portal.mapper")//扫描包
public class MultiDataSourceConfig {
/**
* 主数据源
* @return
*/
@Bean
@ConfigurationProperties(prefix = "spring.datasource.primary")
public DataSource masterDataSource() {
return DataSourceBuilder.create().build();
}
/**
* 从数据源
* @return
*/
@Bean
@ConfigurationProperties(prefix = "spring.datasource.slave")
public DataSource slaveDataSource() {
return DataSourceBuilder.create().build();
}
/**
* 路由数据源,前面两个数据源是为了创建此数据源
* @param masterDataSource 主数据源
* @param slaveDataSource 从数据源
* @return
*/
@Bean
public DataSource myRoutingDataSource(@Qualifier("masterDataSource") DataSource masterDataSource,
@Qualifier("slaveDataSource") DataSource slaveDataSource) {
Map<Object, Object> targetDataSources = new HashMap<>();
targetDataSources.put(DBTypeEnum.MASTER, masterDataSource);
targetDataSources.put(DBTypeEnum.SLAVE, slaveDataSource);
MyRoutingDataSource myRoutingDataSource = new MyRoutingDataSource();
myRoutingDataSource.setDefaultTargetDataSource(slaveDataSource);//设置默认数据源
myRoutingDataSource.setTargetDataSources(targetDataSources);//设置路由表,使用map的key,value方式得到对应数据源
return myRoutingDataSource;
}
数据库枚举类
public enum DBTypeEnum {
MASTER, SLAVE;
}
注解
@Target({ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
public @interface Master {
}
@Target({ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
public @interface Slave {
}
4. Mybatis-plus配置
@EnableTransactionManagement
@Configuration
@MapperScan(basePackages = "com.csc.portal.mapper")
public class MybatisPlusConfig {
/**
* 分页插件
*/
@Bean
public PaginationInterceptor paginationInterceptor() {
return new PaginationInterceptor();
}
@Resource(name = "myRoutingDataSource")
private DataSource myRoutingDataSource;
/**
* 使用MyBatis Plus的sqlSessionFactory代替,
* 此处注意mybatis与mybatisPlus的配置不同,不然扫描不到对数据操作的方法。会报未绑定错误
* @return sqlSessionFactory
* @throws Exception
*/
@Bean
public SqlSessionFactory sqlSessionFactory() throws Exception {
MybatisSqlSessionFactoryBean sqlSessionFactoryBean = new MybatisSqlSessionFactoryBean();
sqlSessionFactoryBean.setDataSource(myRoutingDataSource);
sqlSessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/*.xml"));
MybatisConfiguration mybatisConfiguration = new MybatisConfiguration();
sqlSessionFactoryBean.setConfiguration(mybatisConfiguration);
return sqlSessionFactoryBean.getObject();
}
/**
* 此处为使用mybatis时的sqlsessionFactory配置
* @return
* @throws Exception
*/
/*
@Bean
public SqlSessionFactory sqlSessionFactory() throws Exception {
SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();
sqlSessionFactoryBean.setDataSource(myRoutingDataSource);
sqlSessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/*.xml"));
return sqlSessionFactoryBean.getObject();
}
*/
/**
* 事务配置
* @return 事务管理器
*/
@Bean
public DataSourceTransactionManager transactionManager() {
DataSourceTransactionManager tx = new DataSourceTransactionManager();
tx.setDataSource(myRoutingDataSource);
return tx;
}
5. 增加数据源管理类
DBContextHolder.java
public class DBContextHolder {
/**
* 外部一个请求将会产生一个线程与之对应,每个线程的变量可用ThreadLocal进行存储
*/
private static final ThreadLocal<DBTypeEnum> contextHolder = new ThreadLocal<>();
public static void set(DBTypeEnum dbType) {
contextHolder.set(dbType);
}
public static DBTypeEnum get() {
return contextHolder.get();
}
public static void master() {
set(DBTypeEnum.MASTER);
System.out.println("切换到master");
}
public static void slave() {
set(DBTypeEnum.SLAVE);
System.out.println("切换到slave");
}
}
指定选择数据源
MyRoutingDataSource.java 方法determineCurrentLookupKey决定最终使用哪个数据源进行操作,若为空则使用默认数据源。
public class MyRoutingDataSource extends AbstractRoutingDataSource {
@Nullable
@Override
protected Object determineCurrentLookupKey() {
System.out.println("线程名:"+Thread.currentThread().getName()+":"+DBContextHolder.get());
return DBContextHolder.get();
/* if (DBContextHolder.get() != null) {
System.out.println("线程名:"+Thread.currentThread().getName()+":"+DBContextHolder.get());
return DBContextHolder.get();
} else {
System.out.println("未匹配到指定数据库,默认切换到Master");
return DBTypeEnum.MASTER;
}*/
//return DBContextHolder.get();
}
}
6. 增加aop切面
@Aspect
@Component
@Order(0)//配置注解优先级,优于事物注解@Transactional先进行数据源切换,
//不然在事物中进行数据源切换无效
public class DataSourceAop {
@Pointcut(/*"!@annotation(com.csc.portal.annotation.Master) " +
"&& (execution(* com.csc.portal.service..*.select*(..)) " +
"|| execution(* com.csc.portal.service..*.get*(..))"+*/
" @annotation(com.csc.portal.annotation.Slave)")
public void readPointcut() {
}
@Pointcut("@annotation(com.csc.portal.annotation.Master) " //+
/* "|| execution(* com.csc.portal.service..*.insert*(..)) " +
"|| execution(* com.csc.portal.service..*.add*(..)) " +
"|| execution(* com.csc.portal.service..*.update*(..)) " +
"|| execution(* com.csc.portal.service..*.edit*(..)) " +
"|| execution(* com.csc.portal.service..*.delete*(..)) " +
"|| execution(* com.csc.portal.service..*.remove*(..))"*/)
public void writePointcut() {
}
@Before("readPointcut()")
public void read() {
//获取拦截类
DBContextHolder.slave();
System.out.println(Thread.currentThread().getName()+DBContextHolder.get());
}
@Before("writePointcut()")
public void write() {
//获取拦截类
/* String className = pjp.getTarget().getClass().getName();
System.out.println("当前线程"+Thread.currentThread().getName()+" 拦截类为:" + className);
//获取拦截的方法名
MethodSignature msig = (MethodSignature) pjp.getSignature();
Method currentMethod = null;
try {
currentMethod = pjp.getTarget().getClass().getMethod(msig.getName(), msig.getParameterTypes());
} catch (NoSuchMethodException e) {
e.printStackTrace();
}
String methodName = currentMethod.getName();
System.out.println("拦截方法名为:" + methodName);*/
DBContextHolder.master();
System.out.println(Thread.currentThread().getName()+DBContextHolder.get());
}
}
6. 实际应用
在service层方法前增加注解@Master表示使用主库,进行增删改的操作使用主库。
在service层方法前增加注解@Slave表示使用从库,进行查的操作使用从库,默认使用从库,可不配置。
@ Transactional注解加到service层,增加了@Transactional注解后,启用事务后,一个事务内部的connection是复用的,所以就算AOP切了数据源字符串,但是数据源并不会被真正修改。所以@Transactional注解不要写在controller层,不然在service层也切换不了数据源。
@Transactional与@Master可同时使用,已经配置@Master注解的优先级较高,先切换数据源后执行事务。
来源:https://blog.csdn.net/AAAAABBBBBYYYYY/article/details/110875245
0
投稿
猜你喜欢
- 1.前言 &n
- Python 中有 while 和 for 两种循环机制,其中 while 循环
- 简单总结:1、与类和实例无绑定关系的function都属于函数(function);2、与类和实例有绑定关系的function都属于方法(m
- 概念Python中已经有了threading模块,为什么还需要线程池呢,线程池又是什么东西呢?以爬虫为例,需要控制同时爬取的线程数,例子中创
- 原文地址:30 Days of Mootools 1.2 Tutorials - Day 14 - Periodical and Intro
- 边缘检测图像边缘是指图像中表达物体的周围像素灰度发生阶跃变化的那些像素集合。图像中两个灰度不同的相邻区域的交界处,必然存在灰度的快速过渡或称
- 在开发过程中我们需要将我们的数据通过图标的形式展现出来,接下来我为大家介绍一个有趣的框架:Echarts。这是一个使用JavaScript实
- 本文实例讲述了PHP 对象继承原理与简单用法。分享给大家供大家参考,具体如下:对象继承继承已为大家所熟知的一个程序设计特性,PHP 的对象模
- 一、题目描述题目内容:题目示例:题目解析:1 <= nums.length <= 104-107 <= nums
- 本文实例讲述了python实现搜索本地文件信息写入文件的方法。分享给大家供大家参考,具体如下:主要功能:在指定的盘符,如D盘,搜索出与用户给
- 本文实例讲述了php使用curl获取https请求的方法。分享给大家供大家参考。具体分析如下:今日在做一个项目,需要curl获取第三方的AP
- 初学python,写一个小程序练习一下。主要功能就是增删改查的一些功能。主要用到的技术:字典的使用,pickle的使用,io文件操作。代码如
- 简单的Python代码:用户登录注册利用业余时间,写了一个用户进行登录注册的代码,非常简单。主要实现的功能是:1、可以进行用户登录,在用户进
- Numpy是高性能科学计算和数据分析的基础包,里面包含了许多对数组进行快速运算的标准数学函数,掌握这些方法,能摆脱数据处理时的循环。1.首先
- (应一些初学者的要求,虽然本人也绝对称不上专业,但是想让一个人快速地走出初学的迷茫,需要这种精炼的集合)首先,阐明一下我的观点:不论是什么编
- 一、前言二、爬取观影数据https://movie.douban.com/在『豆瓣』平台爬取用户观影数据。爬取用户列表网页分析为了获取用户,
- 前言:最近写爬虫会经常遇到一些验证码识别的问题,现如今的验证码已经是五花八门,刚开始的验证码就是简单的对生成的验证码图片进行一些干扰,但是随
- python3批量删除豆瓣分组下的好友的实现代码"""python3批量删除豆瓣分组下的好友2016年6月7日
- 本文实例为大家分享了python实现五子棋游戏的具体代码,供大家参考,具体内容如下一、运行截图:二、代码# 用数组定义一个棋盘,棋盘大小为
- 在Python中创建进程有两种方式,第一种是:from multiprocessing import Processimport timed