3. MyCAT安裝（老男孩Linux MySQL課程筆記）
3.0 介紹
開源組織和社群開發人員在淘寶cobar（TDDL）基礎上二次開發的讀寫分離工具。Mycat後來被愛可生改寫成了DBLE

3.1 預先安裝Java執行環境
yum install -y java

3.2下載
Mycat-server-xxxxx.linux.tar.gz

3.3 解壓檔案
tar xf Mycat-server-*
3.4 軟體目錄結構
ls
bin catlet conf lib logs version.txt

3.5 啟動和連線
3.5.1 配置環境變數
vim /etc/profile
export PATH=/opt/mycat/bin:$PATH
source /etc/profile

3.5.2 啟動
mycat start

3.5.3 連線mycat：
mysql -uroot -p123456 -h 127.0.0.1 -P8066

8.0之後：
mysql -uroot -p123456 -h10.0.0.52 -P8066 --default-auth=mysql_native_password

4. 配置檔案介紹
4.1 bin 目錄
程式目錄
4.2 conf
配置檔案目錄
4.2.1 schema.xml
主配置檔案：節點資訊、讀寫分離、高可用設定、呼叫分片策略..

4.2.2 rule.xml
分片策略的定義、功能、使用用方法

4.2.3 server.xml
mycat服務有關配置： 使用者、網路、許可權、策略、資源...

4.2.4 xx.txt檔案
分片引數定義檔案

4.2.5 log4j2.xml
Mycat 相關日誌記錄配置

4.3 logs
wrapper.log : 啟動日誌
mycat.log ：工作日誌

========================
++++++Mycat核心應用+++++++

1. schema.xml配置檔案結構
[root@db01 conf]# cd /opt/mycat/conf/
mv schema.xml schema.xml.bak
vim schema.xml

# 邏輯庫：
<schema name="TESTDB" checkSQLschema="false" sqlMaxLimit="100" dataNode="dn1">
</schema>
# DN資料節點（邏輯分片）：資料節點（邏輯分片）：
<dataNode name="dn1" dataHost="localhost1" database= "world" />
作用：
垂直和水平查分。
# DH 資料主機
作用： 高可用和讀寫分離
<dataHost name="localhost1" maxCon="1000" minCon="10" balance="1" writeType="0" dbType="mysql" dbDriver="native" switchType="1">
<heartbeat>select user()</heartbeat>
<writeHost host="db1" url="10.0.0.51:3307" user="root" password="123">
<readHost host="db2" url="10.0.0.51:3309" user="root" password="123" />
</writeHost>
</dataHost>
</mycat:schema>

====================================
<?xml version="1.0"?>
<!DOCTYPE mycat:schema SYSTEM "schema.dtd">
<mycat:schema xmlns:mycat="http://io.mycat/">

# 1.邏輯庫配置
<schema name="TESTDB" checkSQLschema="false" sqlMaxLimit="100" dataNode="dn1">
</schema>

# 2. DN，分片定義
<dataNode name="dn1" dataHost="localhost1" database= "world" />


#3. DH節點定義
<dataHost name="localhost1" maxCon="1000" minCon="10" balance="1" writeType="0" dbType="mysql" dbDriver="native" switchType="1">
<heartbeat>select user()</heartbeat>
<writeHost host="db1" url="10.0.0.51:3307" user="root" password="123">
<readHost host="db2" url="10.0.0.51:3309" user="root" password="123" />
</writeHost>
</dataHost>

</mycat:schema>

==================配置檔案模板============================
<?xml version="1.0"?>
<!DOCTYPE mycat:schema SYSTEM "schema.dtd">
<mycat:schema xmlns:mycat="http://io.mycat/">
<schema name="TESTDB" checkSQLschema="false" sqlMaxLimit="100" dataNode="dn1">
</schema>
<dataNode name="dn1" dataHost="localhost1" database= "world" />
<dataHost name="localhost1" maxCon="1000" minCon="10" balance="1" writeType="0" dbType="mysql" dbDriver="native" switchType="1">
<heartbeat>select user()</heartbeat>
<writeHost host="db1" url="10.0.0.51:3307" user="root" password="123">
<readHost host="db2" url="10.0.0.51:3309" user="root" password="123" />
</writeHost>
</dataHost>
</mycat:schema>
===========================================================

