.jpg)
.jpg)
.jpg)
.jpg)
简介
MyCat是基于mysql 数据库 的分布式中间件，支持MySQL数据库分库分表，读写分离等。
配置安装流程
本文选用华为鲲鹏 云服务 ECS KC1实例做测试，KC1实例的处理器为兼容ARMv8指令集的鲲鹏920，使用的操作系统为Euler 2.8，内核版本号为：4.19.36。
1.准备环境
选择操作环境
本文选用华为鲲鹏云服务ECS KC1实例做测试
Java版本需要在“1.8.0”及上版本。
您可以通过执行下面命令，安装“java 1.8.0”。
sudo yum install java-1.8.0-openjdk
环境中已运行mysql服务，并且要预先创建好相应的库和表。
db01
只有一个user表
db02
item表
db03
item表
db02和db03上的item根据id%2取摸保存数据，也就是进行数据分片。
执行下面命令，生成上面的库表：
a.连接MySQL数据库。
mysql -uroot -p[PASSWORD]
b.执行以下SQL语句，创建db01库及其下的user表。
create database db01;
use db01
CREATE TABLE `users` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`name` varchar(50) NOT NULL DEFAULT '',
`indate` datetime NOT NULL DEFAULT '0000-00-00 00:00:00',
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;
c.执行以下SQL语句，创建db02及其下的item表。
create database db02;
use db02;
CREATE TABLE `item` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`value` int(11) NOT NULL DEFAULT '0',
`indate` datetime NOT NULL DEFAULT '0000-00-00 00:00:00',
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=9 DEFAULT CHARSET=utf8;
d.执行以下sql语句，创建db03及其下的item表。
create database db03;
use db03;
CREATE TABLE `item` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`value` int(11) NOT NULL DEFAULT '0',
`indate` datetime NOT NULL DEFAULT '0000-00-00 00:00:00',
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=9 DEFAULT CHARSET=utf8;
2.执行安装
本文采用“mycat-1.6”版本为例。
1)执行如下命令，下载软件包。
wget https://github.com/MyCATApache/Mycat-download/raw/master/1.6-RELEASE/Mycat-server-1.6-RELEASE-20161028204710-linux.tar.gz
2)执行如下命令，解压软件包。
tar -zxvf Mycat-server-1.6-RELEASE-20161028204710-linux.tar.gz -C /usr/local/
3)执行如下命令，进入MyCat配置目录。
cd /usr/local/mycat/conf
4)修改MyCat配置文件。
下述配置文件的内容，可以直接替换配置文件原有的内容，也可根据实际情况修改。
“server.xml”和“schema.xml”中的[password]必须根据实际情况配置。
配置“server.xml”，修改内容如下：
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mycat:server SYSTEM "server.dtd">
<mycat:server xmlns:mycat="http://io.mycat/">
<system>
<property name="useSqlStat">0</property> <!-- 1为开启实时统计、0为关闭 -->
<property name="useGlobleTableCheck">0</property> <!-- 1为开启全加班一致性检测、0为关闭 -->
<property name="sequnceHandlerType">1</property>
<property name="processorBufferPoolType">0</property>
<property name="serverPort">8066</property> <!-- 8066 为连接mycat的端口-->
<property name="managerPort">9066</property> <!-- 9066 为连接mycat管理地址的端口-->
<property name="idleTimeout">300000</property>
<property name="bindIp">0.0.0.0</property>
<property name="frontWriteQueueSize">4096</property>
<property name="processors">32</property>
<property name="handleDistributedTransactions">0</property>
<property name="useOffHeapForMerge">1</property>
<property name="memoryPageSize">1m</property>
<property name="spillsFileBufferSize">1k</property>
<property name="useStreamOutput">0</property>
<property name="systemReserveMemorySize">384m</property>
<property name="useZKSwitch">true</property>
</system>
<!-- 配置连接mycat的账号密码, 和逻辑库名称, 可以设置多个-->
<user name="root">
<property name="password">[password]</property>
<property name="schemas">TESTDB</property>
</user>
<user name="user">
<property name="password">[password]</property>
<property name="schemas">TESTDB</property>
<property name="readOnly">true</property>
</user>
</mycat:server>
配置“rule.xml”，修改内容如下：
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mycat:rule SYSTEM "rule.dtd">
<mycat:rule xmlns:mycat="http://io.mycat/">
<!-- 指定表规则的名称, 以及分片的function-->
<tableRule name="mod-long">
<rule>
<columns>id</columns>
<algorithm>mod-long</algorithm>
</rule>
</tableRule>
<!-- 分片名称为mod-long, 为tableRule标签提供-->
<function name="mod-long" class="io.mycat.route.function.PartitionByMod">
<!-- 指定有几个节点,咱们有两个db02和db03,所以写2, 取模就是id%2 -->
<property name="count">2</property>
<property name="virtualBucketTimes">160</property>
</function>
</mycat:rule>
配置“schema.xml”，修改内容如下：
<?xml version="1.0"?>
<!DOCTYPE mycat:schema SYSTEM "schema.dtd">
<mycat:schema xmlns:mycat="http://io.mycat/">
<!-- 声明一个逻辑表, 表名为TESTDB, 和server.xml中的对应 -->
<schema name="TESTDB" checkSQLschema="false" sqlMaxLimit="100">
<!-- 指定实际表名为users, 是在node_db01节点上-->
<table name="users" primaryKey="id" autoIncrement="true" dataNode="node_db01" />
<!-- 实际表名为item, 在node_db02和node_db03节点上-->
<table name="item" primaryKey="id" autoIncrement="true" dataNode="node_db02,node_db03" rule="mod-long" />
</schema>
<dataNode name="node_db01" dataHost="dataHost01" database="db01" />
<dataNode name="node_db02" dataHost="dataHost01" database="db02" />
<dataNode name="node_db03" dataHost="dataHost01" database="db03" />
<!-- 声明数据库的连接地址, 名称为dataHost01, 为dataNode节点提供-->
<dataHost name="dataHost01" maxCon="1000" minCon="10" balance="0" writeType="0" dbType="mysql" dbDriver="native">
<heartbeat>select user()</heartbeat>
<!-- 数据库的连接地址，账号和密码-->
<writeHost host="server1" url="127.0.0.1:3306" user="root" password="[password]" />
</dataHost>
</mycat:schema>
5)修改MyCat执行“startup_nowrap.sh”脚本，在脚本文件开头添加如下内容：
vim /usr/local/mycat/bin/startup_nowrap.sh
JAVA_HOME=/usr/lib/jvm/jre
3.启动软件
1)执行以下命令，启动MyCat。
/usr/local/mycat/bin/startup_nowrap.sh
2)执行以下命令，连接MyCat。
[password]为“server.xml”中配置的用户密码。
mysql -uroot -p[password] -h127.0.0.1 -P8066
3)执行以下命令，查看MyCat的库信息。
show databases;
4)系统如下，表示MyCat拥有TESTDB库。
+----------+
| DATABASE |
+----------+
| TESTDB |
+----------+
1 row in set (0.00 sec)
5) 执行以下命令，进入“TESTDB”库。
use TESTDB;
6) 执行以下命令，查看“TESTDB”下的表信息。
show tables;
+------------------+
| Tables in TESTDB |
+------------------+
| item |
| users |
+------------------+
2 rows in set (0.00 sec)
7）执行以下SQL语句：
insert into users(id,name,indate) values(1,'hello',now());
insert into users(id,name,indate) values(2,'world',now());
insert into item(id,value,indate) values(1,100,now());
insert into item(id,value,indate) values(2,100,now());
系统回显如下，表示能够正常使用MyCat。
Query OK, 1 row affected (0.02 sec)
