- ubuntu12.04环境下使用kvm ioctl接口实现最简单的虚拟机
- Ubuntu 通过无线网络安装Ubuntu Server启动系统后连接无线网络的方法
- 在Ubuntu上搭建网桥的方法
- ubuntu 虚拟机上网方式及相关配置详解
CFSDN坚持开源创造价值,我们致力于搭建一个资源共享平台,让每一个IT人在这里找到属于你的精彩世界.
这篇CFSDN的博客文章springboot结合mysql主从来实现读写分离的方法示例由作者收集整理,如果你对这篇文章有兴趣,记得点赞哟.
基于springboot框架,application.yml配置多个数据源,使用AOP以及AbstractRootingDataSource、ThreadLocal来实现多数据源切换,以实现读写分离。mysql的主从数据库需要进行设置数据之间的同步.
application.properties中的配置 。
1
2
3
4
5
6
7
8
9
10
|
spring.datasource.druid.master.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.druid.master.url=jdbc:mysql://127.0.0.1:3306/node2?useUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true&autoReconnect=true&useSSL=false
spring.datasource.druid.master.username=root
spring.datasource.druid.master.password=123456
spring.datasource.druid.slave.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.druid.slave.url=jdbc:mysql://127.0.0.1:3306/node1?useUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true&autoReconnect=true&useSSL=false
spring.datasource.druid.slave.username=root
spring.datasource.druid.slave.password=123456
|
写一个DataSourceConfig.java来注入两个bean 。
1
2
3
4
5
6
7
8
9
10
11
12
13
|
@Bean
@ConfigurationProperties
(
"spring.datasource.druid.master"
)
public
DataSource masterDataSource() {
logger.info(
"select master data source"
);
return
DruidDataSourceBuilder.create().build();
}
@Bean
@ConfigurationProperties
(
"spring.datasource.druid.slave"
)
public
DataSource slaveDataSource() {
logger.info(
"select slave data source"
);
return
DruidDataSourceBuilder.create().build();
}
|
写一个enum来标识有哪些数据源 。
1
2
3
|
public
enum
DBTypeEnum {
MASTER, SLAVE;
}
|
然后写一个ThreadLocal本地线程的管理类,用于设置当前线程是那一个数据源 。
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
|
private
static
final
ThreadLocal<DBTypeEnum> contextHolder =
new
ThreadLocal<>();
private
static
final
ThreadLocal<DBTypeEnum> contextHolder2 = ThreadLocal.withInitial(() -> DBTypeEnum.MASTER);
public
static
void
set(DBTypeEnum dbType) {
contextHolder.set(dbType);
}
public
static
DBTypeEnum get() {
return
contextHolder.get();
}
public
static
void
master() {
set(DBTypeEnum.MASTER);
logger.info(
"切换到master数据源"
);
}
public
static
void
slave() {
set(DBTypeEnum.SLAVE);
logger.info(
"切换到slave数据源"
);
}
public
static
void
cleanAll() {
contextHolder.remove();
}
|
然后写一个DynamicDataSource继承AbstractRootingDataSource,重写它的determineCurrentLookupKey方法.
1
2
3
4
5
6
7
8
9
|
public
class
DynamicDataSource
extends
AbstractRoutingDataSource {
private
Logger logger = LogManager.getLogger(DynamicDataSource.
class
);
@Override
protected
Object determineCurrentLookupKey() {
logger.info(
"此时数据源为{}"
, DBContextHolder.get());
return
DBContextHolder.get();
}
}
|
最后写一个AOP来实现数据源切换 。
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
|
@Aspect
@Order
(
1
)
@Component
public
class
DataSourceAop {
private
Logger logger = LogManager.getLogger(DataSourceAop.
class
);
@Pointcut
(
"(execution(* com.springboot.demo.service..*.select*(..)) "
+
"|| execution(* com.springboot.demo.service..*.find*(..)) "
+
"|| execution(* com.springboot.demo.service..*.get*(..)))"
)
public
void
readPointcut() {
logger.info(
"read only operate ,into slave db"
);
}
@Pointcut
(
"execution(* com.springboot.demo.service..*.insert*(..)) "
+
"|| execution(* com.springboot.demo.service..*.update*(..)) "
+
"|| execution(* com.springboot.demo.service..*.delete*(..)) "
)
public
void
writePointcut() {
logger.info(
"read or write operate ,into master db"
);
}
@Before
(
"readPointcut()"
)
public
void
read() {
logger.info(
"read operate"
);
DBContextHolder.slave();
}
@Before
(
"writePointcut()"
)
public
void
write() {
logger.info(
"write operate"
);
DBContextHolder.master();
}
@After
(
"writePointcut(),readPointcut()"
)
public
void
clean() {
logger.info(
"dataSource cleanAll"
);
DBContextHolder.cleanAll();
}
}
|
注意:这里只是使用了偷懒的方法,对于service里面的select、get、find前缀的方法都使用从库,对于insert、update和delete方法都使用主库.
可以使用注解如下来进行优化
1
2
3
4
5
6
7
8
9
10
|
@Retention
(RetentionPolicy.RUNTIME)
@Target
(ElementType.METHOD)
public
@interface
DataSource {
@AliasFor
(
"dataSource"
)
DBTypeEnum value()
default
DBTypeEnum.MASTER;
DBTypeEnum dataSource()
default
DBTypeEnum.MASTER;
}
|
使用此注解来放入到service方法上, 。
1
|
@DataSource
(DBTypeEnum.SLAVE)
|
然后AOP方法修改为:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
|
private
static
final
String POINT =
"execution (* com.springboot.demo.service.*.*(..))"
;
@Around
(POINT)
public
Object dataSourceAround(ProceedingJoinPoint joinPoint)
throws
Throwable {
Object[] args = joinPoint.getArgs();
Object obj;
Object target = joinPoint.getTarget();
String methodName = joinPoint.getSignature().getName();
Class clazz = target.getClass();
Class<?>[] parameterTypes = ((MethodSignature) joinPoint.getSignature()).getMethod().getParameterTypes();
boolean
isDynamicDataSourceMethod =
false
;
try
{
Method method = clazz.getMethod(methodName, parameterTypes);
DataSources currentDataSource =
null
;
if
(method !=
null
&& method.isAnnotationPresent(DataSource.
class
)) {
isDynamicDataSourceMethod =
true
;
currentDataSource = method.getAnnotation(DataSource.
class
).value();
DataSourceTypeManager.set(currentDataSource);
log.info(
"DataSourceInterceptor Switch DataSource To {}"
,currentDataSource);
}
obj = joinPoint.proceed(args);
if
(isDynamicDataSourceMethod) {
log.info(
"DataSourceInterceptor DataSource {} proceed"
,currentDataSource);
}
}
finally
{
if
(isDynamicDataSourceMethod) {
DataSourceTypeManager.reset();
log.info(
"DataSourceInterceptor Reset DataSource To {}"
,DataSourceTypeManager.get());
}
}
return
obj;
}
|
到此这篇关于springboot结合mysql主从来实现读写分离的方法示例的文章就介绍到这了,更多相关springboot 读写分离内容请搜索我以前的文章或继续浏览下面的相关文章希望大家以后多多支持我! 。
原文链接:https://blog.csdn.net/yancun93/article/details/103958645 。
最后此篇关于springboot结合mysql主从来实现读写分离的方法示例的文章就讲到这里了,如果你想了解更多关于springboot结合mysql主从来实现读写分离的方法示例的内容请搜索CFSDN的文章或继续浏览相关文章,希望大家以后支持我的博客! 。
SpringBoot-Admin 服务监控 简单介绍 Spring Boot Actuator 是 Spring Boot 自带的一个功能模块, 提供了一组已经开箱即用的生产环境下常用
我想查找通过关键字匹配字段 nameEnglish 或 nameChinese 的模型列表。我花了一个多小时谷歌搜索但我做不到。请帮忙。 Springboot Mongo 入门示例 https://s
(请注意:在调查 this issue 时,我更好地发现了我在此处介绍的问题根源) 我对 Hibernate 和 SpringBoot 非常陌生。我的项目涉及一个搜索引擎,其中索引(javafx 客户
我最近有一个 Web 应用程序从 springboot 升级到 springboot 2。当我将其部署到 Tomcat 8 时,它似乎启动了,但没有完全启动。 在 localhost.2019-09-
我是 Spring boot 的新手...我在运行 Controller 时遇到问题, Description: Field todoService in com.springboot.todoCon
我有一个SpringBoot应用程序,它使用以下配置与PostgreSQL通信,通过AWS Beanstrik部署:。在我将AWS Aurora证书更新为rds-ca-ecc384-g1之前,一切都很
一、介绍 在实际的软件系统开发过程中,由于业务的需求,在代码层面实现数据的脱敏还是远远不够的,往往还需要在数据库层面针对某些关键性的敏感信息,例如:身份证号、银行卡号、手机号、工资等信息进行加密存储
Selenium Selenium是一个用于Web应用程序自动化测试的开源工具套件。它主要用于以下目的: 浏览器自动化:Selenium能够模拟真实用户在不同浏览器(如Chrome、Fire
一、简介 在实际的项目开发过程中,经常需要用到邮件通知功能。例如,通过邮箱注册,邮箱找回密码,邮箱推送报表等等,实际的应用场景非常的多。 早期的时候,为了能实现邮件的自动发送功能,通常会使用 Ja
SpringBoot:基于redis自定义注解实现后端接口防重复提交校验 一、添加依赖 org.springframework.boot spring
SpringBoot:使用Jackson完成全局序列化配置 一、测试准备 com.fasterxml.jackson.core jackson-cor
springboot:整合rocketmq 一、简易消息操作 生产者整合mq 导入依赖 org.springframework.boot
springboot:常用注解 一、spring常用注解 包扫描+组件标注注解 @Component:泛指各种组件 @Controller、@Service、@Repository都可以称为@Comp
我们经常需要在两个系统之间进行一些数据的交互,这时候我们就需要开发数据交互接口。 一般来说,遇到比较多的接口有HTTP接口、WebService接口、FTP文件传输。今天我要来学习一下在SpringB
背景 近期项目上线,甲方要求通过安全检测才能进行验收,故针对扫描结果对系统进行了一系列的安全加固,本文对一些常见的安全问题及防护策略进行介绍,提供对应的解决方案 跨站脚本攻击 XSS常发生于论坛评论等
1.排除 Spring-boot-starter 默认的日志配置 将原本的 spring-boot-starter 改为 org.springframework.boot
springboot:解决跨域问题 一、跨域简介 URL的组成: // 协议 + 域名(子域名 + 主域名) + 端口号 + 资源地址 http://www.baidu.com:8080/ 只要协
一、自定义Starter 的思路: 创建一个Maven工程,创建三个模块 一个模块为demo-app,一个模块为demo-module,一个模块为demo-module-springboot-star
1.pom.xml 4.0.0 org.springframework.boot spring-boot-starter-parent
1.pom.xml 4.0.0 org.springframework.boot spring-boot-starter-parent
我是一名优秀的程序员,十分优秀!