基于Mycat开源数据库中间件MySQL数据库主从读写分离

admin

        采用读写分离技术的目标：有效减轻Master库的压力，又可以把用户查询数据的请求分发到不同的Slave库，从而保证系统的健壮性。我们看下采用读写分离的背景。


　　 随着网站的业务不断扩展，数据不断增加，用户越来越多，数据库的压力也就越来越大，采用传统的方式，比如：数据库或者SQL的优化基本已达不到要求，这个时候可以采用读写分离的策 略来改变现状。


　　具体到开发中，如何方便的实现读写分离呢?目前常用的有两种方式：


　　1 ）第一种方式是我们最常用的方式，就是定义2个sessionFactory，一个是MasterSessionFactory,另一个是SlaveSessionFactory。更新数据时我们读取MasterSessionFactory，查询数据时我们读取SlaveSessionFactory。


　　2 ）第二种方式动态数据源切换，就是在程序运行时，把数据源动态织入到程序中，从而选择读取主库还是从库。主要使用的技术是：annotation，spring AOP ，反射。具体请移步 springMvc +hibernate 实现多数据源动态切换  http://www.52itstyle.top/thread-24647-1-1.html


但是以上两种方式也有一定的缺陷，就是要改变项目的业务逻辑。增加代码量不说，维护起来也不是很方便。


上一篇文章讲到mysql主从复制的配置。 http://www.52itstyle.top/thread-25128-1-1.html


今天要给大家分享的是基于Mycat开源数据库中间件MySQL读写分离。当然首先你要自己做好主从复制，Mycat可是不支持主从复制的。


一、MySQL主从复制状态绑定的读写分离机制，使用如下配置：

1. <schema name="itstyle" checkSQLschema="false" sqlMaxLimit="100" dataNode="dn1">
   
2. </schema>
   
3. <dataNode name="dn1" dataHost="localhost1" database="itstyle" />
   
4. <dataHost name="localhost1" maxCon="1000" minCon="10" balance="1"
   
5.   writeType="0" dbType="mysql" dbDriver="native" switchType="2"  slaveThreshold="100">
   
6.   <heartbeat>show slave status</heartbeat>  
   
7.   <!-- can have multi write hosts-->
   
8.   <writeHost host="hostM1" url="192.16.1.190:3306" user="root"
   
9.    password="123456">
   
10.         <readHost host="hostS1" url="192.16.1.180:3306" user="root"
    
11.    password="123456"/>
    
12.   </writeHost>
    
13. </dataHost>

复制代码

二、参数说明


(1)        设置 balance="1"与writeType="0"
Balance参数设置：
1. balance=“0”, 所有读操作都发送到当前可用的writeHost上。
2. balance=“1”，所有读操作都随机的发送到readHost。
3. balance=“2”，所有读操作都随机的在writeHost、readhost上分发
WriteType参数设置：
1. writeType=“0”, 所有写操作都发送到可用的writeHost上。
2. writeType=“1”，所有写操作都随机的发送到readHost。
3. writeType=“2”，所有写操作都随机的在writeHost、readhost分上发。
“readHost是从属于writeHost的，即意味着它从那个writeHost获取同步数据，因此，当它所属的writeHost宕机了，则它也不会再参与到读写分离中来，即“不工作了”，这是因为此时，它的数据已经“不可靠”了。基于这个考虑，目前mycat 1.3和1.4版本中，若想支持MySQL一主一从的标准配置，并且在主节点宕机的情况下，从节点还能读取数据，则需要在Mycat里配置为两个writeHost并设置banlance=1。”


(2)        设置 switchType="2" 与slaveThreshold="100"
“Mycat心跳检查语句配置为 show slave status ，dataHost 上定义两个新属性： switchType="2" 与slaveThreshold="100"，此时意味着开启MySQL主从复制状态绑定的读写分离与切换机制。Mycat心跳机制通过检测 show slave status 中的 "Seconds_Behind_Master", "Slave_IO_Running", "Slave_SQL_Running" 三个字段来确定当前主从同步的状态以及Seconds_Behind_Master主从复制时延。“


三、测试功能
1）首先要在myca-web界面配置好mycat服务，测试数据库为itstyle。



190 主数据库 写入
mysql> use itstyle；
mysql> select * from person;
+-----+------+
| age | NAME |
+-----+------+
|   1 | zhangsan |
+-----+------+
1 row in set (0.00 sec)


显示用户姓名为zhangsan

190 从数据库 读取
mysql> use itstyle；
mysql> select * from person;
+-----+------+
| age | NAME |
+-----+------+
|   1 |lisi |
+-----+------+
1 row in set (0.00 sec)


显示用户姓名为lisi


二）测试读取是否分离

测试程序类 MycatJdbc.java

1. public class MycatJdbc {
   
2.     private static final String URL = "jdbc:mysql://192.168.1.180:8066/itstyle?characterEncoding=UTF-8";
   
3.     private static final String USERNAME = "test";
   
4.     private static final String PASS = "test";
   
5. 
   
6.     public static void main(String[] args) {
   
7.         mysql();
   
8.     }
   
9.     public static  void  mysql(){
   
10.         Connection conn = null;
    
11.         Statement stmt = null;
    
12.         ResultSet rs = null;
    
13.         try{
    
14.             conn = JDBCConnect.getConnect(URL,USERNAME,PASS);
    
15.             stmt = conn.createStatement();
    
16.             String sql = "SELECT * FROM person";
    
17.             rs = stmt.executeQuery(sql);
    
18.             while(rs.next()){
    
19.                 String name = rs.getString(2);
    
20.                 System.out.println("姓名为:"+name);
    
21.             }
    
22.         }catch(Exception e){
    
23.             e.printStackTrace();
    
24.         }finally{
    
25.             if(rs!=null){
    
26.                 try {
    
27.                     rs.close();
    
28.                 } catch (SQLException e) {
    
29.                     e.printStackTrace();
    
30.                 }
    
31.             }
    
32.             if(stmt!=null){
    
33.                 try {
    
34.                     stmt.close();
    
35.                 } catch (SQLException e) {
    
36.                     e.printStackTrace();
    
37.                 }
    
38.             }
    
39.             if(conn!=null){
    
40.                 try {
    
41.                     conn.close();
    
42.                 } catch (SQLException e) {
    
43.                     e.printStackTrace();
    
44.                 }
    
45.             }
    
46.         }
    
47.     }
    
48. }

复制代码

执行main方法 显示结果正确

admin

狗贼 发表于 2017-1-10 01:55
190 主数据库 写入
mysql> use itstyle；
mysql> select * from person;

为了测试 读写 分离 从库 删掉了

狗贼

190 主数据库 写入
mysql> use itstyle；
mysql> select * from person;
+-----+------+
| age | NAME |
+-----+------+
|   1 | zhangsan |
+-----+------+
1 row in set (0.00 sec)


显示用户姓名为zhangsan

190 从数据库 读取
mysql> use itstyle；
mysql> select * from person;
+-----+------+
| age | NAME |
+-----+------+
|   1 |lisi |
+-----+------+
1 row in set (0.00 sec)


显示用户姓名为lisi


那原来从库的 李四 去哪了