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

傷城~ 2022-06-16 12:17 231阅读 0赞

## 1、MyCat概念    ##

## 1.1 总体架构 ##

MyCAT的[架构][Link 1]如下图所示：  
![o_MyCAT_E6_9E_B6_E6_9E_84_E5_9B_BE.png][]

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

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

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

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

## 1.2 逻辑库 ##

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

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

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

·        MYCAT\_HOME/conf/schema.xml中定义逻辑库，表、分片节点等内容；

·        MYCAT\_HOME/conf/rule.xml中定义分片规则；

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

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

# 2、  MyCat基本使用教程 #

## 2.1 下载和安装 ##

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

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

目录下的“[Mycat-server-1.2-GA-win.tar.gz][]”文件，解压后的目录结构如下图所示：  
     ![r_MyCAT_e7_9b_ae_e5_bd_95_e7_bb_93_e6_9e_84.png][]

目录说明见下表所示：

<table style="color:rgb(0,0,0); font-family:Arial; font-size:14px; line-height:26px; border:medium none; border-collapse:collapse"> 
 <tbody> 
 <tr> 
 <td style="border:1pt solid black; padding:0cm 5.4pt; width:83.4pt; background:yellow"> 目录名称 </td> 
 <td style="border-color:black black black rgb(240,240,240); border-bottom-width:1pt; border-bottom-style:solid; padding:0cm 5.4pt; width:342.7pt; border-top-width:1pt; border-top-style:solid; border-right-width:1pt; border-right-style:solid; background:yellow"> 说明 </td> 
 </tr> 
 <tr style="height:195.2pt"> 
 <td style="border-color:rgb(240,240,240) black black; border-bottom-width:1pt; border-bottom-style:solid; border-left-width:1pt; border-left-style:solid; padding:0cm 5.4pt; width:83.4pt; height:195.2pt; border-right-width:1pt; border-right-style:solid; background-color:transparent"> bin </td> 
 <td style="border-color:rgb(240,240,240) black black rgb(240,240,240); border-bottom-width:1pt; border-bottom-style:solid; padding:0cm 5.4pt; width:342.7pt; height:195.2pt; border-right-width:1pt; border-right-style:solid; background-color:transparent"> 存放window版本和<a href="http://lib.csdn.net/base/linux" title="Linux知识库" style="color:rgb(223,52,52); text-decoration:none; font-weight:bold" rel="nofollow">Linux</a>版本，除了提供封装成服务的版本之外，也提供nowrap的shell脚本命令，方便大家选择和修改。 Windows&nbsp;下&nbsp;运行：mycat.bat&nbsp;console在控制台启动程序，也可以装载成服务，若此程序运行有问题，也可以运行startup_nowrap.bat，确保java命令可以在命令执行。 Warp方式的命令，可以安装成服务并启动或停止。 l&nbsp;mycat install (可选) l&nbsp;mycat start 注意，wrap方式的程序，其JVM配置参数在conf/wrap.conf中，可以修改为合适的参数，参数调整参照<a href="http://wrapper.tanukisoftware.com/doc/english/properties.html" style="color:rgb(202,0,0); text-decoration:none" rel="nofollow">http://wrapper.tanukisoftware.com/doc/english/properties.html</a>。 </td> 
 </tr> 
 <tr> 
 <td style="border-color:rgb(240,240,240) black black; border-bottom-width:1pt; border-bottom-style:solid; border-left-width:1pt; border-left-style:solid; padding:0cm 5.4pt; width:83.4pt; border-right-width:1pt; border-right-style:solid; background-color:transparent"> conf </td> 
 <td style="border-color:rgb(240,240,240) black black rgb(240,240,240); border-bottom-width:1pt; border-bottom-style:solid; padding:0cm 5.4pt; width:342.7pt; border-right-width:1pt; border-right-style:solid; background-color:transparent"> 存放配置文件： l&nbsp;server.xml：是Mycat服务器参数调整和用户授权的配置文件。 l&nbsp;schema.xml：是逻辑库定义和表以及分片定义的配置文件。 l&nbsp;rule.xml：是分片规则的配置文件，分片规则的具体一些参数信息单独存放为文件，也在这个目录下，配置文件修改，需要重启MyCAT或者通过9066端口reload。 l&nbsp;wrapper.conf：JVM配置参数等设置。 l&nbsp;log4j.xml：日志存放在logs/mycat.log中，每天一个文件，日志的配置是在conf/log4j.xml中，根据自己的需要，可以调整输出级别为debug，debug级别下，会输出更多的信息，方便排查问题。 </td> 
 </tr> 
 <tr> 
 <td style="border-color:rgb(240,240,240) black black; border-bottom-width:1pt; border-bottom-style:solid; border-left-width:1pt; border-left-style:solid; padding:0cm 5.4pt; width:83.4pt; border-right-width:1pt; border-right-style:solid; background-color:transparent"> lib </td> 
 <td style="border-color:rgb(240,240,240) black black rgb(240,240,240); border-bottom-width:1pt; border-bottom-style:solid; padding:0cm 5.4pt; width:342.7pt; border-right-width:1pt; border-right-style:solid; background-color:transparent"> MyCAT自身的jar包或依赖的jar包的存放目录。 </td> 
 </tr> 
 <tr> 
 <td style="border-color:rgb(240,240,240) black black; border-bottom-width:1pt; border-bottom-style:solid; border-left-width:1pt; border-left-style:solid; padding:0cm 5.4pt; width:83.4pt; border-right-width:1pt; border-right-style:solid; background-color:transparent"> logs </td> 
 <td style="border-color:rgb(240,240,240) black black rgb(240,240,240); border-bottom-width:1pt; border-bottom-style:solid; padding:0cm 5.4pt; width:342.7pt; border-right-width:1pt; border-right-style:solid; background-color:transparent"> MyCAT日志的存放目录。日志存放在logs/mycat.log中，每天一个文件 </td> 
 </tr> 
 </tbody> 
