spring MVC、mybatis配置读写分离

布满荆棘的人生 2021-12-15 05:15 292阅读 0赞

第一種方法：  
當後端MYSQL服務器群是master-master雙向同步機制時，前端應用使用JDBC連接數據庫可以使用loadbalance方式，如下所示：  
**jdbc:mysql:**loadbalance://dbnode\_1:port,dbnode\_2:port,dbnode\_3:port,dbnode\_n:port/dbname?user=xxxx;password=xxxxxxx;loadBalanceBlacklistTimeout=3000;&characterEncoding=utf-8  
loadbalance方式有兩種負載均衡算法，一種是隨機式的輪詢算法，另一種是最短響應時間算法，具體會使用哪種算法、怎　人為指定使用哪種算法目前還不太清楚。。官方網站上也沒看到很明確的說明。

第二種方法：  
當後端MYSQL服務器群是master-slave單向一主N 從的同步複製機制時，再使用loadbalance方式就會有問題了，因為如果有insert、update等寫操作改變了從機的數據就麻煩了，從機不會 將變化複製到主機，因此這種情況下需要實現“主讀寫、從只讀”的模式，為了達到這個目的可以使用replication方式，如下所示：  
**jdbc:mysql:**replication://dbnode\_1:port,dbnode\_2:port,dbnode\_3:port,dbnode\_n:port/dbname?user=xxxx;password=xxxxxxxx;&characterEncoding=utf-8  
replication方式可以很安全的實現寫操作只發送到主機執行，而從機只會接收到讀操作。

.环境：

3台数据库机器，一个master，二台slave，分别为slave1，slave2

2.要实现的目标：

①使数据写入到master

②读数据时，从slave1和slave2中读取

以此来实现数据库的读写分离

3.原理：

使用mysql驱动自带的replicationDriver来实现，replicationDriver简单来说就是存在两个Connection，一个masterConnection，一个slaveConnection；

当setReadonly(true)就把currentConnection=slaveConnection，反之设置为masterConnection

4.实现步骤：

①jdbc.properties

