MySQL 高可用：mysql+mycat实现数据库分片（分库分表）

男娘i 2023-10-17 15:51 110阅读 0赞

**什么是MYCAT：**

一个彻底开源的，面向企业应用开发的大数据库集群

支持事务、ACID、可以替代MySQL的加强版数据库

一个可以视为MySQL集群的企业级数据库，用来替代昂贵的Oracle集群

一个融合内存缓存技术、NoSQL技术、HDFS大数据的新型SQL Server

结合传统数据库和新型分布式数据仓库的新一代企业级数据库产品

一个新颖的数据库中间件产品

**Mycat关键特性 ：**  
  
支持SQL92标准

遵守Mysql原生协议，跨语言，跨平台，跨数据库的通用中间件代理。

基于心跳的自动故障切换，支持读写分离，支持MySQL主从，以及galera cluster集群。

支持Galera for MySQL集群，Percona Cluster或者MariaDB cluster

基于Nio实现，有效管理线程，高并发问题。

支持数据的多片自动路由与聚合，支持sum,count,max等常用的聚合函数,支持跨库分页。

支持单库内部任意join，支持跨库2表join，甚至基于caltlet的多表join。

支持通过全局表，ER关系的分片策略，实现了高效的多表join查询。

支持多租户方案。

支持分布式事务（弱xa）。

支持全局序列号，解决分布式下的主键生成问题。

分片规则丰富，插件化开发，易于扩展。

强大的web，命令行监控。

支持前端作为mysq通用代理，后端JDBC方式支持Oracle、DB2、SQL Server 、 mongodb 、巨杉。

支持密码加密

支持服务降级

支持IP白名单

支持SQL黑名单、sql注入攻击拦截

支持分表（1.6）

集群基于ZooKeeper管理，在线升级，扩容，智能优化，大数据处理（2.0开发版）。

（[官方说明参考：Mycat 数据库分库分表中间件][Mycat] ）

**JDK 下载（建议要求jdk7及以上）：**

