MyCat部署运行（Windows环境）与使用步骤详解

时间 2019-11-12

标签 mycat 部署运行 windows 环境使用步骤详解栏目 Windows 繁體版

原文原文链接

一、MyCat概念

1.1 整体架构

MyCAT的架构以下图所示：
html

MyCAT使用MySQL的通信协议模拟成一个MySQL服务器，并创建了完整的Schema（数据库）、Table（数据表）、User（用户）的逻辑模型，并将这套逻辑模型映射到后端的存储节点DataNode（MySQL Instance）上的真实物理库中，这样一来，全部能使用MySQL的客户端以及编程语言都能将MyCAT当成是MySQLServer来使用，没必要开发新的客户端协议。java

当MyCAT收到一个客户端发送的SQL请求时，会先对SQL进行语法分析和检查，分析的结果用于SQL路由，SQL路由策略支持传统的基于表格的分片字段方式进行分片，也支持独有的基于数据库E-R关系的分片策略，对于路由到多个数据节点（DataNode）的SQL，则会对收到的数据集进行“归并”而后输出到客户端。node

SQL执行的过程，简单的说，就是把SQL经过网络协议发送给后端的真正的数据库上进行执行，对于MySQL Server来讲，是经过MySQL网络协议发送报文，并解析返回的结果，若SQL不涉及到多个分片节点，则直接返回结果，写入客户端的SOCKET流中，这个过程是非阻塞模式（NIO）。mysql

DataNode是MyCAT的逻辑数据节点，映射到后端的某一个物理数据库的一个Database，为了作到系统高可用，每一个DataNode能够配置多个引用地址（DataSource），当主DataSource被检测为不可用时，系统会自动切换到下一个可用的DataSource上，这里的DataSource便可认为是Mysql的主从服务器的地址。linux

1.2 逻辑库

与任何一个传统的关系型数据库同样，MyCAT也提供了“数据库”的定义，并有用户受权的功能，下面是MyCAT逻辑库相关的一些概念：sql

schema:逻辑库，与MySQL中的Database（数据库）对应，一个逻辑库中定义了所包括的Table。
table：表，即物理数据库中存储的某一张表，与传统数据库不一样，这里的表格须要声明其所存储的逻辑数据节点DataNode，这是经过表格的分片规则定义来实现的，table能够定义其所属的“子表(childTable)”，子表的分片依赖于与“父表”的具体分片地址，简单的说，就是属于父表里某一条记录A的子表的全部记录都与A存储在同一个分片上。
分片规则：是一个字段与函数的捆绑定义，根据这个字段的取值来返回所在存储的分片（DataNode）的序号，每一个表格能够定义一个分片规则，分片规则能够灵活扩展，默认提供了基于数字的分片规则，字符串的分片规则等。
dataNode: MyCAT的逻辑数据节点，是存放table的具体物理节点，也称之为分片节点，经过DataSource来关联到后端某个具体数据库上，通常来讲，为了高可用性，每一个DataNode都设置两个DataSource，一主一从，当主节点宕机，系统自动切换到从节点。
dataHost：定义某个物理库的访问地址，用于捆绑到dataNode上。

MyCAT目前经过配置文件的方式来定义逻辑库和相关配置：shell

· MYCAT_HOME/conf/schema.xml中定义逻辑库，表、分片节点等内容；数据库

· MYCAT_HOME/conf/rule.xml中定义分片规则；express

· MYCAT_HOME/conf/server.xml中定义用户以及系统相关变量，如端口等。apache

下图给出了MyCAT一个可能的逻辑库到物理库（MySQL的完整映射关系），能够看出强大的分片能力以及灵活的Mysql集群整合能力。

二、 MyCat基本使用教程

2.1 下载和安装

MyCAT使用Java开发，由于用到了JDK 7的部分功能，因此在使用前请确保安装了JDK 7.0，要求是JDK 7.0以上，并设置了正确的Java环境变量

目前下载的版本是免安装，解压在任意磁盘、根目录下，避免路径中出现中文。

