MyCat 入门：漫谈 MyCat 配置系统

Posted 2021-04-28 陈树义

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了MyCat 入门：漫谈 MyCat 配置系统相关的知识，希望对你有一定的参考价值。

上篇文章，我们通过一个项目从零到百万级访问的变化，展示了这个过程中数据层的架构变化。其中说到了数据层架构变化所带来的三个问题：

读写数据源判断
分表判断

而 MyCat 最初就是为了解决这个问题而存在的，它能集中管理项目涉及到的所有数据库连接，减少项目中非业务性代码的编写。

了解完 MyCat 的诞生背景，现在我们就上手用一用这个框架。话不多说，我们先通过一个简单的例子让 MyCat 跑起来。

运行MyCat服务器

提示：运行 MyCat 服务器需要安装 JDK 和 mysql，请确保你的服务器上已经正确安装。

完成环境确认后，到 MyCat 官网下载 MyCat 的服务器包。MyCat 针对不同系统提供了不同的安装包，我这边下载的是 1.6.RELEASE 版本的 Mac 安装包。

图片描述

下载完成后解压进入 bin 目录，运行下面的命令运行 MyCat 服务器：

YuRongChandeMacBook-Pro:bin yurongchan$ ./mycat start
Starting Mycat-server...

查看 MyCat 安装包目录下的 logs/wrapper.log日志，如果没有报错，那就是启动成功了。

MyCat 安装包默认为我们提供了有读写权限的账号，账号名为 root，密码是 123456。下面我们直接用这个默认账号在命令行上连接 MyCat。

mysql -uroot -p123456 -h127.0.0.1 -P8066

可以看到我们已经成功连上了 MyCat 服务器。MyCat 服务器默认定义了一个名为 TESTDB 的逻辑数据库，并且也在该逻辑数据库中定义了一些逻辑表。

mysql> show databases;
+----------+
| DATABASE |
+----------+
| TESTDB   |
+----------+
1 row in set (0.01 sec)
mysql> use TESTDB;
Reading table information for completion of table and column names
You can turn off this feature to get a quicker startup with -A
Database changed
mysql> show tables;
+------------------+
| Tables in TESTDB |
+------------------+
| company          |
| customer         |
| customer_addr    |
| employee         |
| goods            |
| hotnews          |
| orders           |
| order_items      |
| travelrecord     |
+------------------+
9 rows in set (0.00 sec)

但当你尝试做一些 select 操作的时候，控制台会提示报错，这是因为 MyCat 配置错误导致的。

如果我们要使用 MyCat 正确执行 select 语句的话，我们需要在 MySQL 中先创建三个数据库，分别是：db1、db2、db3。

创建完成之后再创建 travelrecord 表。

create table travelrecord (id bigint not null primary key,user_id varchar(100),traveldate DATE, fee decimal,days int);

最后在 schema.xml 中保留一个 DataHost 节点：

<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="localhost:3306" user="root"
               password="root"> 
    </writeHost> 
</dataHost>

最后重启 MyCat 服务器：

./mycat restart

之后连接 MyCat

mysql -uroot -p123456 -h127.0.0.1 -P8066

连接成功后尝试运行相应的 SQL 语句：

mysql> use TESTDB;
Reading table information for completion of table and column names
You can turn off this feature to get a quicker startup with -A
Database changed
mysql> select * from travelrecord;
+----+---------+------------+------+------+
| id | user_id | traveldate | fee  | days |
+----+---------+------------+------+------+
|  1 | Victor  | 2016-01-01 |  100 |   10 |
+----+---------+------------+------+------+
1 row in set (0.01 sec)

到这里，我们已经学会最基本的 MyCat 服务器启动以及配置了。但单单会这些还不够，我们需要了解一下 MyCat 的目录结构，以及其常用的配置文件。

MyCat 的目录结构

打开 MyCat 的目录，我们可以看到 MyCat 主要包括了以下几个文件夹：

其中 bin 目录是 MyCat 的启动目录，conf 目录是 MyCat 的配置文件目录，lib 目录是 MyCat 自身的 Jar 包以及所依赖 Jar 包的目录，logs 目录是日志目录。

MyCat 的配置文件

在这 MyCat 的目录中，最重要的是 conf 目录，这里面存放了 MyCat 所有的配置信息。在 conf 目录中有三个重要的配置文件：schema.xml、server.xml、rule.xml。

3.1

schema.xml

schema.xml 文件定义了 MyCat 到底连接那个数据库实例，连接这个数据库实例的哪个数据库。MyCat 一共有几个逻辑数据库，MyCat 一共有几个逻辑表。

schema.xml 文件一共有四个配置节点：DataHost、DataNode、Schema、Table。

DataHost 节点定义了 MyCat 要连接哪个 MySQL 实例，连接的账号密码是多少。默认的 MyCat 为我们定义了一个名为 localhost1 的数据服务器（DataHost），它指向了本地（localhost）3306 端口的 MySQL 服务器，对应 MySQL 服务器的账号是 root，密码是 123456。