[http://www.oracle.com/technetwork/java/javase/downloads/java-archive-downloads-javase7-521261.html][http_www.oracle.com_technetwork_java_javase_downloads_java-archive-downloads-javase7-521261.html]

Linux x86147.68 MB jdk-7u80-linux-i586.tar.gz  
  
  
**MyCAT 相关：**

Mycat 捐赠地址：[http://www.mycat.io/donate.html][http_www.mycat.io_donate.html]

Mycat 官斱网站：[http://www.mycat.io/][http_www.mycat.io]

Mycat 源码：[https://github.com/MyCATApache/Mycat-Server][https_github.com_MyCATApache_Mycat-Server]

Mycat 下载地址：[https://github.com/MyCATApache/Mycat-download][https_github.com_MyCATApache_Mycat-download]

**既然 mycat 那么强大，那就测试看看：**

![20160413222108878][]

**\#测试环境：**

\# 有3张表 users,item,item\_detail (item 的子表) 和 3 个数据库 db01,db02,db03

\# 表 users 存储在数据库 db01, 表 item 和 item\_detail 分布存储在数据 db01 和 db02

\# 现在在3个数据库都创建相同的表

**\[sql\]** [view plain][] [copy][view plain]

1.  **create****database** db01; 
2.  **create****database** db02; 
3.  **create****database** db03; 
4.  
5.  **CREATE****TABLE** users ( 
6.   id **INT**NOTNULL AUTO\_INCREMENT, 
7.  **name****varchar**(50) NOTNULL**default**'', 
8.   indate DATETIME NOTNULL**default**'0000-00-00 00:00:00', 
9.  **PRIMARY****KEY** (id) 
10. )AUTO\_INCREMENT= 1 ENGINE=InnoDB **DEFAULT** CHARSET=utf8; 
11. 
12. **CREATE****TABLE** item ( 
13.  id **INT**NOTNULL AUTO\_INCREMENT, 
14.  value **INT**NOTNULL**default** 0, 
15.  indate DATETIME NOTNULL**default**'0000-00-00 00:00:00', 
16. **PRIMARY****KEY** (id) 
17. )AUTO\_INCREMENT= 1 ENGINE=InnoDB **DEFAULT** CHARSET=utf8; 
18. 
19. **CREATE****TABLE** item\_detail ( 
20.  id **INT**NOTNULL AUTO\_INCREMENT, 
21.  value **INT**NOTNULL**default** 0, 
22. **name****varchar**(50) NOTNULL**default**'', 
23.  item\_id **INT**NOTNULL, 
24. **PRIMARY****KEY** (id), 
25. **key** (item\_id) 
26. )AUTO\_INCREMENT= 1 ENGINE=InnoDB **DEFAULT** CHARSET=utf8;

**\# JDK 安装配置**

**\[plain\]** [view plain][] [copy][view plain]

1.  cd /usr/local/src 
2.  tar xvf jdk-7u80-linux-i586.tar.gz 
3.  mkdir -p /usr/local/java 
4.  mv /usr/local/src/jdk1.7.0\_80 /usr/local/java/ 
5.  chown -R root:root /usr/local/java 
6.  cd /usr/local/java/

\#配置环境变量

**\[plain\]** [view plain][] [copy][view plain]

1.  vi /etc/profile 
2.  vi ~/.bash\_profile 
3.  
4.  export JAVA\_HOME=/usr/local/java/jdk1.7.0\_80 
5.  export PATH=$PATH:$JAVA\_HOME/bin 
6.  export CLASSPATH=.:$JAVA\_HOME/lib/dt.jar:$JAVA\_HOME/lib/tools.jar

\#设置生效（最好重启系统）

**\[plain\]** [view plain][] [copy][view plain]

1.  source /etc/profile 
2.  source ~/.bash\_profile

\#测试是否安装成功

**\[plain\]** [view plain][] [copy][view plain]

1.  \[root@server1 ~\]\# java -version 
2.  java version "1.7.0\_80" 
3.  Java(TM) SE Runtime Environment (build 1.7.0\_80-b15) 
4.  Java HotSpot(TM) Client VM (build 24.80-b11, mixed mode)

**\# Mycat 安装配置**

**\[plain\]** [view plain][] [copy][view plain]

1.  cd /usr/local/src 
2.  tar xvf Mycat-server-1.5.1-RELEASE-20160405120037-linux.tar.gz 
3.  mv /usr/local/src/mycat /usr/local/ 
4.  
5.  groupadd mycat 
6.  useradd -g mycat mycat 
7.  passwd mycat 
8.  chown -R mycat.mycat /usr/local/mycat

\#添加环境变量

**\[plain\]** [view plain][] [copy][view plain]

1.  vi /etc/profile 
2.  vi ~/.bash\_profile 
3.  
4.  export MYCAT\_HOME=/usr/local/mycat

\#设置生效（最好重启系统）

**\[plain\]** [view plain][] [copy][view plain]

1.  source /etc/profile 
2.  source ~/.bash\_profile

\#服务器名和IP绑定

**\[plain\]** [view plain][] [copy][view plain]

1.  vi /etc/hosts 
2.  192.168.100.50 server1 
3.  127.0.0.1 server1

\# 设置 wrapper.java.command 的java 路径

**( 同时可设置** **-Xmx 和** **-Xms ，参考：** [mycat 启动失败 The specified size exceeds the maximum representable size][mycat _ The specified size exceeds the maximum representable size]**)**

**\[plain\]** [view plain][] [copy][view plain]

1.  vi /usr/local/mycat/conf/wrapper.conf 
2.  
3.  wrapper.java.command=%JAVA\_HOME%/bin/java

\#配置 server.xml 和 schema.xml (本案例配置信息在文章底部)

**\[plain\]** [view plain][] [copy][view plain]

1.  vi /usr/local/mycat/conf/server.xml 
2.  vi /usr/local/mycat/conf/schema.xml

\#启动mycat服务 ./mycat  \{ console | start | stop | restart | status | dump \}

**\[plain\]** [view plain][] [copy][view plain]

1.  /usr/local/mycat/bin/mycat console

**\[plain\]** [view plain][] [copy][view plain]

1.  \#mycat 进程 
2.  ps -ef | grep mycat 
3.  
4.  \#日子信息 
5.  tail -20 /usr/local/mycat/logs/wrapper.log

**测试：**

**\#访问 mycat (凭据参考 /usr/local/mycat/conf/server.xml)**

**\[plain\]** [view plain][] [copy][view plain]

1.  mysql -utest -ptest -h127.0.0.1 -P8066 -DTESTDB

**\[sql\]** [view plain][] [copy][view plain]

\#在 mycat 中插入数据并查询：

**\[sql\]** [view plain][] [copy][view plain]

1.  **insert****into** users(**name**,indate) **values**('kk',now()); 
2.  **insert****into** item(id,value,indate) **values**(1,100,now()); 
3.  **insert****into** item\_detail(value,**name**,item\_id) **values**('pad',40,1); 
4.  **insert****into** item\_detail(value,**name**,item\_id) **values**('phone',50,1); 
5.  
6.  **insert****into** item(id,value,indate) **values**(999,100,now()); 
7.  **insert****into** item\_detail(value,**name**,item\_id) **values**('pad',40,999); 
8.  **insert****into** item\_detail(value,**name**,item\_id) **values**('phone',50,999);

**\[sql\]** [view plain][] [copy][view plain]

1.  mysql> **select** \* **from** users; 
2.  \+\----+------+---------------------+
3.  | id | **name** | indate | 
4.  \+\----+------+---------------------+
5.  | 1 | kk | 2016-04-13 06:28:00 | 
6.  \+\----+------+---------------------+
7.  
8.  mysql> **select** \* **from** item; 
9.  \+\-----+-------+---------------------+
10. | id | value | indate | 
11. \+\-----+-------+---------------------+
12. | 999 | 100 | 2016-04-13 06:34:12 | 
13. | 1 | 100 | 2016-04-13 06:32:58 | 
14. \+\-----+-------+---------------------+
15. 
16. mysql> **select** \* **from** item\_detail; 
17. \+\----+-------+------+---------+
18. | id | value | **name** | item\_id | 
19. \+\----+-------+------+---------+
20. | 1 | 0 | 40 | 999 | 
21. | 2 | 0 | 50 | 999 | 
22. | 1 | 0 | 40 | 1 | 
23. | 2 | 0 | 50 | 1 | 
24. \+\----+-------+------+---------+

\#打开另一个终端，使用mysql账号登陆访问查看表情况

**\[plain\]** [view plain][] [copy][view plain]

1.  mysql -uroot -ptest -p

\#具体的表数据存储情况：

**\[sql\]** [view plain][] [copy][view plain]

1.  \-----------------------------------------
2.  mysql> **select** \* **from** db01.users; 
3.  \+\----+------+---------------------+
4.  | id | **name** | indate | 
5.  \+\----+------+---------------------+
6.  | 1 | kk | 2016-04-13 06:28:00 | 
7.  \+\----+------+---------------------+
8.  
9.  mysql> **select** \* **from** db02.users; 
10. 
11. mysql> **select** \* **from** db03.users; 
12. 
13. \-----------------------------------------
14. 
15. mysql> **select** \* **from** db01.item; 
16. 
17. mysql> **select** \* **from** db02.item; 
18. \+\-----+-------+---------------------+
19. | id | value | indate | 
20. \+\-----+-------+---------------------+
21. | 999 | 100 | 2016-04-13 06:34:12 | 
22. \+\-----+-------+---------------------+
23. 
24. mysql> **select** \* **from** db03.item; 
25. \+\----+-------+---------------------+
26. | id | value | indate | 
27. \+\----+-------+---------------------+
28. | 1 | 100 | 2016-04-13 06:32:58 | 
29. \+\----+-------+---------------------+
30. 
31. \-----------------------------------------
32. 
33. mysql> **select** \* **from** db01.item\_detail; 
34. 
35. mysql> **select** \* **from** db02.item\_detail; 
36. \+\----+-------+------+---------+
37. | id | value | **name** | item\_id | 
38. \+\----+-------+------+---------+
39. | 1 | 0 | 40 | 999 | 
40. | 2 | 0 | 50 | 999 | 
41. \+\----+-------+------+---------+
42. 
43. mysql> **select** \* **from** db03.item\_detail; 
44. \+\----+-------+------+---------+
45. | id | value | **name** | item\_id | 
46. \+\----+-------+------+---------+
47. | 1 | 0 | 40 | 1 | 
48. | 2 | 0 | 50 | 1 | 
49. \+\----+-------+------+---------+

**测试完成！！~数据进行了分库分表！**  
\------------------------------------------------------------------------------------

\------------------------------------------------------------------------------------

**\# server.xml 和 schema.xml 配置情况**

**\[plain\]** [view plain][] [copy][view plain]

1.  \# vi /usr/local/mycat/conf/server.xml 
2.  
3.  <?xml version="1.0" encoding="UTF-8"?> 
4.  <!DOCTYPE mycat:server SYSTEM "server.dtd"> 
5.  <mycat:server xmlns:mycat="http://org.opencloudb/"> 
6.   <system> 
7.    
15.  <property name="defaultSqlParser">druidparser</property> 
16.  <property name="mutiNodeLimitType">1</property> 
17.  <property name="serverPort">8066</property> 
18.  <property name="managerPort">9066</property> 
19.  </system> 
20.   
21.  <user name="test"> 
22.  <property name="password">test</property> 
23.  <property name="schemas">TESTDB</property> 
24.  </user> 
25. 
26.  <user name="user"> 
27.  <property name="password">user</property> 
28.  <property name="schemas">TESTDB</property> 
29.  <property name="readOnly">true</property> 
30.  </user> 
31.   
40. </mycat:server>

**\[plain\]** [view plain][] [copy][view plain]

1.  \# vi /usr/local/mycat/conf/schema.xml 
2.  
3.  <?xml version="1.0"?> 
4.  <!DOCTYPE mycat:schema SYSTEM "schema.dtd"> 
5.  <mycat:schema xmlns:mycat="http://org.opencloudb/"> 
6.  
7.    
8.   <schema name="TESTDB" checkSQLschema="false" sqlMaxLimit="100"> 
9.   <table name="users" primaryKey="id" type="global" dataNode="node\_db01" /> 
10. 
11.  <table name="item" primaryKey="id" dataNode="node\_db02,node\_db03" rule="mod-long"> 
12.  <childTable name="item\_detail" primaryKey="id" joinKey="item\_id" parentKey="id" /> 
13.  </table> 
14.  </schema> 
15. 
16.   
17.  <dataNode name="node\_db01" dataHost="dataHost01" database="db01" /> 
18.  <dataNode name="node\_db02" dataHost="dataHost01" database="db02" /> 
19.  <dataNode name="node\_db03" dataHost="dataHost01" database="db03" /> 
20. 
21.   
22.  <dataHost name="dataHost01" maxCon="1000" minCon="10" balance="0" writeType="0" dbType="mysql" dbDriver="native"> 
23.  <heartbeat>select user()</heartbeat> 
24.  <writeHost host="server1" url="127.0.0.1:3306" user="root" password="mysql"/> 
25.  </dataHost> 
26. </mycat:schema>

**其他参考：**

[http://www.csdn.net/article/2015-07-16/2825228][http_www.csdn.net_article_2015-07-16_2825228] （原理及应用）

[http://www.songwie.com/articlelist/50][http_www.songwie.com_articlelist_50]（理论和实践 写的好）  
  
[http://ly.blog.itpub.net/29733787/viewspace-2049139/][http_ly.blog.itpub.net_29733787_viewspace-2049139]（示例） MyCAT安装使用及简单测试

[http://www.cnblogs.com/ivictor/p/5111495.html][http_www.cnblogs.com_ivictor_p_5111495.html]（示例） MyCAT简易入门

[http://www.2cto.com/database/201503/385641.html][http_www.2cto.com_database_201503_385641.html]（示例） Mycat水平分表，垂直分表实践（2）

[http://www.51testing.com/html/34/369434-3686088.html][http_www.51testing.com_html_34_369434-3686088.html]（示例）使用Mycat 做简单的读写分离(一)

来源:http://blog.csdn.net/kk185800961/article/details/51147029

[Mycat]: http://mycat.org.cn/
[http_www.oracle.com_technetwork_java_javase_downloads_java-archive-downloads-javase7-521261.html]: http://www.oracle.com/technetwork/java/javase/downloads/java-archive-downloads-javase7-521261.html
[http_www.mycat.io_donate.html]: http://www.mycat.io/donate.html
[http_www.mycat.io]: http://www.mycat.io/
[https_github.com_MyCATApache_Mycat-Server]: https://github.com/MyCATApache/Mycat-Server
[https_github.com_MyCATApache_Mycat-download]: https://github.com/MyCATApache/Mycat-download
[20160413222108878]: https://img-blog.csdn.net/20160413222108878
[view plain]: http://blog.csdn.net/kk185800961/article/details/51147029#
[mycat _ The specified size exceeds the maximum representable size]: http://blog.csdn.net/kk185800961/article/details/51146576
[http_www.csdn.net_article_2015-07-16_2825228]: http://www.csdn.net/article/2015-07-16/2825228
[http_www.songwie.com_articlelist_50]: http://www.songwie.com/articlelist/50
[http_ly.blog.itpub.net_29733787_viewspace-2049139]: http://ly.blog.itpub.net/29733787/viewspace-2049139/
[http_www.cnblogs.com_ivictor_p_5111495.html]: http://www.cnblogs.com/ivictor/p/5111495.html
[http_www.2cto.com_database_201503_385641.html]: http://www.2cto.com/database/201503/385641.html
[http_www.51testing.com_html_34_369434-3686088.html]: http://www.51testing.com/html/34/369434-3686088.html