目录下的“Mycat-server-1.2-GA-win.tar.gz”文件，解压后的目录结构以下图所示：

目录说明见下表所示：

目录名称	说明
bin	存放window版本和linux版本，除了提供封装成服务的版本以外，也提供nowrap的shell脚本命令，方便你们选择和修改。 Windows 下运行：mycat.bat console在控制台启动程序，也能够装载成服务，若此程序运行有问题，也能够运行startup_nowrap.bat，确保java命令能够在命令执行。 Warp方式的命令，能够安装成服务并启动或中止。 l mycat install (可选) l mycat start 注意，wrap方式的程序，其JVM配置参数在conf/wrap.conf中，能够修改成合适的参数，参数调整参照http://wrapper.tanukisoftware.com/doc/english/properties.html。
conf	存放配置文件： l server.xml：是Mycat服务器参数调整和用户受权的配置文件。 l schema.xml：是逻辑库定义和表以及分片定义的配置文件。 l rule.xml：是分片规则的配置文件，分片规则的具体一些参数信息单独存放为文件，也在这个目录下，配置文件修改，须要重启MyCAT或者经过9066端口reload。 l wrapper.conf：JVM配置参数等设置。 l log4j.xml：日志存放在logs/mycat.log中，天天一个文件，日志的配置是在conf/log4j.xml中，根据本身的须要，能够调整输出级别为debug，debug级别下，会输出更多的信息，方便排查问题。
lib	MyCAT自身的jar包或依赖的jar包的存放目录。
logs	MyCAT日志的存放目录。日志存放在logs/mycat.log中，天天一个文件

2.2 启动和中止

安装mycat服务：mycat install

启动mycat服务：mycat start

中止mycat服务：mycat stop

注意：当修改配置文件后，须要重启mycat服务

三、使用教程

3.1 硬件配置和安装数据库

本地 mycat 192.168.1.5

服务器A mysql 192.168.1.201

服务器A mysql 192.168.1.202

安装MySQL服务器和MySQL客户端，笔者使用的MySQL服务器是免安装版本：mysql-noinstall-5.1.73-winx64，MySQL客户端是：Navicat for MySQL，免安装版本安装方法请参考：http://blog.csdn.net/q98842674/article/details/12094777

3.2 建立数据库

分别在服务器A、服务器B建立所用的分片数据库；
CREATE database db1;

3.3 配置文件

schema.xml配置文件，由于分库在不一样的服务器，所以配置两个datahost；若是在一个datahost中配置多个writeHost，则为主从配置。type="global"时，为全局表，

<?xml version="1.0"?>
<!DOCTYPE mycat:schema SYSTEM "schema.dtd">
<mycat:schema xmlns:mycat="http://org.opencloudb/">

   <schema name="TESTDB" checkSQLschema="false" sqlMaxLimit="100">
       
       <table name="travelrecord" dataNode="dn1,dn2" rule="auto-sharding-long" />

       
       <table name="company" primaryKey="ID" type="global" dataNode="dn1,dn2" />
       <table name="goods" primaryKey="ID" type="global" dataNode="dn1,dn2" />

       
       <table name="hotnews" primaryKey="ID" dataNode="dn1,dn2"
           rule="mod-long" />
       
       <table name="employee" primaryKey="ID" dataNode="dn1,dn2"
           rule="sharding-by-intfile" />
       <table name="customer" primaryKey="ID" dataNode="dn1,dn2"
           rule="sharding-by-intfile">
           <childTable name="orders" primaryKey="ID" joinKey="customer_id"
               parentKey="id">
               <childTable name="order_items" joinKey="order_id"
                   parentKey="id" />
           </childTable>
           <childTable name="customer_addr" primaryKey="ID" joinKey="customer_id"
               parentKey="id" />
       </table>
   </schema>
   <dataNode name="dn1" dataHost="localhost1" database="db1" />
   <dataNode name="dn2" dataHost="localhost2" 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="192.168.1.201:3306" user="shopuser"
           password="123456">
       </writeHost>
   </dataHost>
   <dataHost name="localhost2" maxCon="1000" minCon="10" balance="0"
       writeType="0" dbType="mysql" dbDriver="native" switchType="1" slaveThreshold="100">
       <heartbeat>select user()</heartbeat>
       <writeHost host="hostM1" url="192.168.1.202:3306" user="shopuser"
           password="123456">
       </writeHost>
   </dataHost>