2. 測試環境準備
db01:

mysql -S /data/3307/mysql.sock -e "source /root/world.sql"
mysql -S /data/3308/mysql.sock -e "source /root/world.sql"

重啟mycat
mycat restart

3. 讀寫分離測試
# 測試讀
mysql -uroot -p123456 -h 10.0.0.52 -P8066 --default-auth=mysql_native_password -e "select @@server_id;"
# 測試寫
mysql -uroot -p123456 -h 10.0.0.52 -P8066 --default-auth=mysql_native_password -e "begin ; select @@server_id;commit;"

4. 配置讀寫分離及高可用

[root@db01 conf]# mv schema.xml schema.xml.rw
[root@db01 conf]# vim schema.xml
<?xml version="1.0"?>
<!DOCTYPE mycat:schema SYSTEM "schema.dtd">
<mycat:schema xmlns:mycat="http://io.mycat/">
<schema name="TESTDB" checkSQLschema="false" sqlMaxLimit="100" dataNode="sh1">
</schema>
<dataNode name="sh1" dataHost="oldguo1" database= "world" />
<dataHost name="oldguo1" maxCon="1000" minCon="10" balance="1" writeType="0" dbType="mysql" dbDriver="native" switchType="1">
<heartbeat>select user()</heartbeat>
<writeHost host="db1" url="10.0.0.51:3307" user="root" password="123">
<readHost host="db2" url="10.0.0.51:3309" user="root" password="123" />
</writeHost>
<writeHost host="db3" url="10.0.0.52:3307" user="root" password="123">
<readHost host="db4" url="10.0.0.52:3309" user="root" password="123" />
</writeHost>
</dataHost>
</mycat:schema>

primary writehost ：負責寫操作的writehost
standby writeHost ：和readhost一樣，只提供讀服務

當寫節點宕機後，後面跟的readhost也不提供服務，這時候standby的writehost就提供寫服務，
後面跟的readhost提供讀服務

測試讀寫分離：

mycat restart
# 測試讀
mysql -uroot -p123456 -h 10.0.0.52 -P8066 --default-auth=mysql_native_password -e "select @@server_id;"
# 測試寫
mysql -uroot -p123456 -h 10.0.0.52 -P8066 --default-auth=mysql_native_password -e "begin ; select @@server_id;commit;"

測試高可用：
[root@db01 conf]# systemctl stop mysqld3307
mysql -uroot -p123456 -h 10.0.0.52 -P8066 --default-auth=mysql_native_password -e "select @@server_id;"
mysql -uroot -p123456 -h 10.0.0.52 -P8066 --default-auth=mysql_native_password -e "begin ; select @@server_id;commit;"

[root@db01 conf]# systemctl start mysqld3307
mysql -uroot -p123456 -h 10.0.0.52 -P8066 --default-auth=mysql_native_password -e "select @@server_id;"
mysql -uroot -p123456 -h 10.0.0.52 -P8066 --default-auth=mysql_native_password -e "begin ; select @@server_id;commit;"

5. 引數介紹
5.1 balance屬性
讀操作負載均衡型別，目前的取值有3種：
1. balance="0", 不開啟讀寫分離機制，所有讀操作都發送到當前可用的writeHost上。
2. balance="1"，全部的readHost與standby writeHost參與select語句的負載均衡，簡單的說，
當雙主雙從模式(M1->S1，M2->S2，並且M1與 M2互為主備)，正常情況下，M2,S1,S2都參與select語句的負載均衡。
3. balance="2"，所有讀操作都隨機的在writeHost、readhost上分發。

