经过测试,MySQL的ReplicationConnection在和Druid连接池使用时,会经常出现连接断开不可用的问题,推测是主从配置不一样,导致超出生存时间的问题。
鉴于实际情况中,主从的配置有分开配置的需求,弃用Replication方案,使用多数据源解决
applicationContext.xml 加入多个数据源:
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
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
|
<?xml version= "1.0" encoding= "UTF-8" ?>
<beans xmlns= "http://www.springframework.org/schema/beans"
xmlns:xsi= "http://www.w3.org/2001/XMLSchema-instance"
xmlns:context= "http://www.springframework.org/schema/context"
xmlns:tx= "http://www.springframework.org/schema/tx"
xsi:schemaLocation="
http: //www.springframework.org/schema/beans
http: //www.springframework.org/schema/beans/spring-beans-3.0.xsd
http: //www.springframework.org/schema/context
http: //www.springframework.org/schema/context/spring-context-3.0.xsd
http: //www.springframework.org/schema/tx
http: //www.springframework.org/schema/tx/spring-tx-2.0.xsd
">
<bean id= "masterDataSource" class = "com.alibaba.druid.pool.DruidDataSource" init-method= "init" destroy-method= "close" >
<!-- 基本属性 url、user、password -->
<property name= "driverClassName" value= "${jdbc.driverclass}" />
<property name= "url" value= "${jdbc.url}" />
<!--
<property name= "url" value= "${jdbc.url}?characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull&allowMultiQueries=true" />
<property name= "url" value= "${jdbc.url}?useUnicode=true&zeroDateTimeBehavior=convertToNull&autoReconnect=true" />
-->
<property name= "username" value= "${jdbc.username}" />
<property name= "password" value= "${jdbc.password}" />
<!-- 配置初始化大小、最小、最大 -->
<property name= "initialSize" value= "5" />
<property name= "minIdle" value= "15" />
<property name= "maxActive" value= "100" />
<!-- 配置获取连接等待超时的时间 -->
<property name= "maxWait" value= "60000" />
<!-- 配置间隔多久才进行一次检测,检测需要关闭的空闲连接,单位是毫秒 -->
<property name= "timeBetweenEvictionRunsMillis" value= "60000" />
<!-- 配置一个连接在池中最小生存的时间,单位是毫秒 -->
<property name= "minEvictableIdleTimeMillis" value= "300000" />
<property name= "validationQuery" value= "SELECT 'x'" />
<property name= "testWhileIdle" value= "true" />
<property name= "testOnBorrow" value= "true" />
<property name= "testOnReturn" value= "false" />
<!-- 打开PSCache,并且指定每个连接上PSCache的大小 -->
<property name= "poolPreparedStatements" value= "true" />
<property name= "maxPoolPreparedStatementPerConnectionSize" value= "20" />
<!-- 配置监控统计拦截的filters -->
<property name= "filters" value= "stat,log4j" />
</bean>
<bean id= "slaveDataSource" class = "com.alibaba.druid.pool.DruidDataSource" init-method= "init" destroy-method= "close" >
<!-- 基本属性 url、user、password -->
<property name= "driverClassName" value= "${jdbc.driverclass}" />
<property name= "url" value= "${read.jdbc.url}" />
<!--
<property name= "url" value= "${jdbc.url}?characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull&allowMultiQueries=true" />
<property name= "url" value= "${jdbc.url}?useUnicode=true&zeroDateTimeBehavior=convertToNull&autoReconnect=true" />
-->
<property name= "username" value= "${read.jdbc.username}" />
<property name= "password" value= "${read.jdbc.password}" />
<!-- 配置初始化大小、最小、最大 -->
<property name= "initialSize" value= "5" />
<property name= "minIdle" value= "15" />
<property name= "maxActive" value= "100" />
<!-- 配置获取连接等待超时的时间 -->
<property name= "maxWait" value= "60000" />
<!-- 配置间隔多久才进行一次检测,检测需要关闭的空闲连接,单位是毫秒 -->
<property name= "timeBetweenEvictionRunsMillis" value= "60000" />
<!-- 配置一个连接在池中最小生存的时间,单位是毫秒 -->
<property name= "minEvictableIdleTimeMillis" value= "300000" />
<property name= "validationQuery" value= "SELECT 'x'" />
<property name= "testWhileIdle" value= "true" />
<property name= "testOnBorrow" value= "true" />
<property name= "testOnReturn" value= "false" />
<!-- 打开PSCache,并且指定每个连接上PSCache的大小 -->
<property name= "poolPreparedStatements" value= "true" />
<property name= "maxPoolPreparedStatementPerConnectionSize" value= "20" />
<!-- 配置监控统计拦截的filters -->
<property name= "filters" value= "stat,log4j" />
</bean>
<bean id= "dataSource" class = "com.qding.order.dao.util.DynamicDataSource" >
<property name= "targetDataSources" >
<map key-type= "java.lang.String" >
<entry key= "master" value-ref= "masterDataSource" />
<entry key= "slave" value-ref= "slaveDataSource" />
</map>
</property>
<property name= "defaultTargetDataSource" ref= "masterDataSource" />
</bean>
</beans> |
加入数据源动态切换 DynamicDataSource:
1
2
3
4
5
6
7
8
|
public class DynamicDataSource extends AbstractRoutingDataSource {
@Override
protected Object determineCurrentLookupKey() {
return DynamicDataSourceHolder.getDataSouce();
}
} |
DynamicDataSourceHolder:
1
2
3
4
5
6
7
8
9
10
11
|
public class DynamicDataSourceHolder {
public static final ThreadLocal<String> holder = new ThreadLocal<String>();
public static void putDataSource(String name) {
holder.set(name);
}
public static String getDataSouce() {
return holder.get();
}
} |
改变代理实现 ReadOnlyTransFactoryBean:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
|
public Object intercept(Object obj, Method method, Object[] args, MethodProxy proxy) throws Throwable {
T service = applicationContext.getBean(delegateBeanName, serviceInterface);
try {
DynamicDataSourceHolder.putDataSource( "slave" );
DataSourceTransactionManager txManager = applicationContext.getBean(DataSourceTransactionManager. class );
DefaultTransactionDefinition definition = new DefaultTransactionDefinition(DefaultTransactionDefinition.PROPAGATION_REQUIRED);
definition.setReadOnly( true );
logger.info( "Start ReadOnly Transactional!" );
TransactionStatus transaction = txManager.getTransaction(definition);
Object result = method.invoke(service, args);
if (!transaction.isCompleted()) {
txManager.commit(transaction);
}
logger.info( "End ReadOnly Transactional!" );
return result;
} finally {
DynamicDataSourceHolder.putDataSource( "master" );
}
} |
使用方法不变
相关推荐
第一种是依靠中间件MyCat,也就是说应用程序连接到中间件,中间件帮我们做SQL分离,去选择指定的数据源;第二种是应用程序自己去做分离。这里我用程序自己来做,主要是利用Spring提供的路由数据源,以及Aop
具有负载均衡、高可用性、SQL 过滤、读写分离、可路由相关的到目标数据库、可并发请求多台数据库合并结果。 通过Amoeba能够完成多数据源的高可用、负载均衡、数据切片的功能,目前Amoeba已在很多企业的生产线上面...
应用层读写分离的改进背景数据库...手动指定数据源用不用DB中间件需要考虑实际情况,如数据体量和有没有人维护等等,这里讲的是应用层读写分离。当前方案通过自定义注释解@DataSourceRoute ,手动声明当前方法操作的数
NULL 博文链接:https://zzc1684.iteye.com/blog/2339523
解决读写分离的方案很多,常用的有SQL解析、动态设置数据源。SQL解析主要是通过分析sql语句是insert/select/update/delete中的哪一种,从而对应选择主从。而动态设置数据源,则是通过拦截方法名称的方式来决定主从的...
Java 快速开发平台,不仅仅是一个后台开发框架,它是一个企业级快速开发解决方案,采用经典开发模式,提供 Spring Boot 在线代码生成功能...支持集群、多租户、多数据源、读写分离、分库分表、Cloud 微服务,无用户限制
Java 快速开发平台,不仅仅是一个后台开发框架,它是一个企业级快速开发解决方案,采用经典开发模式,提供 Spring Boot 在线代码生成功能...支持集群、多租户、多数据源、读写分离、分库分表、Cloud 微服务,无用户限制
读库的高可用(一期未实现).x-jdbc的想法:当应用想使用读写分离功能时,可以很方便的接入,因为x-jdbc就是一个jar包,并扩展了Spring的自定义标签方便应用通过xjdbc:cluter,xjdbc:rwds来定义数据源,并将x-jdbc的数据源...
自1998年首次发布以来,MySQL以其卓越的性能、可靠性和可扩展性,成为全球范围内Web应用程序、企业级解决方案以及其他各种数据处理场景的首选数据库平台之一。 以下是对MySQL数据库的详细介绍: 核心特性与优势 ...
JeeSite 快速开发平台,不仅仅是一个后台开发框架,它是一个企业级快速开发解决方案,后端基于经典组合 Spring Boot、Shiro、MyBatis,前端采用 Beetl、...支持多数据源;支持读写分离、分库分表;支持微服务应用。
参考Eric Evans提出的DDD(Domain-Driven Design 领域驱动设计),结合springboot,mybatis+,动态数据源(读写分离)等搭建的DDD架构ddd_springboot_demo-master.zip 大学期间做的各样项目,有JavaPythonJavaScriptVert....
支持多数据源;支持读写分离、分库分表;支持微服务应用。 JeeSite4 的升级,作者结合了多年总结和经验,以及各方面的应用案例,对架构完成了一次全部重构,也纳入很多新的思想。不管是从开发者模式、底层架构、...
支持多数据源;支持读写分离、分库分表;支持微服务应用。 JeeSite 快速开发平台的主要目的是能够让初级的研发人员快速的开发出复杂的业务功能(经典架构会的人多),让开发者注重专注业务,其余有平台来封装技术...
头都大了 ©_Ob)框架,主要解决了分库分表对应用的透明化以及异构数据库之间的数据复制,它是一个基于集中式配置的 jdbc datasource实现,具有主备,读写分离,动态数据库配置等功能。 TDDL所处的位置(tddl通用...
开始使用数据库首先需要配置数据库连接组件,通过添加 db 组件到应用配置实现(”基础的” Web 应用是 config/web.PHP),DSN( Data Source Name )是数据源名称,用于指定数据库信息.如下所示: return [ // ... ...
具有负载均衡、高可用性、Query过滤、读写分离、可路由相关的query到目标数据库、可并发请求多台数据库合并结果。 在Amoeba上面你能够完成多数据源的高可用、负载均衡、数据切片的功能。目前在很多企业的生产线上面...
具有负载均衡、高可用性、Query过滤、读写分离、可路由相关的query到目标数据库、可并发请求多台数据库合并结果。 在Amoeba上面你能够完成多数据源的高可用、负载均衡、数据切片的功能。目前在很多企业的生产线上面...
ShardingJDBC通过数据分片和读写分离,使Java应用能透明地访问分库分表的多个数据源。它在JDBC层提供服务,无需额外部署,兼容各种ORM框架。与ShardingProxy不同,ShardingJDBC在客户端执行分库分表逻辑,提供...
拆分多个数据库实现读写分离 使用Redis实现分布式锁技术 系统在生活中的应用十分广泛,无论是个人还是企业,在日常生活中都需要系统,不仅可以提高工作效率和质量,也可以提高数据准确性,以下是系统的好处: 1. ...
2个目标文件 摘要:Java源码,文件操作,TCP,服务器 Tcp服务端与客户端的JAVA实例源代码,一个简单的Java TCP服务器端程序,别外还有一个客户端的程序,两者互相配合可以开发出超多的网络程序,这是最基础的部分。...