</mycat:schema>

server.xml配置文件，本实例很简单，就只定义user，

name：用户名

password：密码

schemas：实例名，和schema.xml定义的schema对应，这里的实例名是虚拟名，也就是对mycat服务的一种别名，是应用程序以及客户端链接的入口。

<?xml version="1.0" encoding="UTF-8"?>

<!DOCTYPE mycat:server SYSTEM "server.dtd">
<mycat:server xmlns:mycat="http://org.opencloudb/">
   <system>
   <property name="defaultSqlParser">druidparser</property>
       
   
   
       
       
       
       
       
       
       
   </system>
   <user name="test">
       <property name="password">test</property>
       <property name="schemas">TESTDB</property>
   </user>
</mycat:server>

3.4 登陆mycat
在任意有mysql的客户端的机器链接Mycat, 执行如下命令
       mysql -utest -ptest -h192.168.1.5 -P8066 -DTESTDB   注意：8066登陆mycat数据端口，9066登陆mycat管理端口(能看到mycat内的配置、以及各个数据库链接状况，颇有用)

3.5 测试
全局表：company

mysql> create table company(id int not null primary key,name varchar(100),sharding_id int not null);
      Query OK, 0 rows affected (0.30 sec)
      mysql> explain create table company(id int not null primary key,name varchar(100),sharding_id int not null);
     +-----------+------------------------------------------------------------------------------------------------+
     | DATA_NODE | SQL                                                                                            |
     +-----------+------------------------------------------------------------------------------------------------+
     | dn1       | create table company(id int not null primary key,name varchar(100),sharding_id int not null) |
     | dn2       | create table company(id int not null primary key,name varchar(100),sharding_id int not null) |
     +-----------+------------------------------------------------------------------------------------------------+
     2 rows in set (0.04 sec)

mysql> insert into company(id,name,sharding_id) values(1,'leader us',10000);
      ERROR 2006 (HY000): MySQL server has gone away
      No connection. Trying to reconnect...
      Connection id:    6
      Current database: TESTDB

Query OK, 1 row affected (0.03 sec)
       mysql> explain insert into company(id,name,sharding_id) values(1,'leader us',10000);
       +-----------+-----------------------------------------------------------------------+
       | DATA_NODE | SQL                                                                   |
       +-----------+-----------------------------------------------------------------------+
      | dn1       | insert into company(id,name,sharding_id) values(1,'leader us',10000) |
      +-----------+-----------------------------------------------------------------------+
      1 row in set (0.00 sec)

水平分表：travelrecord

mysql> explain create table travelrecord(id int not null primary key,name varchar(100));
    +-----------+---------------------------------------------------------------------+
    | DATA_NODE | SQL                                                                 |
   +-----------+---------------------------------------------------------------------+
   | dn1       | create table travelrecord(id int not null primary key,name varchar(100)) |
   | dn2       | create table travelrecord(id int not null primary key,name varchar(100)) |
   | dn3       | create table travelrecord(id int not null primary key,name varchar(100)) |
   +-----------+---------------------------------------------------------------------+
   3 rows in set (0.01 sec)

(7) 三个分片上都插入了3条数据
   mysql> explain insert into travelrecord(id,name) values(1,'hp');
   +-----------+---------------------------------------------+
   | DATA_NODE | SQL                                         |
   +-----------+---------------------------------------------+
   | dn1       | insert into travelrecord(id,name) values(1,'hp') |
   | dn2       | insert into travelrecord(id,name) values(1,'hp') |
   | dn3       | insert into travelrecord(id,name) values(1,'hp') |
   +-----------+---------------------------------------------+
   3 rows in set (0.00 sec)

－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－