</table>

##    2.2 启动和停止 ##

安装mycat服务 ：mycate install

启动mycat服务 ：mycate start

停止mycat服务 ：mycate stop

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

## 3、使用教程 ##

## 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  
  
][http_blog.csdn.net_q98842674_article_details_12094777]

**3.2 创建数据库**

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

### 3.3 配置文件 ###

schema.xml配置文件，因为分库在不同的服务器，因此配置两个datahost；如果在一个datahost中配置多个writeHost，则为主从配置。type="global"时，为全局表，

![None.gif][]<?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)

[Link 1]: http://lib.csdn.net/base/architecture
[o_MyCAT_E6_9E_B6_E6_9E_84_E5_9B_BE.png]: /images/20220616/f232a62a06804403bf591bb279263d1d.png
[MySQL]: http://lib.csdn.net/base/mysql
[r_MyCat_e9_80_bb_e8_be_91_e5_ba_93.png]: http://www.blogjava.net/images/blogjava_net/amigoxie/21128/r_MyCat%e9%80%bb%e8%be%91%e5%ba%93.png
[Java]: http://lib.csdn.net/base/javase
[Mycat-server-1.2-GA-win.tar.gz]: http://code.taobao.org/svn/openclouddb/downloads/old/MyCat-Sever-1.2/Mycat-server-1.2-GA-win.tar.gz
[r_MyCAT_e7_9b_ae_e5_bd_95_e7_bb_93_e6_9e_84.png]: http://www.blogjava.net/images/blogjava_net/amigoxie/21128/r_MyCAT%e7%9b%ae%e5%bd%95%e7%bb%93%e6%9e%84.png
[http_blog.csdn.net_q98842674_article_details_12094777]: http://blog.csdn.net/q98842674/article/details/12094777
[None.gif]: /images/20220616/c478630fe4694563aa03a7026d5007f8.png