Mycat讀寫分離在MySQL主從復制基礎上實現的實例

今天,給大家帶來一篇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???? 主機名:liuyazhuang133? 主機配置:4核CPU、4G內存
MySQL版本:mysql-5.6.32.tar.gz
主節點IP:192.168.209.131???? 主機名:liuyazhuang131?? 主機配置:4核CPU、4G內存
從節點IP:192.168.209.132???? 主機名:liuyazhuang132?? 主機配置:4核CPU、4G內存

二、MyCat介紹? ( MyCat官網:http://mycat.io/ )

MyCat的讀寫分離是基于后端MySQL集群的主從同步來實現的,而MyCat提供語句的分發功能。MyCat1.4開始支持MySQL主從復制狀態綁定的讀寫分離機制,讓讀更加安全可靠。

Mycat讀寫分離在MySQL主從復制基礎上實現的實例

三、MyCat的安裝

1、設置MyCat的主機名和IP與主機名的映射

#?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環境變量

因為MyCat是用Java開發的,因此MyCat運行需要安裝JDK(準確來說是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服務器中的/home/mycat目錄,并解壓并移動到 /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

Mycat讀寫分離在MySQL主從復制基礎上實現的實例

4、設置Mycat的環境變量

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

四、配置MyCat

1、確認MySQL主從復制正常

在配置MyCat前,請確認MySQL的主從復制安裝配置已完成并正常運行。MySQL主從數據的同步在MySQL中配置,MyCat不負責數據同步的問題。
補充:
(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 。

2、配置MyCat的schema.xml

schema.xml是MyCat最重要的配置文件之一,用于設置MyCat的邏輯庫、表、數據節點、dataHost等內容,

[root@liuyazhuang133?conf]$?cd?/usr/local/root/conf/  [root@liuyazhuang133?conf]$?vi?schema.xml
<?xml  version="1.0"?>nbsp;mycat:schema?SYSTEM?"schema.dtd"&gt;    <schema>    ??????<!-- 定義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></schema>    ??????<schema></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></datanode>    ??????<datanode></datanode><!-- 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>    ???????????<!-- 通過show slave status檢測主從狀態,當主宕機以后,發生切換,從變為主,原來的主變為從,這時候show slave status就會發生錯誤,因為原來的主沒有開啟slave,不建議直接使用switch操作,而是在DB中做主從對調。 -->    ???????????<heartbeat>show?slave?status</heartbeat>    ???????????<!-- can have multi write hosts -->    ???????????<writehost></writehost>    ???????????<writehost></writehost>    ??????</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,會導致數據庫不一致的嚴重問題 -->    </schema>

MyCat1.4開始支持MySQL主從復制狀態綁定的讀寫分離機制,讓讀更加安全可靠,配置如下:
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_Master 大于slaveThreshold時,讀寫分離篩選器會過濾掉此Slave機器,防止讀到很久之前的舊數據,而當主節點宕機后,切換邏輯會檢查Slave上的Seconds_Behind_Master是否為0,為0時則表示主從同步,可以安全切換,否則不會切換。

3、配置 server.xml

server.xml 主要用于設置系統變量、管理用戶、設置用戶權限等。

[root@liuyazhuang133?conf]$?vi?server.xml
<?xml  version="1.0" encoding="UTF-8"?>nbsp;mycat:server?SYSTEM?"server.dtd"&gt;    <server>    ??????<system><property>druidparser</property><property>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>    			???<property>lyz.123</property>    			???<property>lyz_schema1,lyz_schema2</property>    		??</user>    		??<!-- 用戶3,只讀權限-->    		??<user>    			???<property>lyz.123</property>    			???<property>lyz_schema1,lyz_schema2</property>    			???<property>true</property>    		??</user></server>

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

MyCat的默認數據端口為8066,mycat通過這個端口接收數據庫客戶端的訪問請求。
管理端口為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

5、修改log日志級別為debug

修改log日志級別為debug,以便通過日志確認基于MyCat的MySQL數據庫集群讀寫分離的數據操作狀態(可以在正式上生產前改成info級別)

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

Mycat讀寫分離在MySQL主從復制基礎上實現的實例

6、啟動root

[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?)

7、MyCat連接測試

(1) 如果本地Windows安裝有MySQL,可以使用已有的mysql客戶端遠程操作Mycat
Mycat讀寫分離在MySQL主從復制基礎上實現的實例
Mycat讀寫分離在MySQL主從復制基礎上實現的實例

(2) Nativecat連接Mycat

Mycat讀寫分離在MySQL主從復制基礎上實現的實例

Mycat讀寫分離在MySQL主從復制基礎上實現的實例

Mycat讀寫分離在MySQL主從復制基礎上實現的實例

8、讀寫分離測試

(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&gt;?show?databases;

Mycat讀寫分離在MySQL主從復制基礎上實現的實例

mysql&gt;?use?lyz_schema2;

Mycat讀寫分離在MySQL主從復制基礎上實現的實例

mysql&gt;?show?tables;

Mycat讀寫分離在MySQL主從復制基礎上實現的實例

mysql&gt;?select?*?from?lyz_user_02;

Mycat讀寫分離在MySQL主從復制基礎上實現的實例
執行上面的查詢語句,此時對應的MyCat日志信息如下:

Mycat讀寫分離在MySQL主從復制基礎上實現的實例

多次執行 select * from lyz_user_02 語句,Mycat打印出來的日志信息顯示讀操作請求都是路由到Slave節點(192.168.209.132)

(2) 寫測試

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

Mycat讀寫分離在MySQL主從復制基礎上實現的實例
執行上面的新增插入語句后,此時對應的Mycat日志信息如下:

Mycat讀寫分離在MySQL主從復制基礎上實現的實例

多次執行以上插入語句,發現新增數據都是從 Master節點(192.168.209.131)插進入的,并且Slave節點通過Binlog同步了Master節點中的數據。

Mycat讀寫分離在MySQL主從復制基礎上實現的實例

Mycat讀寫分離在MySQL主從復制基礎上實現的實例

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

? 版權聲明
THE END
喜歡就支持一下吧
點贊11 分享