1.mycat简介
1.1什么是Mycat？
简单的说，Mycat就是（官网:http://www.mycat.org.cn）：
- 一个彻底开源的，面向企业应用开发的“大数据库集群”
- 支持事务、ACID、可以替代MySQL的加强版数据库
- 一个可以视为“MySQL”集群的企业级数据库，用来替代昂贵的Oracle集群
- 一个融合内存缓存技术、Nosql技术、HDFS大数据的新型SQL Server
- 结合传统数据库和新型分布式数据仓库的新一代企业级数据库产品
- 一个新颖的数据库中间件产品
1.2Mycat的关键特性：
- 支持 SQL 92标准
- 支持MySQL集群，可以作为Proxy使用
- 支持JDBC连接ORACLE、DB2、SQL Server，将其模拟为MySQL Server使用
- 支持galera for MySQL集群，percona-cluster或者mariadb cluster，提供高可用性数据分片集群
- 自动故障切换，高可用性
- 支持读写分离，支持MySQL双主多从，以及一主多从的模式
- 支持全局表，数据自动分片到多个节点，用于高效表关联查询
- 支持独有的基于E-R 关系的分片策略，实现了高效的表关联查询
- 多平台支持，部署和实施简单
2.环境搭建
2.1依赖工具
Maven 、Git、JDK 、MySQL 、IDEA
2.2源码地址
官网：https://github.com/MyCATApache/Mycat-Server
2.3 数据库配置
创建数据库 db01
-
创建数据表：test
CREATE TABLE `test` ( `id` bigint(20) NOT NULL AUTO_INCREMENT, `name` varchar(255) CHARACTER SET latin1 DEFAULT NULL, PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8 COLLATE=utf8_bin
2.4mycat配置
为了避免对实现源码产生影响，我们选择对 test 目录做变更。
在
resources目录下新建文件夹backups，将原resources下的所有文件移到backups下，这样我们的环境就干干净了。-
在
resources目录下新建schema.xml文件，配置MyCAT的逻辑库、表、数据节点、数据源。<?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="test" dataNode="dn1" autoIncrement="true" primaryKey="id" /> </schema> <dataNode name="dn1" dataHost="localhost1" database="db1" /> <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="hostM1" url="127.0.0.1:3306" user="root" password="123456"> <!-- ‼️‼️‼️ url、user、password 设置成你的数据库 --> </writeHost> </dataHost> </mycat:schema> -
在
resources目录下新建server.xml文件，配置MyCAT系统配置<?xml version="1.0" encoding="UTF-8"?> <!DOCTYPE mycat:server SYSTEM "server.dtd"> <mycat:server xmlns:mycat="http://io.mycat/"> <system> <property name="nonePasswordLogin">0</property> <!-- 0为需要密码登陆、1为不需要密码登陆 ,默认为0，设置为1则需要指定默认账户--> <property name="useHandshakeV10">1</property> <property name="useSqlStat">0</property> <!-- 1为开启实时统计、0为关闭 --> <property name="useGlobleTableCheck">0</property> <!-- 1为开启全加班一致性检测、0为关闭 --> <property name="sequnceHandlerType">2</property> <property name="processorBufferPoolType">0</property> <property name="handleDistributedTransactions">0</property> <property name="useOffHeapForMerge">1</property> <property name="memoryPageSize">64k</property> <property name="spillsFileBufferSize">1k</property> <property name="useStreamOutput">0</property> <property name="systemReserveMemorySize">384m</property> <property name="useZKSwitch">false</property> </system> <user name="root" defaultAccount="true"> <property name="password">123456</property> <property name="schemas">db01</property> </user> </mycat:server>
3. MyCAT 启动
- 在
java目录下新建debugger包，和原先已存在的包做区分 - 在
debbuger包下新建MycatStartupTest.java：
package demo.debugger;
import io.mycat.MycatStartup;
/**
* @Author smallmartial
* @Date 2020/4/7
* @Email smallmarital@qq.com
*/
public class MycatStartupTest {
public static void main(String[] args) {
MycatStartup.main(args);
}
}
- 运行
MycatStartupTest.java，当看到输出日志MyCAT Server startup successfully. see logs in logs/mycat.log即为启动成功。
image-20200407152623914.png
4. MyCAT 测试
使用 MySQL 客户端连接 MyCAT ：
- HOST ：127.0.0.1
- PORT ：8066
- USERNAME ：root
- PASSWORD ：123456
image-20200407152758685.png
