1500字范文 > MySQL使用MyCat实现分库分表

MySQL使用MyCat实现分库分表

时间：2020-07-12 10:04:40

相关推荐

MySQL使用MyCat实现分库分表

MySQL分库分表的实现方式有：

shardingJDBC：基于AOP原理，在应用程序中对本地执行的SQL进行拦截，解析、改写、路由处理。需要自行编码配置实现，只支持java语言，性能较高。MyCat：数据库分库分表中间件，不用调整代码即可实现分库分表，支持多种语言,性能不及前者。

这里使用的是MyCat

mycat2官网地址:MyCat2

mycat只需要在一台服务器上安装即可，安装的服务器也称为中间件服务器。

我这里是在虚拟机上进行的，一共3台服务器，192.168.168.100，192.168.168.101，192.168.168.102

3台服务器上都需要安装mysql（安装mysql：Linux安装MySQL_生骨大头菜的博客-CSDN博客），只需要在192.168.168.100上安装mycat和jdk

1.安装jdk

如果系统没有安装jdk，需要先安装：linux安装java_生骨大头菜的博客-CSDN博客_java安装linux

2.下载安装包并且解压

地址：/MyCATApache/Mycat-download/tree/master/1.6-RELEASE

将下载好的文件上传到服务器的/usr/mycat目录下

# 进入mycat文件夹cd /usr/mycat# 解压tar -zxvf Mycat-server-1.6-RELEASE-1028204710-linux.tar.gz -C /usr/local/

cd /usr/local/ll

进入mycat可以看到文件及文件夹

3.设置分片配置

cd conf/ll

分片配置文件是schema.xml ，删除不需要的部分进行精简

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"><table name="travelrecord" dataNode="dn1,dn2,dn3" rule="auto-sharding-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="localhost:3316" user="root" password="123456" /></dataHost></mycat:schema>

编辑相关配置：

<?xml version="1.0"?><!DOCTYPE mycat:schema SYSTEM "schema.dtd"><mycat:schema xmlns:mycat="http://io.mycat/"><schema name="DB01" checkSQLschema="true" sqlMaxLimit="100"><table name="TB_ORDER" dataNode="dn1,dn2,dn3" rule="auto-sharding-long" /></schema><dataNode name="dn1" dataHost="dhost1" database="db01" /><dataNode name="dn2" dataHost="dhost2" database="db01" /><dataNode name="dn3" dataHost="dhost3" database="db01" /><dataHost name="dhost1" maxCon="1000" minCon="10" balance="0"writeType="0" dbType="mysql" dbDriver="jdbc" switchType="1" slaveThreshold="100"><heartbeat>select user()</heartbeat><writeHost host="master" url="jdbc:mysql://192.168.168.100:3306?useSSL=false&serverTimezone=Asia/Shanghai&characterEncoding=utf8" user="root" password="root" /></dataHost><dataHost name="dhost2" maxCon="1000" minCon="10" balance="0"writeType="0" dbType="mysql" dbDriver="jdbc" switchType="1" slaveThreshold="100"><heartbeat>select user()</heartbeat><writeHost host="master" url="jdbc:mysql://192.168.168.101:3306?useSSL=false&serverTimezone=Asia/Shanghai&characterEncoding=utf8" user="root" password="root" /></dataHost><dataHost name="dhost3" maxCon="1000" minCon="10" balance="0"writeType="0" dbType="mysql" dbDriver="jdbc" switchType="1" slaveThreshold="100"><heartbeat>select user()</heartbeat><writeHost host="master" url="jdbc:mysql://192.168.168.102:3306?useSSL=false&serverTimezone=Asia/Shanghai&characterEncoding=utf8" user="root" password="root" /></dataHost></mycat:schema>

配置server.xml，配置mycat的用户及用户的权限信息

<user name="root"><property name="password">123456</property><property name="schemas">DB01</property></user><user name="user"><property name="password">123456</property><property name="schemas">DB01</property><property name="readOnly">true</property></user>

4.启动mycat服务

# /usr/local/mycat/为mycat的安装目录# 启动/usr/local/mycat/bin/mycat start# 停止/usr/local/mycat/bin/mycat stop

mycat启动之后，占用的端口号8806

查看是否启动成功

