基于前面讲的Mysql主从复制，我们通过Mycat，能够实现读写分离，即master主服务器实现写操作(insert,update,delete等)，salve从服务器实现读操作(select等)，

主服务器一旦有写入操作，从服务器通过读取binlog，来实现数据同步；Mycat也时时发送心跳包来检测mysql服务器是否可用；

实现

1）配置文件详解

Mycat读写分离核心配置文件 schema.xml文件，我们打开； 我们对配置文件来详细介绍下；

schema.xml有几个标签，分别是：

mycat:schema 主配置标签；

schema逻辑库配置标签；

dataNode数据节点配置标签；

dataHost数据库主机配置标签；

一个逻辑库，对应多个逻辑表，每个逻辑表如上图，可以水平分片，分成一个或者多个数据分片节点，每个数据分片节点对应一个dataHost（数据库主机），dataHost里可以通过writeHost和readHost配置写主机和读主机；

1.1）schema逻辑库配置标签

（定义逻辑数据库）

1.2）dataNode数据节点配置标签

（定义数据分片节点）

1.3）dataHost数据库主机配置标签

（定义后端的数据库主机）

heartbeat子标签属性（心跳执行SQL） writeHost子标签属性（写主机配置） readHost子标签属性（读主机配置）

2）读写分离实现

参考配置

<?xml version="1.0"?>
<!DOCTYPE mycat:schema SYSTEM "schema.dtd">
<mycat:schema xmlns:mycat="http://io.mycat/">
​
  <schema name="TESTDB" checkSQLschema="true" sqlMaxLimit="100" dataNode="dn1">
  </schema>
​
  <dataNode name="dn1" dataHost="localhost1" database="db_javaxl" />
 
​
  <dataHost name="localhost1" maxCon="1000" minCon="10" balance="3"
         writeType="0" dbType="mysql" dbDriver="native" switchType="2"  slaveThreshold="100">
​
     <heartbeat>select user()</heartbeat>
     <!-- can have multi write hosts -->
​
     <writeHost host="masterHost1" url="172.20.0.2:3306" user="root"
             password="123456">
             <readHost host="slaveHost1" url="172.20.0.3:3306" user="root"
             password="123456"></readHost>
     </writeHost>
     
  </dataHost>
​
</mycat:schema>

测试

重新启动一个Mycat容器

docker run --name mycat2 -p 8066:8066 -it --net extnetwork --ip 172.20.0.4 -v /home/docker/mycat/conf/:/home/mycat/conf/ -v /home/docker/mycat/logs/:/home/mycat/logs/ 镜像id

为了能看到读写分离效果，我们把mysql主从复制的一个配置文件改下：binlog_format= MIXED 改成 STATEMENT

改完mysql的配置需要重启，并确保mysql、mysql2主从复制生效；

可能涉及到的sql语句

CREATE USER 'slave1'@'172.20.0.3' IDENTIFIED BY '123456';
GRANT REPLICATION SLAVE ON *.* TO 'slave1'@'172.20.0.3';
FLUSH PRIVILEGES;
​
SHOW MASTER STATUS
reset MASTER
​
START SLAVE
STOP SLAVE 
SHOW SLAVE STATUS
​
CHANGE MASTER TO MASTER_HOST='172.20.0.2', MASTER_USER='slave1', MASTER_PASSWORD='123456', MASTER_LOG_FILE='mysql-bin.000001', MASTER_LOG_POS=154;

这样同步的时候 同步的是SQL，我们一些函数的一定特定，能分辨出哪个主机行了 写请求，哪个主机执行了 读请求； 我们在mycat中 执行

INSERT INTO TESTDB.t_student VALUES(NULL,@@hostname) 

插入主机名称；@@hostname

Master看到

Slave看到

我们再到Master服务器执行插入语句看看

我们再到Slave服务器执行插入语句看看

over......