**\[java\]** [view plain][] [copy][view plain] [![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  \#\# 使用ReplicationDriver而不是driver
2.  jdbc.driverClassName=com.mysql.jdbc.ReplicationDriver
3.  \#\# 使用的是jdbc:mysql:replication:// 
4.  jdbc.url=jdbc:mysql:replication://master:3306,slave1:3306,slave2:3306/test2?characterEncoding=utf8 
5.  jdbc.username=root
6.  jdbc.password=123456

②使用spring的事物，把读操作设置为readonly=true

jdbc.connection.driver=com.mysql.jdbc.ReplicationDriver

jdbc.connection.url=jdbc:mysql:replication://192.168.202.190,192.168.202.190/job?useUnicode=true&characterEncoding=utf-8

**\[java\]** [view plain][] [copy][view plain] [![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  
2.  <bean class="org.springframework.jdbc.datasource.DriverManagerDataSource" 
3.  id="dataSource"> 
4.  <property name="driverClassName" value="$\{jdbc.driverClassName\}"/> 
5.  <property name="username" value="$\{jdbc.username\}"/> 
6.  <property name="password" value="$\{jdbc.password\}"/> 
7.  <property name="url" value="$\{jdbc.url\}"></property> 
8.  </bean>
9.  
10. 
11. <bean id="transactionManager" 
12. class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> 
13. <property name="dataSource" ref="dataSource" /> 
14. </bean>
15. 
16. 
17. <tx:advice id="txAdvice" transaction-manager="transactionManager"> 
18. 
19. <tx:attributes>
20. 
21. <tx:method name="\*" propagation="REQUIRED"/> 
22. 
23. <tx:method name="get\*" read-only="true"/> 
24. </tx:attributes>
25. </tx:advice>
26. 
27. 
28. <aop:config>
29. 
30. <aop:pointcut expression="execution (\* com.most.service.\*.\*(..))" id="services"/> 
31. 
32. <aop:advisor advice-ref="txAdvice" pointcut-ref="services"/> 
33. </aop:config>
34. 
35. <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean"> 
36. <property name="dataSource" ref="dataSource" /> 
37. <property name="configLocation" value="/WEB-INF/conf/mybatis-config.xml" /> 
38. </bean>

所有以get开头的方法被调用时，readonly = true

ps：这个只是实现了读写分离，master与slave之间的数据同步使用mysql replication即可

昨晚看了一晚上的MySQL文档，主要是关于MySQL的复制方面的文档，用的工具是MySQL的帮助文档+金山词霸。

终于比较大概的了解了如何通过复制来提升MySQL数据库的高可用性和处理能力，不过还没有经过实际的试验，但整体的思想是清楚了，下面把思路大概的描述一下，有机会再进行实验。

首先在服务器端采用1+N的模型来安装和配置MySQL数据库。1就是一个master数据库，N就是一至多个slave数据库。master数据 库必须启用binlog模式，关于这两种数据库的配置参见MySQL的文档。配置完成后就形成了一个1+N的复制集群，当对master进行修改时会自动 把修改的数据更新到N个slave数据库上。但是有一个注意的是，所有的修改操作包括添加、删除、修改等语句必须作用在master数据库上，这样才能使 数据可靠的复制到其他slave服务器上。另外，由于slave服务器只用作查询，因此选用MyISAM的存储引擎可以提高查询的速度。

而在客户端呢？如何使客户端程序能均衡的使用这些可用的服务器呢？而且更新操作只能对master进行处理。这个岂不是应用程序对数据库的操作逻辑非常的复杂？

其实没有那么复杂，MySQL为我们提供了接口可以将这些复杂的操作透明化。下面主要介绍采用JDBC的客户端如何工作在基于复制的集群环境中，其他编程语言请参照mysql的文档。

MySQL最新的JDBC驱动程序包中提供了一个驱动类就是 com.mysql.jdbc.ReplicationDriver 。这个驱动类允许在url中设置多个mysql主机地址，例如：

jdbc:mysql://master1,slave1,slave2/dlog?autoReconnect=true&roundRobinLoadBalance=true

在上面的url中，有三个主机地址分别是master1,slave1,slave2，其中ReplicationDriver 规定第一个主机是master主机地址，剩下的全部是slave主机。另外有两个参数必须指定为true，就是autoReconnect和roundRobinLoadBalance。

使用这个驱动和配置后还不能马上解决所有的问题，我们还需要对程序做一些小改动。

我们必须告诉驱动程序，哪些语句的执行是作用在master数据库，而哪些语句的执行作用在slave数据库上。

ReplicationDriver 是通过Connection对象的readOnly属性来判断该操作是否为更新操作。因此我们在执行一个sql语句的时候必须调用一下 setReadOnly告诉驱动程序当前执行的操作是否是只读。如果你是使用hibernate操作数据库的，那可以调用 Query.setReadOnly方法。

以上就是整个思路的大概描述，猜想肯定还有存在一些问题，例如因为数据的复制过程是异步的，也是说有可能执行了某个更新操作，但是查询的时候查不到的情况出现。当然这些问题只能在实际的过程中进行解决。

另外关于最新版本的MySQL 5.1有一个集群的功能，不过经过研究发现这个东西简直就是儿戏，实在搞不懂MySQL怎么会做这么不负责任的设计，因为这个特性要求数据库是整个 load到内存中的，也就是说你的数据有多大，内存就得有多大，怎么说呢？ 如果你真的内存足够大，你去试试吧，反正这种方案已经被我否决了，希望MySQL能改进一下。

转载于:https://www.cnblogs.com/fx2008/p/4099143.html

[view plain]: http://blog.csdn.net/lixiucheng005/article/details/17391857
[CODE]: https://code.csdn.net/assets/CODE_ico.png
[CODE_CODE]: https://code.csdn.net/snippets/117230
[ico_fork.svg]: https://code.csdn.net/assets/ico_fork.svg
[ico_fork.svg 1]: https://code.csdn.net/snippets/117230/fork