基于Mycat开源数据库中间件MySQL数据库主从读写分离
采用读写分离技术的目标：有效减轻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主从复制状态绑定的读写分离机制，使用如下配置：
<schema name="itstyle" checkSQLschema="false" sqlMaxLimit="100" dataNode="dn1">
</schema>
<dataNode name="dn1" dataHost="localhost1" database="itstyle" />
<dataHost name="localhost1" maxCon="1000" minCon="10" balance="1"
writeType="0" dbType="mysql" dbDriver="native" switchType="2"slaveThreshold="100">
<heartbeat>show slave status</heartbeat>
<!-- can have multi write hosts-->
<writeHost host="hostM1" url="192.16.1.190:3306" user="root"
password="123456">
<readHost host="hostS1" url="192.16.1.180:3306" user="root"
password="123456"/>
</writeHost>
</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
public class MycatJdbc {
private static final String URL = "jdbc:mysql://192.168.1.180:8066/itstyle?characterEncoding=UTF-8";
private static final String USERNAME = "test";
private static final String PASS = "test";
public static void main(String[] args) {
mysql();
}
public staticvoidmysql(){
Connection conn = null;
Statement stmt = null;
ResultSet rs = null;
try{
conn = JDBCConnect.getConnect(URL,USERNAME,PASS);
stmt = conn.createStatement();
String sql = "SELECT * FROM person";
rs = stmt.executeQuery(sql);
while(rs.next()){
String name = rs.getString(2);
System.out.println("姓名为:"+name);
}
}catch(Exception e){
e.printStackTrace();
}finally{
if(rs!=null){
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if(stmt!=null){
try {
stmt.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if(conn!=null){
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
}
执行main方法 显示结果正确
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
那原来从库的 李四 去哪了 狗贼 发表于 2017-1-10 01:55
190 主数据库 写入
mysql> use itstyle；
mysql> select * from person;
为了测试 读写 分离 从库 删掉了:lol
页:
[1]