今天，給大家?guī)�來一篇Mycat在MySQL主從復(fù)制的基礎(chǔ)上實(shí)現(xiàn)讀寫分離，這里大家需要注意的是MySQL的主從復(fù)制是依賴的MySQL自己的主從復(fù)制機(jī)制，Mycat不負(fù)責(zé)MySQL的主從復(fù)制，有關(guān)MySQL的主從復(fù)制配置，大家可以參考博文《MySQL之——主從復(fù)制的配置》,好了，我們接下來進(jìn)入今天的主題內(nèi)容。

一、環(huán)境

操作系統(tǒng)：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節(jié)點(diǎn)IP：192.168.209.133 主機(jī)名：liuyazhuang133 主機(jī)配置：4核CPU、4G內(nèi)存
MySQL版本：mysql-5.6.32.tar.gz
主節(jié)點(diǎn)IP：192.168.209.131 主機(jī)名：liuyazhuang131 主機(jī)配置：4核CPU、4G內(nèi)存
從節(jié)點(diǎn)IP：192.168.209.132 主機(jī)名：liuyazhuang132 主機(jī)配置：4核CPU、4G內(nèi)存

二、MyCat介紹 （ MyCat官網(wǎng)：http://mycat.io/ ）

MyCat的讀寫分離是基于后端MySQL集群的主從同步來實(shí)現(xiàn)的，而MyCat提供語(yǔ)句的分發(fā)功能。MyCat1.4開始支持MySQL主從復(fù)制狀態(tài)綁定的讀寫分離機(jī)制，讓讀更加安全可靠。

三、MyCat的安裝

1、設(shè)置MyCat的主機(jī)名和IP與主機(jī)名的映射

# 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

2、配置Java環(huán)境變量

因?yàn)镸yCat是用Java開發(fā)的，因此MyCat運(yùn)行需要安裝JDK（準(zhǔn)確來說是JRE就夠了），并且需要JDK1.7或以上版本

# 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

3、上傳安裝包

上傳Mycat-server-1.5.1-RELEASE-20170717215510-linux.tar.gz 到 MyCat服務(wù)器中的/home/mycat目錄，并解壓并移動(dòng)到 /usr/local/mycat目錄

$ tar -zxvf Mycat-server-1.5.1-RELEASE-20170717215510-linux.tar.gz

# mv /home/mycat/mycat  /usr/local/
# cd /usr/local/mycat/
# ll

4、設(shè)置Mycat的環(huán)境變量

# vi /etc/profile
## mycat env
export MYCAT_HOME=/usr/local/mycat
export PATH=$PATH:$MYCAT_HOME/bin
# source /etc/profile

四、配置MyCat

1、確認(rèn)MySQL主從復(fù)制正常

在配置MyCat前，請(qǐng)確認(rèn)MySQL的主從復(fù)制安裝配置已完成并正常運(yùn)行。MySQL主從數(shù)據(jù)的同步在MySQL中配置，MyCat不負(fù)責(zé)數(shù)據(jù)同步的問題。
補(bǔ)充：
(1) MySQL主從復(fù)制配置中，如果涉及到函數(shù)或存儲(chǔ)過程的同步復(fù)制，需要在/etc/my.cnf中的[mysqld]段中增加配置log_bin_trust_function_creators=true 或在客戶端中設(shè)置 set global log_bin_trust_function_creators = 1;
(2) 如果要做讀寫分離下的主從切換，那么從節(jié)點(diǎn)也有可能會(huì)變?yōu)閷懝?jié)點(diǎn)，因此從節(jié)點(diǎn)就不能設(shè)置為只讀 read_only=1 。
(3) Linux版本的MySQL，需要設(shè)置為MySQL大小寫不敏感，否則可能會(huì)發(fā)生找不到表的問題。可在/etc/my.cnf的[mysqld]段中增加lower_case_table_names=1 。

2、配置MyCat的schema.xml

schema.xml是MyCat最重要的配置文件之一，用于設(shè)置MyCat的邏輯庫(kù)、表、數(shù)據(jù)節(jié)點(diǎn)、dataHost等內(nèi)容，