<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="localhost:3306" user="root" password="123456"> 
        <readHost host="hostS2" url="192.168.1.200:3306" user="root" password="xxx" />
    </writeHost>
    <writeHost host="hostS1" url="localhost:3316" user="root" password="123456" /> 
</dataHost>

DataNode 节点指定了需要连接的具体数据库名称，其使用一个 dataHost 属性指定该数据库位于哪个数据库实例上。默认的 MyCat 为我们创建了三个数据节点（DataNode），dn1 数据节点对应 localhost1 数据服务器上的 db1 数据库，dn2 数据节点对应 localhost1 数据服务器上的 db2 数据库，dn1 数据节点对应 localhost1 数据服务器上的 db3 数据库。

<dataNode name="dn1" dataHost="localhost1" database="db1" />
<dataNode name="dn2" dataHost="localhost1" database="db2" />
<dataNode name="dn3" dataHost="localhost1" database="db3" />

Schema 节点定义了 MyCat 的所有逻辑数据库，Table 节点定义了 MyCat 的所有逻辑表。默认的 MyCat 为我们定义了一个名为 TESTDB 的逻辑数据库，在这个逻辑数据库下又定义了名为 travaelrecord、company 等 6 个逻辑表。

<schema name="TESTDB" checkSQLschema="false" sqlMaxLimit="100"> 
    <table name="travelrecord" dataNode="dn1,dn2,dn3" rule="auto-sharding-long" /> 
    <table name="company" primaryKey="ID" type="global" dataNode="dn1,dn2,dn3" />
    ……
</schema>

所以上面当我们登陆 MyCat 输入show databases会看到只有一个名为 TESTDB 的数据库，这个就是 MyCat 的逻辑数据库。

我们输入show tables可以看到 TESTDB 下对应的逻辑表。

3.2

server.xml

server.xml 定义了项目中连接 MyCat 服务器所需要的账号密码，以及该账号能访问那些逻辑数据库。server.xml 配置文件中有 System 和 User 两个配置节点。

System 节点定义了连接 MyCat 服务器的系统配置信息。例如是否开启实时统计功能，是否开启全加班一致性检测等。

<system>
    <property name="useSqlStat">0</property>  <!-- 1为开启实时统计、0为关闭 -->
    <property name="useGlobleTableCheck">0</property>  <!-- 1为开启全加班一致性检测、0为关闭 --> 
    <property name="sequnceHandlerType">2</property> 
    <property name="processorBufferPoolType">0</property> 
    ……
</system>

User 配置节点定义了连接 MyCat 服务器的账号密码，以及该账号密码所能进行的数据库操作。默认的 MyCat 为我们创建了一个账户名为 root，密码为 123456 的账号，只能访问 TESTDB 逻辑数据库，并且定义了对相关表的操作权限。

<user name="root">
    <property name="password">123456</property>
    <property name="schemas">TESTDB</property> 
    <privileges check="false">
        <schema name="TESTDB" dml="0110" >
            <table name="tb01" dml="0000"></table>
            <table name="tb02" dml="1111"></table>
        </schema>
    </privileges>    
</user>

3.3

rule.xml

rule.xml 定义了逻辑表使用哪个字段进行拆分，使用什么拆分算法进行拆分。rule.xml 中有两个配置节点，分别是：TableRule 和 Function 配置节点。

TableRule 配置节点定义了逻辑表的拆分信息，例如使用哪个字段进行拆分，使用什么拆分算法。默认的 MyCat 为我们配置了一个名为 rule2 的表拆分规则，表示根据 user_id 字段进行拆分，拆分算法是 func1。

<tableRule name="rule2">
    <rule>
        <columns>user_id</columns>
        <algorithm>func1</algorithm>
    </rule>
</tableRule>

Function 配置节点则定义了具体的拆分算法。例如使用对 1000 取余的拆分算法，对 100 取余的拆分算分等等。默认的 MyCat 为我们定义了一个名为 func1 的拆分算法，这个拆分算法定义在 o.mycat.route.function.PartitionByLong 类中，并且还传入了两个参数值。

<function name="func1" class="io.mycat.route.function.PartitionByLong">
    <property name="partitionCount">8</property>
    <property name="partitionLength">128</property>
</function>

总结

到这里，我们就将 MyCat 的三个重要的配置文件讲完了。

其实 MyCat 的使用就只有三个配置文件：

schema.xml 文件定义了 MyCat 到底连接那个数据库实例，连接这个数据库实例的哪个数据库。
server.xml 定义了项目中连接 MyCat 服务器所需要的账号密码，以及该账号能访问那些逻辑数据库。
rule.xml 定义了逻辑表使用哪个字段进行拆分，使用什么拆分算法进行拆分。

其实 MyCat 并不难，只要把 MyCat 的几个配置文件弄熟悉了就可以了，也不需要去死记硬背，只需要用到的时候查询一下就可以。

如果觉得文章还不够，记得点赞评论转发哦。