tail -f /usr/local/mycat/logs/wrapper.log

如果这时提示错误：

原因为缺少驱动，可以下载相应的驱动：/archives/c-j/

上传到/usr/local/mycat/lib进行解压，取出文件夹里jar文件

# 授权chmod 777 mysql-connector-java-5.1.49.jar

/usr/local/mycat/bin/mycat stop/usr/local/mycat/bin/mycat starttail -f /usr/local/mycat/logs/wrapper.log

看到这句话证明正常启动了

5.登录mycat服务

mysql -h 192.168.168.100 -P 8066 -uroot -p123456

show databases;

可以看到对应的逻辑数据库以及表

创表并插入数据

CREATE TABLE TB_ORDER (id BIGINT(20) NOT NULL,title VARCHAR(100) NOT NULL,PRIMARY KEY(id))ENGINE=INNODB DEFAULT CHARSET=utf8;

可以在Navicat工具上看到每台虚拟机的数据库都有这张表了

INSERT INTO TB_ORDER(id,title) VALUES(1,'goods1');INSERT INTO TB_ORDER(id,title) VALUES(2,'goods2');INSERT INTO TB_ORDER(id,title) VALUES(3,'goods3');INSERT INTO TB_ORDER(id,title) VALUES(1000000, 'goods1000000');INSERT INTO TB_ORDER(id,title) VALUES(10000000, 'goods10000000');INSERT INTO TB_ORDER(id,title) VALUES(10000001, 'goods10000001');

注意：由于分配规则使用的是auto-sharding-long，所以只能插入id<=15000000的数据，如果需要插入这个值以上的就需要增加数据节点，或者修改规则

至此mycat部署已基本完成

如果想更灵活地使用mycat，则需要了解mycat的相关配置文件的使用

6.mycat配置文件

主要有3个：

schema.xml：配置逻辑库逻辑表等相关信息server.xml：mycat运行的服务的信息，例如用户及其权限rule.xml：分片规则的信息

都存放在/usr/local/mycat/conf

6.1.schema.xml

schema.xml作为MyCat中最重要的配置文件之一, 涵盖了MyCat的逻辑库、逻辑表、分片规则、分片节点及数据源的配置。

主要包含以下三组标签:

6.1.1.schema标签

schema标签用于定义MyCat实例中的逻辑库,一个MyCat实例中, 可以有多个逻辑库,可以通过schema标签来划分不同的逻辑库。 MyCat中的逻辑库的概念，等同于MySQL 中的database概念,需要操作某个逻辑库下的表时,也需要切换逻辑库(use xxx)。

核心属性:

name:指定自定义的逻辑库库名checkSQLschema:在SQL语句操作时指定了数据库名称，执行时是否自动去除; true: 自动去除，false: 不自动去除sqlMaxLimit:如果未指定limit进行查询，列表查询模式查询多少条记录

table标签

table标签定义了MyCat中逻辑库schema'下的逻辑表,所有需要拆分的表都需要在table标签中定义。

核心属性:

name:定义逻辑表表名，在该逻辑库下唯一dataNode: 定义逻辑表所属的dataNode, 该属性需要与dataNode标签中name对应;多个dataNode逗号分隔rule:分片规则的名字，分片规则名字是在rule.xml中定义的primaryKey:逻辑表对应真实表的主键type:逻辑表的类型，目前逻辑表只有全局表和普通表，如果未配置，就是普通表；全局表，配置为global

6.1.2. dataNode标签

dataNode标签中定义了MyCat中的数据节点,也就是我们通常说的数据分片。一个dataNode标签就是-个独立的数据分片。

核心属性:

name:定义数据节点名称dataHost: 数据库实例主机名称，引用自dataHost标签中name属性database:定义分片所属数据库

6.1.3.datahost栋签

该标签在MyCat逻辑库中作为底层标签存在,直接定义了具体的数据库实例、读写分离、心跳语句。

核心属性:

name:唯一标识，供上层标签使用maxCon/minCon: 最大连接数/最小连接数balance: 负载均衡策略，取值0,1,2,3writeType: 写操作分发方式(0:写操作转发到第一个writeHost，第一个挂了，切换到第二个; 1:写操作随机分发到配置的writeHost)dbDriver:数据库驱动，支持native、jdbc