[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的邏輯庫(kù)，邏輯庫(kù)的概念與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的情況，如邏輯庫(kù)為 TESTDB，則可能寫為select * from TESTDB.edu_user，此時(shí)會(huì)自動(dòng)過濾TESTDB，SQL變?yōu)閟elect * from edu_user，若不會(huì)出現(xiàn)上述寫法，則可以關(guān)閉屬性為false -->

		<!--sqlMaxLimit默認(rèn)返回的最大記錄數(shù)限制，MyCat1.4版本里面，用戶的Limit參數(shù)會(huì)覆蓋掉MyCat的sqlMaxLimit默認(rèn)設(shè)置-->

      <!-- 定義MyCat的數(shù)據(jù)節(jié)點(diǎn) -->

      <dataNode name="lyz_dn1" dataHost="dtHost2" database="lyzdb1" />

      <dataNode name="lyz_dn2" dataHost="dtHost2" database="lyzdb2" />

	<!-- dataNode 中的 name 數(shù)據(jù)表示節(jié)點(diǎn)名稱， dataHost表示數(shù)據(jù)主機(jī)名稱， database表示該節(jié)點(diǎn)要路由的數(shù)據(jù)庫(kù)的名稱 -->

 

      <!-- dataHost配置的是實(shí)際的后端數(shù)據(jù)庫(kù)集群（當(dāng)然，也可以是非集群） -->

      <!-- 注意：schema中的每一個(gè)dataHost中的host屬性值必須唯一，否則會(huì)出現(xiàn)主從在所有dataHost中全部切換的現(xiàn)象 -->

      <!-- 定義數(shù)據(jù)主機(jī)dtHost1，只連接到MySQL讀寫分離集群中的Master節(jié)點(diǎn)，不使用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主從切換 -->

      <!-- 定義數(shù)據(jù)主機(jī)dtHost2，連接到MySQL讀寫分離集群，并配置了讀寫分離和主從切換 -->

      <dataHost name="dtHost2" maxCon="500" minCon="20" balance="1"

           writeType="0" dbType="mysql" dbDriver="native" switchType="2" slaveThreshold="100">

           <!-- 通過show slave status檢測(cè)主從狀態(tài)，當(dāng)主宕機(jī)以后，發(fā)生切換，從變?yōu)橹�，原來的主變�(yōu)閺�，這時(shí)候show slave status就會(huì)發(fā)生錯(cuò)誤，因?yàn)樵瓉淼闹鳑]有開啟slave，不建議直接使用switch操作，而是在DB中做主從對(duì)調(diào)。 -->

           <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>

      <!-- 參數(shù)balance決定了哪些MySQL服務(wù)器參與到讀SQL的負(fù)載均衡中 -->

		<!-- balance="0"，為不開啟讀寫分離，所有讀操作都發(fā)送到當(dāng)前可用的writeHost上-->

      <!-- balance="1"，全部的readHost與stand by writeHost參與select語(yǔ)句的負(fù)載均衡-->

      <!-- balance="2"，所有讀操作都隨機(jī)的在writeHost、readHost上分發(fā)-->

      <!-- MyCat1.4版本中，若想支持MySQL一主一從的標(biāo)準(zhǔn)配置，并且在主節(jié)點(diǎn)宕機(jī)的情況下，從節(jié)點(diǎn)還能讀取數(shù)據(jù)，則需要在MyCat里配置為兩個(gè)writeHost并設(shè)置balance="1" -->

      <!-- writeType="0"，所有寫操作都發(fā)送到可用的writeHost上 -->

      <!-- writeType="1"，僅僅對(duì)于galera for mysql集群這種多主多節(jié)點(diǎn)都能寫入的集群起效，此時(shí)Mycat會(huì)隨機(jī)選擇一個(gè)writeHost并寫入數(shù)據(jù)，對(duì)于非galera for mysql集群，請(qǐng)不要配置writeType=1，會(huì)導(dǎo)致數(shù)據(jù)庫(kù)不一致的嚴(yán)重問題 -->

</mycat:schema>

MyCat1.4開始支持MySQL主從復(fù)制狀態(tài)綁定的讀寫分離機(jī)制，讓讀更加安全可靠，配置如下：
MyCat心跳檢查語(yǔ)句配置為 show slave status ，dataHost 上定義兩個(gè)新屬性：switchType="2" 與 slaveThreshold="100"，此時(shí)意味著開啟MySQL主從復(fù)制狀態(tài)綁定的讀寫分離與切換機(jī)制，MyCat心跳機(jī)制通過檢測(cè) show slave status 中的
"Seconds_Behind_Master", "Slave_IO_Running", "Slave_SQL_Running" 三個(gè)字段來確定當(dāng)前主從同步的狀態(tài)以及Seconds_Behind_Master主從復(fù)制時(shí)延，當(dāng)Seconds_Behind_Master 大于slaveThreshold時(shí)，讀寫分離篩選器會(huì)過濾掉此Slave機(jī)器，防止讀到很久之前的舊數(shù)據(jù)，而當(dāng)主節(jié)點(diǎn)宕機(jī)后，切換邏輯會(huì)檢查Slave上的Seconds_Behind_Master是否為0，為0時(shí)則表示主從同步，可以安全切換，否則不會(huì)切換。

3、配置 server.xml

server.xml 主要用于設(shè)置系統(tǒng)變量、管理用戶、設(shè)置用戶權(quán)限等。

