mycat做Mysql的讀寫分離
在MySQL中介軟體出現之前,對於MySQL主從叢集,如果要實現其讀寫分離,一般是在程式端實現,這樣就帶來一個問題,即資料庫和程式的耦合度太高,如果我資料庫的地址發生改變了,那麼我程式端也要進行相應的修改,如果資料庫不小心掛掉了,則同時也意味著程式的不可用,而這對很多應用來說,並不能接受。
引入MySQL中介軟體能很好的對程式端和資料庫進行解耦,這樣,程式端只需關注資料庫中介軟體的地址,而無需知曉底層資料庫是如何提供服務。
作為當前炙手可熱的MySQL中介軟體,MyCAT實現MySQL主從叢集的讀寫分離自是應有之義,其配置也相當簡單。
在這裡,我用三個例項組成MySQL主從叢集,來驗證MyCAT的讀寫分離功能,其實,一主一從就可以滿足,之所以用三個,是為了驗證MyCAT的分片功能。
叢集組成如下:
角色 主機名 主機IP
master mysql-server1 192.168.1.5
slave mysql-server2 192.168.1.6
slave mysql-server3 192.168.1.4
在這裡,還是使用Travelrecord表進行測試。
首先編輯MyCAT的配置檔案schema.xml,關於dataHost的配置資訊如下:
<dataHost name="localhost1" maxCon="1000" minCon="10" balance="1" writeType="0" dbType="mysql" dbDriver="native" switchType="-1" slaveThreshold="100"> <heartbeat>select user()</heartbeat> <!-- can have multi write hosts --> <writeHost host="MYM1" url="192.168.1.5:3307" user="root" password="lichao"> </writeHost> <writeHost host="MYS1" url="192.168.1.6:3307" user="root" password="lichao" /> <writeHost host="MYS2" url="192.168.1.4:3307" user="root" password="123456" /> </dataHost>
這裡面,有兩個引數需要注意,balance和 switchType。
其中,balance指的負載均衡型別,目前的取值有4種:
- balance="0", 不開啟讀寫分離機制,所有讀操作都發送到當前可用的writeHost上。
- balance="1",全部的readHost與stand by writeHost參與select語句的負載均衡,簡單的說,當雙主雙從模式(M1->S1,M2->S2,並且M1與 M2互為主備),正常情況下,M2,S1,S2都參與select語句的負載均衡。
- balance="2",所有讀操作都隨機的在writeHost、readhost上分發。
- balance="3",所有讀請求隨機的分發到wiriterHost對應的readhost執行,writerHost不負擔讀壓力
switchType指的是切換的模式,目前的取值也有4種:
- switchType='-1' 表示不自動切換
- switchType='1' 預設值,表示自動切換
- switchType='2' 基於MySQL主從同步的狀態決定是否切換,心跳語句為 show slave status
- switchType='3'基於MySQL galary cluster的切換機制(適合叢集)(1.4.1),心跳語句為 show status like 'wsrep%'。
因此,該配置檔案中的balance="1"意味著作為stand by writeHost的hostS1和hostS2將參與select語句的負載均衡,這就實現了主從的讀寫分離,switchType='-1'意味著當主掛掉的時候,不進行自動切換,即hostS1和hostS2並不會被提升為主,仍只提供讀的功能。這就避免了將資料寫進slave的可能性,畢竟,單純的MySQL主從叢集並不允許將資料讀進slave中,除非配置的是雙master。
驗證讀寫分離
下面來驗證一下,
建立Travelrecord表
create table travelrecord (id bigint not null primary key,user_id varchar(100),traveldate DATE, fee decimal,days int);`
插入資料
mysql> insert into travelrecord(id,user_id,traveldate,fee,days) values(1,@@hostname,20160101,100,10);
Query OK, 1 row affected, 1 warning (0.02 sec)mysql> insert into travelrecord(id,user_id,traveldate,fee,days) values(5000001,@@hostname,20160102,100,10);
Query OK, 1 row affected, 1 warning (0.01 sec)
在這裡,用了一個取巧的方法,即對user_id插入了當前例項的主機名,這樣可直觀的觀察讀寫是否分離以及MyCAT的分片功能。能這樣做的原因在於我當前的MySQL版本-5.6.26預設是基於statement的複製,如果是基於row的複製,則這個方法將不可取。
查詢資料
mysql> select * from travelrecord;
+---------+---------------+------------+------+------+
| id | user_id | traveldate | fee | days |
+---------+---------------+------------+------+------+
| 1 | mysql-server2 | 2016-01-01 | 100 | 10 |
| 5000001 | mysql-server3 | 2016-01-02 | 100 | 10 |
+---------+---------------+------------+------+------+
rows in set (0.01 sec)mysql> select * from travelrecord;
+---------+---------------+------------+------+------+
| id | user_id | traveldate | fee | days |
+---------+---------------+------------+------+------+
| 5000001 | mysql-server3 | 2016-01-02 | 100 | 10 |
| 1 | mysql-server2 | 2016-01-01 | 100 | 10 |
+---------+---------------+------------+------+------+
rows in set (0.02 sec)mysql> select * from travelrecord;
+---------+---------------+------------+------+------+
| id | user_id | traveldate | fee | days |
+---------+---------------+------------+------+------+
| 5000001 | mysql-server3 | 2016-01-02 | 100 | 10 |
| 1 | mysql-server3 | 2016-01-01 | 100 | 10 |
+---------+---------------+------------+------+------+
rows in set (0.01 sec)mysql> select * from travelrecord;
+---------+---------------+------------+------+------+
| id | user_id | traveldate | fee | days |
+---------+---------------+------------+------+------+
| 5000001 | mysql-server3 | 2016-01-02 | 100 | 10 |
| 1 | mysql-server3 | 2016-01-01 | 100 | 10 |
+---------+---------------+------------+------+------+
rows in set (0.01 sec)mysql> select * from travelrecord;
+---------+---------------+------------+------+------+
| id | user_id | traveldate | fee | days |
+---------+---------------+------------+------+------+
| 1 | mysql-server2 | 2016-01-01 | 100 | 10 |
| 5000001 | mysql-server2 | 2016-01-02 | 100 | 10 |
+---------+---------------+------------+------+------+
從上面的輸出結果,可以得出以下兩點:
一、該配置已實現讀寫分離,讀出來的資料沒有master節點的。
二、MyCAT的隨機分發不是基於statement的,即一個select語句查詢其中一個節點,另外一個select語句查詢另外一個節點。它分發針對的是片的,同一個select語句的結果是有不同dataNode返回的。
不僅如此,從MyCAT日誌中也可以獲取讀寫分離的相關資訊,當然,前提是MyCAT的日誌級別是debug。日誌相關資訊如下:
驗證mater掛了,slave還能提供讀的功能
對於MySQL主從叢集,我們的需求是master掛了,slave還能提供讀的功能。
下面來測試一下
首先,人為的關閉主庫
[[email protected] ~]# /etc/init.d/mysqld stop
登入MyCAT
[[email protected] ~]# mysql -utest -ptest -h127.0.0.1 -P8066 -DTESTDB
插入資料
mysql> insert into travelrecord(id,user_id,traveldate,fee,days) values(10000001,@@hostname,20160103,100,10);
ERROR 1184 (HY000): Connection refused
mysql> select * from travelrecord;
+---------+---------------+------------+------+------+
| id | user_id | traveldate | fee | days |
+---------+---------------+------------+------+------+
| 1 | mysql-server2 | 2016-01-01 | 100 | 10 |
| 5000001 | mysql-server3 | 2016-01-02 | 100 | 10 |
+---------+---------------+------------+------+------+
rows in set (0.02 sec)
可見無法插入資料,但不影響讀取資料。
至此,MyCAT實現MySQL的讀寫分離部署測試完畢。
總結:
- 其實,剛開始配置的是readHost節點,配置如下:
<dataHost name="localhost1" maxCon="1000" minCon="10" balance="1"
writeType="0" dbType="mysql" dbDriver="native" switchType="-1" slaveThreshold="100">
<heartbeat>select user()</heartbeat>