5.2 writeType屬性
寫操作，負載均衡型別，目前的取值有2種：
1. writeType="0", 所有寫操作傳送到配置的第一個writeHost，
第一個掛了切到還生存的第二個writeHost，重新啟動後已切換後的為主，切換記錄在配置檔案中:dnindex.properties .
2. writeType=“1”，所有寫操作都隨機的傳送到配置的writeHost，但不推薦使用

5.3 switchType屬性
-1 表示不自動切換
1 預設值，自動切換
2 基於MySQL主從同步的狀態決定是否切換 ，心跳語句為 show slave status
datahost其他配置

5.4 連線有關
maxCon="1000"：最大的併發連線數
minCon="10" ：mycat在啟動之後，會在後端節點上自動開啟的連線執行緒

5.5 tempReadHostAvailable="1"
這個一主一從時（1個writehost，1個readhost時），可以開啟這個引數，如果2個writehost，2個readhost時
<heartbeat>select user()</heartbeat> 監測心跳

6. Mycat 分散式架構--垂直分表
taobao庫: user （sh1），order_t(sh2) ,others(sh3)

mv schema.xml schema.xml.ha
vim schema.xml
<?xml version="1.0"?>
<!DOCTYPE mycat:schema SYSTEM "schema.dtd">
<mycat:schema xmlns:mycat="http://io.mycat/">
<schema name="TESTDB" checkSQLschema="false" sqlMaxLimit="100" dataNode="sh1">
<table name="user" dataNode="sh1"/>
<table name="order_t" dataNode="sh2"/>
</schema>
<dataNode name="sh1" dataHost="oldguo1" database= "taobao" />
<dataNode name="sh2" dataHost="oldguo2" database= "taobao" />
<dataHost name="oldguo1" maxCon="1000" minCon="10" balance="1" writeType="0" dbType="mysql" dbDriver="native" switchType="1">
<heartbeat>select user()</heartbeat>
<writeHost host="db1" url="10.0.0.51:3307" user="root" password="123">
<readHost host="db2" url="10.0.0.51:3309" user="root" password="123" />
</writeHost>
<writeHost host="db3" url="10.0.0.52:3307" user="root" password="123">
<readHost host="db4" url="10.0.0.52:3309" user="root" password="123" />
</writeHost>
</dataHost>

<dataHost name="oldguo2" maxCon="1000" minCon="10" balance="1" writeType="0" dbType="mysql" dbDriver="native" switchType="1">
<heartbeat>select user()</heartbeat>
<writeHost host="db1" url="10.0.0.51:3308" user="root" password="123">
<readHost host="db2" url="10.0.0.51:3310" user="root" password="123" />
</writeHost>
<writeHost host="db3" url="10.0.0.52:3308" user="root" password="123">
<readHost host="db4" url="10.0.0.52:3310" user="root" password="123" />
</writeHost>
</dataHost>

</mycat:schema>

建立測試庫和表:
mysql -S /data/3307/mysql.sock -e "create database taobao charset utf8;"
mysql -S /data/3308/mysql.sock -e "create database taobao charset utf8;"

mysql -S /data/3307/mysql.sock -e "use taobao;create table user(id int,name varchar(20))";
mysql -S /data/3308/mysql.sock -e "use taobao;create table order_t(id int,name varchar(20))"

# 重啟mycat
mycat restart

# mycat中對user 和 order 資料插入
mysql -uroot -p123456 -h 10.0.0.52 -P 8066 --default-auth=mysql_native_password
insert into user values(1,'a');
insert into user values(2,'b');
insert into user values(3,'c');
commit;

insert into order_t values(1,'x'),(2,'y');
commit;

[root@db01 conf]# mysql -S /data/3307/mysql.sock -e "show tables from taobao"
+------------------+
| Tables_in_taobao |
+------------------+
| user |
+------------------+
[root@db01 conf]# mysql -S /data/3308/mysql.sock -e "show tables from taobao"
+------------------+
| Tables_in_taobao |
+------------------+
| order_t |
+------------------+
[root@db01 conf]# mysql -S /data/3307/mysql.sock -e "select * from taobao.user"
+------+------+
| id | name |
+------+------+
| 1 | a |
| 2 | b |
| 3 | c |
+------+------+
[root@db01 conf]# mysql -S /data/3308/mysql.sock -e "select * from taobao.order_t"
+------+------+
| id | name |
+------+------+
| 1 | x |
| 2 | y |
+------+------+
[root@db01 conf]#

