今天，帶給大家一篇Mycat在MySQL主從複製的基礎上實現讀寫分離，這裡大家需要注意的是MySQL的主從複製是依賴的MySQL自己的主從複製機制，Mycat不負責MySQL的主從複製，有關MySQL的主從複製配置，大家可以參考博文《MySQL之——主從複製的配置》,好了，我們接下來進入今天的主題內容。
作業系統：CentOS-6.5-x86_64-bin-DVD1.iso
JDK版本：jdk1.7.0_80
MyCat版本：Mycat- server-1.5.1-RELEASE-20170717215510-linux.tar.gz (下載原始碼自行編譯的)
MyCat節點IP：192.168.209.133 SQL##MyCat節點主機名稱：liuyyazhuang133334版本主機主機配置、4p ：mysql-5.6.32.tar.gz
主節點IP：192.168.209.131 主機名稱：liuyazhuang131 主機配置：4核心CPU、4G記憶體
從節點IP：192.168.30 主機配置： 4核心CPU、4G記憶體
# vi /etc/sysconfig/network NETWORKING=yes HOSTNAME=liuyazhuang133
# vi /etc/hosts 127.0.0.1 liuyazhuang133 192.168.209.131 liuyazhuang131 192.168.209.132 liuyazhuang132 192.168.209.133 liuyazhuang133
# vi /etc/profile ## java env export JAVA_HOME=/usr/local/java/jdk1.7.0_80 export JRE_HOME=$JAVA_HOME/jre export CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar:$JRE_HOME/lib/rt.jar export PATH=$PATH:$JAVA_HOME/bin:$JRE_HOME/bin # source /etc/profile # java -version
$ tar -zxvf Mycat-server-1.5.1-RELEASE-20170717215510-linux.tar.gz
# mv /home/mycat/mycat /usr/local/ # cd /usr/local/mycat/ # ll
# vi /etc/profile ## mycat env export MYCAT_HOME=/usr/local/mycat export PATH=$PATH:$MYCAT_HOME/bin # source /etc/profile
補充：
(1) MySQL主從複製配置中，如果涉及函數或預存程序的同步複製，需要在/etc/my.cnf中的[mysqld]段中增加配置log_bin_trust_function_creators=true 或在客戶端設定set global log_bin_trust_function_creators = 1;
(2) 如果要做讀寫分離下的主從切換，那麼從節點也有可能會變成寫節點，因此從節點就不能設定為唯讀read_only =1 。
(3) Linux版本的MySQL，需要設定為MySQL大小寫不敏感，否則可能會發生找不到表格的問題。可在/etc/my.cnf的[mysqld]段中增加lower_case_table_names=1 。
[root@liuyazhuang133 conf]$ cd /usr/local/root/conf/ [root@liuyazhuang133 conf]$ vi schema.xml
<?xml version="1.0"?>
<!DOCTYPE mycat:schema SYSTEM "schema.dtd">
<mycat:schema xmlns:mycat="http://org.opencloudb/">
<!-- 定义MyCat的逻辑库，逻辑库的概念与MySQL中的 database 概念相同 -->
<!-- schema name="rc_schema1" checkSQLschema="false" sqlMaxLimit="100" dataNode="rc_dn1"></schema -->
<!--schema name="pay_schema1" checkSQLschema="false" sqlMaxLimit="100" dataNode="pay_dn1"></schema-->
<schema name="lyz_schema1" checkSQLschema="false" sqlMaxLimit="100" dataNode="lyz_dn1"></schema>
<schema name="lyz_schema2" checkSQLschema="false" sqlMaxLimit="100" dataNode="lyz_dn2"></schema>
<!-- 其中checkSQLschema表明是否检查并过滤SQL中包含schema的情况，如逻辑库为 TESTDB，则可能写为select * from TESTDB.edu_user，此时会自动过滤TESTDB，SQL变为select * from edu_user，若不会出现上述写法，则可以关闭属性为false -->
<!--sqlMaxLimit默认返回的最大记录数限制，MyCat1.4版本里面，用户的Limit参数会覆盖掉MyCat的sqlMaxLimit默认设置-->
<!-- 定义MyCat的数据节点 -->
<dataNode name="lyz_dn1" dataHost="dtHost2" database="lyzdb1" />
<dataNode name="lyz_dn2" dataHost="dtHost2" database="lyzdb2" />
<!-- dataNode 中的 name 数据表示节点名称， dataHost表示数据主机名称， database表示该节点要路由的数据库的名称 -->
<!-- dataHost配置的是实际的后端数据库集群（当然，也可以是非集群） -->
<!-- 注意：schema中的每一个dataHost中的host属性值必须唯一，否则会出现主从在所有dataHost中全部切换的现象 -->
<!-- 定义数据主机dtHost1，只连接到MySQL读写分离集群中的Master节点，不使用MyCat托管MySQL主从切换 -->
<!--
<dataHost name="dtHost1" maxCon="500" minCon="20" balance="0"
writeType="0" dbType="mysql" dbDriver="native" switchType="1" slaveThreshold="100">
<heartbeat>select user()</heartbeat>
<writeHost host="hostM1" url="192.168.1.205:3306" user="root" password="lyz" />
</dataHost>
-->
<!-- 使用MyCat托管MySQL主从切换 -->
<!-- 定义数据主机dtHost2，连接到MySQL读写分离集群，并配置了读写分离和主从切换 -->
<dataHost name="dtHost2" maxCon="500" minCon="20" balance="1"
writeType="0" dbType="mysql" dbDriver="native" switchType="2" slaveThreshold="100">
<!-- 通过show slave status检测主从状态，当主宕机以后，发生切换，从变为主，原来的主变为从，这时候show slave status就会发生错误，因为原来的主没有开启slave，不建议直接使用switch操作，而是在DB中做主从对调。 -->
<heartbeat>show slave status</heartbeat>
<!-- can have multi write hosts -->
<writeHost host="hostM2" url="192.168.209.131:3306" user="root" password="root" />
<writeHost host="hostS2" url="192.168.209.132:3306" user="root" password="root" />
</dataHost>
<!-- 参数balance决定了哪些MySQL服务器参与到读SQL的负载均衡中 -->
<!-- balance="0"，为不开启读写分离，所有读操作都发送到当前可用的writeHost上-->
<!-- balance="1"，全部的readHost与stand by writeHost参与select语句的负载均衡-->
<!-- balance="2"，所有读操作都随机的在writeHost、readHost上分发-->
<!-- MyCat1.4版本中，若想支持MySQL一主一从的标准配置，并且在主节点宕机的情况下，从节点还能读取数据，则需要在MyCat里配置为两个writeHost并设置balance="1" -->
<!-- writeType="0"，所有写操作都发送到可用的writeHost上 -->
<!-- writeType="1"，仅仅对于galera for mysql集群这种多主多节点都能写入的集群起效，此时Mycat会随机选择一个writeHost并写入数据，对于非galera for mysql集群，请不要配置writeType=1，会导致数据库不一致的严重问题 -->
</mycat:schema>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主從複製時延，當Seconds_Behind_MasterMaster 大於slaveThreshold時，機器讀寫分離篩選器會過濾掉此機器，防止讀到很久之前的舊數據，而當主節點宕機後，切換邏輯會檢查Slave上的Seconds_Behind_Master是否為0，為0時則表示主從同步，可以安全切換，否則不會切換。
[root@liuyazhuang133 conf]$ vi server.xml
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mycat:server SYSTEM "server.dtd">
<mycat:server xmlns:mycat="http://org.opencloudb/">
<system>
<property name="defaultSqlParser">druidparser</property>
<property name="charset">utf8mb4</property>
<!-- <property name="useCompression">1</property>-->
<!--1为开启mysql压缩协议-->
<!-- <property name="processorBufferChunk">40960</property> -->
<!--
<property name="processors">1</property>
<property name="processorExecutor">32</property>
-->
<!--默认是65535 64K 用于sql解析时最大文本长度 -->
<!--<property name="maxStringLiteralLength">65535</property>-->
<!--<property name="sequnceHandlerType">0</property>-->
<!--<property name="backSocketNoDelay">1</property>-->
<!--<property name="frontSocketNoDelay">1</property>-->
<!--<property name="processorExecutor">16</property>-->
<!-- <property name="mutiNodeLimitType">1</property> 0：开启小数量级（默认） ；1：开启亿级数据排序
<property name="mutiNodePatchSize">100</property> 亿级数量排序批量
<property name="processors">32</property> <property name="processorExecutor">32</property>
<property name="serverPort">8066</property> <property name="managerPort">9066</property>
<property name="idleTimeout">300000</property> <property name="bindIp">0.0.0.0</property>
<property name="frontWriteQueueSize">4096</property>
<property name="processors">32</property>
-->
</system>
<!-- 用户1，对应的MyCat逻辑库连接到的数据节点对应的主机为MySQL主从复制配置中的Master节点，没实现读写分离，读写都在该Master节点中进行 -->
<!--
<user name="user1">
<property name="password">roncoo.1</property>
<property name="schemas">rc_schema1,pay_schema1</property>
</user>
-->
<!-- 用户2，对应的MyCat逻辑库连接到的数据节点对应的主机为主从复制集群，并通过MyCat实现了读写分离 -->
<user name="lyz">
<property name="password">lyz.123</property>
<property name="schemas">lyz_schema1,lyz_schema2</property>
</user>
<!-- 用户3，只读权限-->
<user name="userlyz">
<property name="password">lyz.123</property>
<property name="schemas">lyz_schema1,lyz_schema2</property>
<property name="readOnly">true</property>
</user>
</mycat:server>管理埠為9066，用來接收mycat監控指令、查詢mycat運作狀況、重新載入設定檔等。
[root@liuyazhuang133 mycat]# vi /etc/sysconfig/iptables
## MyCat -A INPUT -m state --state NEW -m tcp -p tcp --dport 8066 -j ACCEPT -A INPUT -m state --state NEW -m tcp -p tcp --dport 9066 -j ACCEPT
[root@liuyazhuang133 mycat]# service iptables restart
[root@liuyazhuang133 conf]$ vi /usr/local/mycat/conf/log4j.xml
#
[root@liuyazhuang133 bin]$ cd /usr/local/root/bin/
(1) 控制台启动，这种启动方式在控制台关闭后，root服务也将关闭，适合调试使用：
[root@liuyazhuang133 bin]$ ./root console
(2) 可以采用以下后台启动的方式：
[root@liuyazhuang133 bin]$ ./root start Starting root-server...
（对应的，重启: root restart ， 关闭: root stop ）
(1) 如果本地Windows安装有MySQL，可以使用已有的mysql客户端远程操作Mycat
(2) Nativecat连接Mycat
(1) 监听MyCat日志
[root@liuyazhuang133 ~]$ cd /usr/local/mycat/logs/ [root@liuyazhuang133 logs]$ tail -f mycat.log
(2) 读测试
$ mysql -uuserlyz -plyz.123 -h192.168.209.233 -P8066 mysql> show databases;
mysql> use lyz_schema2;
mysql> show tables;
mysql> select * from lyz_user_02;
执行上面的查询语句，此时对应的MyCat日志信息如下：
多次执行 select * from lyz_user_02 语句，Mycat打印出来的日志信息显示读操作请求都是路由到Slave节点（192.168.209.132）
(2) 写测试
mysql> insert into lyz_user_02 (userName, pwd) values('liuyazhuang', 'lyz。123');
执行上面的新增插入语句后，此时对应的Mycat日志信息如下：
多次执行以上插入语句，发现新增数据都是从 Master节点（192.168.209.131）插进入的，并且Slave节点通过Binlog同步了Master节点中的数据。
综上，基于MyCat的读写分离集群配置成功。
以上是Mycat讀寫分離在MySQL主從複製基礎上實現的實例的詳細內容。更多資訊請關注PHP中文網其他相關文章！