[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壓縮協(xié)議-->

		  <!-- <property name="processorBufferChunk">40960</property> -->

		  <!--

		  <property name="processors">1</property>

		  <property name="processorExecutor">32</property>

		   -->

			   <!--默認(rèn)是65535 64K 用于sql解析時(shí)最大文本長(zhǎng)度 -->

			   <!--<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：開啟小數(shù)量級(jí)（默認(rèn)） ；1：開啟億級(jí)數(shù)據(jù)排序

					  <property name="mutiNodePatchSize">100</property> 億級(jí)數(shù)量排序批量

					 <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，對(duì)應(yīng)的MyCat邏輯庫(kù)連接到的數(shù)據(jù)節(jié)點(diǎn)對(duì)應(yīng)的主機(jī)為MySQL主從復(fù)制配置中的Master節(jié)點(diǎn)，沒實(shí)現(xiàn)讀寫分離，讀寫都在該Master節(jié)點(diǎn)中進(jìn)行  -->

		  <!--

		  <user name="user1">

			   <property name="password">roncoo.1</property>

			   <property name="schemas">rc_schema1,pay_schema1</property>

		  </user>

		  -->

		  <!-- 用戶2，對(duì)應(yīng)的MyCat邏輯庫(kù)連接到的數(shù)據(jù)節(jié)點(diǎn)對(duì)應(yīng)的主機(jī)為主從復(fù)制集群，并通過MyCat實(shí)現(xiàn)了讀寫分離 -->

		  <user name="lyz">

			   <property name="password">lyz.123</property>

			   <property name="schemas">lyz_schema1,lyz_schema2</property>

		  </user>

		  <!-- 用戶3，只讀權(quán)限-->

		  <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>

4、防火墻中打開8066和9066端口

MyCat的默認(rèn)數(shù)據(jù)端口為8066，mycat通過這個(gè)端口接收數(shù)據(jù)庫(kù)客戶端的訪問請(qǐng)求。
管理端口為9066，用來接收mycat監(jiān)控命令、查詢mycat運(yùn)行狀況、重新加載配置文件等。

[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

5、修改log日志級(jí)別為debug

修改log日志級(jí)別為debug，以便通過日志確認(rèn)基于MyCat的MySQL數(shù)據(jù)庫(kù)集群讀寫分離的數(shù)據(jù)操作狀態(tài)（可以在正式上生產(chǎn)前改成info級(jí)別）

[root@liuyazhuang133 conf]$ vi /usr/local/mycat/conf/log4j.xml

6、啟動(dòng)root

[root@liuyazhuang133 bin]$ cd /usr/local/root/bin/

(1) 控制臺(tái)啟動(dòng)，這種啟動(dòng)方式在控制臺(tái)關(guān)閉后，root服務(wù)也將關(guān)閉，適合調(diào)試使用：

[root@liuyazhuang133 bin]$ ./root console

(2) 可以采用以下后臺(tái)啟動(dòng)的方式：

[root@liuyazhuang133 bin]$ ./root start
Starting root-server...

（對(duì)應(yīng)的，重啟: root restart ， 關(guān)閉: root stop ）

7、MyCat連接測(cè)試

(1) 如果本地Windows安裝有MySQL，可以使用已有的mysql客戶端遠(yuǎn)程操作Mycat

(2) Nativecat連接Mycat

8、讀寫分離測(cè)試

(1) 監(jiān)聽MyCat日志

[root@liuyazhuang133 ~]$ cd /usr/local/mycat/logs/
[root@liuyazhuang133 logs]$ tail -f mycat.log

(2) 讀測(cè)試

$ 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;

執(zhí)行上面的查詢語(yǔ)句，此時(shí)對(duì)應(yīng)的MyCat日志信息如下：

多次執(zhí)行 select * from lyz_user_02 語(yǔ)句，Mycat打印出來的日志信息顯示讀操作請(qǐng)求都是路由到Slave節(jié)點(diǎn)（192.168.209.132）

(2) 寫測(cè)試

mysql> insert into lyz_user_02 (userName, pwd) values('liuyazhuang', 'lyz。123');

執(zhí)行上面的新增插入語(yǔ)句后，此時(shí)對(duì)應(yīng)的Mycat日志信息如下：

多次執(zhí)行以上插入語(yǔ)句，發(fā)現(xiàn)新增數(shù)據(jù)都是從 Master節(jié)點(diǎn)（192.168.209.131）插進(jìn)入的，并且Slave節(jié)點(diǎn)通過Binlog同步了Master節(jié)點(diǎn)中的數(shù)據(jù)。

綜上，基于MyCat的讀寫分離集群配置成功。

以上就是Mycat讀寫分離在MySQL主從復(fù)制基礎(chǔ)上實(shí)現(xiàn)的實(shí)例的詳細(xì)內(nèi)容，更多請(qǐng)關(guān)注php中文網(wǎng)其它相關(guān)文章！