7. Mycat 分散式架構--水平拆分
7.0 重要概念
# 1. 分片策略 ：幾乎融合經典業務中大部分的分片策略。Mycat已經開發了相應演算法，非常方便呼叫。
範圍分片
取模
列舉
日期
HASH
等。
# 2.分片鍵： 作為分片條件的列。

7.1 範圍分片(range)
比如說t3表

(1)行數非常多，2000w（1-1000w:sh1 1000w01-2000w:sh2）
(2)訪問非常頻繁，使用者順序訪問較多

# 1. 修改schema.xml檔案，定製分片策略
cp schema.xml schema.xml.1
vim schema.xml
新增：
<table name="t3" dataNode="sh1,sh2" rule="auto-sharding-long" />

# 2. 定義和使用分片策略
vim rule.xml

<tableRule name="auto-sharding-long">
<rule>
<columns>id</columns>
<algorithm>rang-long</algorithm>
</rule>

<function name="rang-long"
class="io.mycat.route.function.AutoPartitionByLong">
<property name="mapFile">autopartition-long.txt</property>
</function>

# 3. 定義範圍

vim autopartition-long.txt
0-10=0
10-20=1

4. 建立測試表：
mysql -S /data/3307/mysql.sock -e "use taobao;create table t3 (id int not null primary key auto_increment,name varchar(20) not null);"
mysql -S /data/3308/mysql.sock -e "use taobao;create table t3 (id int not null primary key auto_increment,name varchar(20) not null);"

5. 測試：
重啟mycat
mycat restart
mysql -uroot -p123456 -h 10.0.0.52 -P 8066 --default-auth=mysql_native_password
insert into t3(id,name) values(1,'a');
insert into t3(id,name) values(2,'b');
insert into t3(id,name) values(3,'c');
insert into t3(id,name) values(4,'d');
insert into t3(id,name) values(11,'aa');
insert into t3(id,name) values(12,'bb');
insert into t3(id,name) values(13,'cc');
insert into t3(id,name) values(14,'dd');

[root@db01 conf]# mysql -S /data/3308/mysql.sock -e "select * from taobao.t3"
[root@db01 conf]# mysql -S /data/3307/mysql.sock -e "select * from taobao.t3"

7.2 取模分片

1%3 1
2%3 2
3%3 0
4%3 1
5%3 2
任何正整數數字和N（正整數）取模，得的值永遠都是 0~N-1

id % 分片數量取模
N % 5 = 0-4 idx

取餘分片方式：分片鍵（一個列）與節點數量進行取餘，得到餘數，將資料寫入對應節點

# 1. 修改配置檔案
vim schema.xml

<table name="t4" dataNode="sh1,sh2" rule="mod-long" />

# 2. 檢視和定義分片使用
vim rule.xml
<property name="count">2</property>

# 3. 準備測試環境

建立測試表：
mysql -S /data/3307/mysql.sock -e "use taobao;create table t4 (id int not null primary key auto_increment,name varchar(20) not null);"
mysql -S /data/3308/mysql.sock -e "use taobao;create table t4 (id int not null primary key auto_increment,name varchar(20) not null);"

重啟mycat
mycat restart

# 4. 測試：
[root@db01 ~]# mysql -uroot -p123456 -h 10.0.0.52 -P8066 --default-auth=mysql_native_password

use TESTDB
insert into t4(id,name) values(1,'a');
insert into t4(id,name) values(2,'b');
insert into t4(id,name) values(3,'c');
insert into t4(id,name) values(4,'d');
insert into t4(id,name) values(6,'x'),(8,'y'),(10,'z');

