利用mycat管理mysql的集群的管理

Dear 丶 2022-05-25 14:23 162阅读 0赞

Mycat是什么：

Mycat是一个 数据库的中间件，支持 SQL92标准

支持MySQL、Oracle、DB2、SQLServer、PostgreSQL等DB的常见SQL语法

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

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

首先在github上下载Mycat-Server的源代码：

https://github.com/MyCATApache/Mycat-Server

找到 项目当中的 MycatStartup.java  这个文件是一个入口文件，等下会用到。

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

接下来演示mycat对mysql中的一张表进行垂直分表（单数据库大表拆分）的操作，即将一张表映射到mysql当中的三张表上

首先在某台服务器的mysql当中建立一张表如下图：

表名：  company1

![70][]

然后把company1这张表复制2份

表名： company2

表名： company3

![70][]

在navicat当中是这样的：

![70 1][]

然后回到  Mycat-Server这个项目中进行对应的配置：

看到  server.xml文件中的 <user 这个标签的配置

![70 2][]

记下这里的 password和schemas，等下使用  navicat连接

然后过来配置  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">
    		<table name="company" subTables="company$1-3" dataNode="dn1" rule="mod-long" />
    	</schema>
    	
    	
    	<dataNode name="dn1" dataHost="localhost1" database="test" />
    
    	<dataHost name="localhost1" maxCon="1000" minCon="10" balance="0"
    			  writeType="0" dbType="mysql" dbDriver="native" switchType="1"  slaveThreshold="100">
    
    		<heartbeat>select user()</heartbeat>
    		
    		
    		<writeHost host="hostS1" url="192.168.159.136:3306" user="root"
    				   password="root" />
    
    	</dataHost>
    
    	
    </mycat:schema>

然后把 MyCat-Server.java中的 MyCatStartUp.java这个文件运行一下

运行，在navicat控制端连接mycat

![70 3][]

连接之后发现 TESTDB这个模拟库和  company 这个mycat中的模拟表

![70 4][]![70 5][]![70 6][]

然后点击Mycat-Server中的查询-->新建查询,然后在控制台执行下面的语句：

INSERT INTO \`company2\` VALUES ('1', '华为');  
INSERT INTO \`company3\` VALUES ('2', '中兴');  
INSERT INTO \`company1\` VALUES ('3', 'OPPO');  
INSERT INTO \`company2\` VALUES ('4', '百度');  
INSERT INTO \`company3\` VALUES ('5', '小米');

INSERT INTO \`company1\` VALUES ('6', '阿里');

然后看实际数据库表中的数据，已经被mycat分流到不同的 company1、company2、company3表当中了如下图：

company1：

![70 7][]

company2：

![70 8][]

company3：

![70 9][]

然后继续在控制台执行下面的语句：

explain select \* from company;

可以看到下面的信息：

![70 10][]

发现sql解释执行计划会遍历所有的表

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

接下来演示下跨数据库分表的问题：

在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">
    
    		<table name="company" subTables="company$1-3" dataNode="dn1" rule="mod-long" />
    		<table name="record"  dataNode="dn1,dn2,dn3" rule="mod-long" />
    
    	</schema>
    
    
    	<dataNode name="dn1" dataHost="localhost1" database="db1" />
    	<dataNode name="dn2" dataHost="localhost1" database="db2" />
    	<dataNode name="dn3" dataHost="localhost1" database="db3" />
    
    
    	<dataHost name="localhost1" maxCon="1000" minCon="10" balance="0"
    			  writeType="0" dbType="mysql" dbDriver="native" switchType="1"  slaveThreshold="100">
    
    		<heartbeat>select user()</heartbeat>
    
    		<writeHost host="hostS1" url="192.168.159.136:3306" user="root"
    				   password="root" />
    
    	</dataHost>
    
    
    </mycat:schema>

然后再192.168.159.136这台服务器上面建立三个 数据库 分别为  db1、db2、db3

![70 11][]

![70 12][]

配置完成后运行 MycatStartup.java 这个文件：

然后再在  Mycay-server.java  当中发起一个查询：

![70 13][]

输入下面的建表语句

CREATE TABLE \`record\` (  
  \`id\` varchar(32) DEFAULT NULL,  
  \`record\_name\` varchar(255) DEFAULT NULL

) ENGINE=InnoDB DEFAULT CHARSET=utf8;

然后会发现在 管理配置的192.168.159.136这台服务器上出现了 schema.xml当中配置的record这张表，并且分配给了不同的三个数据库  db1、db2、db3

![70 14][]

再次在Mycat-Server这个虚拟库下新建一个查询

![70 15][]

insert into record(id,record\_name)value(1,"hahaha");  
insert into record(id,record\_name)value(2,"hehehe");

insert into record(id,record\_name)value(3,"gagaga");

然后可以再其他三个库当中看到record记录被分片路由，最后存储到三个不同的库，如下图所示:

db1中:

![70 16][]

db2中：

![70 17][]

db3中：

![70 18][]

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

接下来演示下mycat当中的读写分离：

<?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" />
    
    
    	<dataNode name="dn1" dataHost="localhost1" database="DB" />
    	
    
    
    	<dataHost name="localhost1" maxCon="1000" minCon="10" balance="0"
    			  writeType="0" dbType="mysql" dbDriver="native" switchType="1"  slaveThreshold="100">
    
    		<heartbeat>show slave status</heartbeat>
    
    		<writeHost host="hostM1" url="192.168.159.136:3306" user="root"
    				   password="root" >
    			<readHost host="hostS1" url="192.168.159.135:3306" password="root" user="root" />
    		</writeHost>
    
    		
    
    	</dataHost>
    
    
    </mycat:schema>

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

[70]: /images/20220525/4ec7724e95df4ec086575c9a06588e22.png
[70 1]: /images/20220525/d23151fbf03d4f508f254a9eb549f7bf.png
[70 2]: /images/20220525/8f4e679e9ded4ba49d4e5a5bfba4fea8.png
[70 3]: /images/20220525/cd90e7369c8144b68b4b69acac650033.png
[70 4]: https://img-blog.csdn.net/20180516104900626?watermark/2/text/aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JhaWR1XzI0NTQ1OTAx/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70
[70 5]: https://img-blog.csdn.net/20180516105431528?watermark/2/text/aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JhaWR1XzI0NTQ1OTAx/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70
[70 6]: /images/20220525/200a6f69b04041c9a9c1522e791ba1a7.png
[70 7]: /images/20220525/010647808c144d5a8314f1528e57cc2a.png
[70 8]: /images/20220525/a6f09f4682144a2f9473142b1a1ea916.png
[70 9]: /images/20220525/8593494a65184a43a35abc7a8152ac4f.png
[70 10]: /images/20220525/e24d26bce0e84bc09eb1cdbbd9c2869a.png
[70 11]: /images/20220525/8f206545f338427fba851d2280bdac02.png
[70 12]: /images/20220525/cdde4dd98c084c5abe15c1bed76195b7.png
[70 13]: /images/20220525/1fb88fecc4b6479f926f247d45b8e398.png
[70 14]: /images/20220525/74415217a38847fc98d5f7de7afd4cbf.png
[70 15]: /images/20220525/ef34bf87f39447b8bdf04e01d52c03d1.png
[70 16]: /images/20220525/90b4fe2c000e4dd2b9d13bad56f4a665.png
[70 17]: /images/20220525/cbba9dec69c14abf87285ae8269ea590.png
[70 18]: /images/20220525/ae07f71d935f473d9b0df8da53014113.png