分別登入後端節點查詢資料
mysql -S /data/3308/mysql.sock -e "select * from taobao.t4"
mysql -S /data/3307/mysql.sock -e "select * from taobao.t4"

7.3 列舉分片 (區域、zone)
t5 表
id name telnum
1 bj 1212
2 sh 22222
3 bj 3333
4 sh 44444
5 bj 5555

sharding-by-intfile

# 1. 設計分片策略
vim schema.xml
<table name="t5" dataNode="sh1,sh2" rule="sharding-by-intfile" />

# 2. 應用分片策略

vim rule.xml

<tableRule name="sharding-by-intfile">
<rule>
<columns>name</columns>
<algorithm>hash-int</algorithm>
</rule>
</tableRule>

<function name="hash-int" class="org.opencloudb.route.function.PartitionByFileMap">
<property name="mapFile">partition-hash-int.txt</property>
<property name="type">1</property>
</function>

vim partition-hash-int.txt 配置：
bj=0
sh=1
DEFAULT_NODE=1

# 3. 準備測試環境

mysql -S /data/3307/mysql.sock -e "use taobao;create table t5 (id int not null primary key auto_increment,name varchar(20) not null);"
mysql -S /data/3308/mysql.sock -e "use taobao;create table t5 (id int not null primary key auto_increment,name varchar(20) not null);"

重啟mycat
mycat restart

# 4. 插入測試資料：

mysql -uroot -p123456 -h10.0.0.52 -P8066 --default-auth=mysql_native_password
use TESTDB
insert into t5(id,name) values(1,'bj');
insert into t5(id,name) values(2,'sh');
insert into t5(id,name) values(3,'bj');
insert into t5(id,name) values(4,'sh');
insert into t5(id,name) values(5,'tj');

mysql -S /data/3308/mysql.sock -e "select * from taobao.t5"
mysql -S /data/3307/mysql.sock -e "select * from taobao.t5"

7.4 Mycat全域性表
a b c d .....
join

t

a
id name age

1 zs 18 sh1
id addr aid
1001 bj 1
1002 sh 2

2 ls 19 sh2
id addr aid
1001 bj 1
1002 sh 2

t
id addr aid
1001 bj 1
1002 sh 2

使用場景：
如果你的業務中有些資料類似於資料字典，比如配置檔案的配置，
常用業務的配置或者資料量不大很少變動的表，這些表往往不是特別大，
而且大部分的業務場景都會用到，那麼這種表適合於Mycat全域性表，無須對資料進行切分，
要在所有的分片上儲存一份資料即可，Mycat 在Join操作中，業務表與全域性表進行Join聚合會優先選擇相同分片內的全域性表join，
避免跨庫Join，在進行資料插入操作時，mycat將把資料分發到全域性表對應的所有分片執行，在進行資料讀取時候將會隨機獲取一個節點讀取資料。

# 1. 設定全域性表策略
vim schema.xml
<table name="t_area" primaryKey="id" type="global" dataNode="sh1,sh2" />

# 2. 後端資料準備
mysql -S /data/3307/mysql.sock -e "use taobao;create table t_area (id int not null primary key auto_increment,name varchar(20) not null);"
mysql -S /data/3308/mysql.sock -e "use taobao;create table t_area (id int not null primary key auto_increment,name varchar(20) not null);"

重啟mycat
mycat restart

# 3. 測試：
mysql -uroot -p123456 -h10.0.0.52 -P8066 --default-auth=mysql_native_password

use TESTDB
insert into t_area(id,name) values(1,'a');
insert into t_area(id,name) values(2,'b');
insert into t_area(id,name) values(3,'c');
insert into t_area(id,name) values(4,'d');
mysql -S /data/3308/mysql.sock -e "select * from taobao.t_area"
mysql -S /data/3307/mysql.sock -e "select * from taobao.t_area"

本文來自部落格園老男孩的部落格，作者：老男孩老師，轉載請務必註明原文連結：https://www.cnblogs.com/oldboy666/p/15669115.html