您的位置：首页 > 数据库

数据库中间件 MyCAT源码分析：调试环境搭建

2017-05-24 22:50 615 查看


🙂🙂🙂关注**微信公众号：【芋艿的后端小屋】**有福利：

RocketMQ / MyCAT / Sharding-JDBC 所有源码分析文章列表

RocketMQ / MyCAT / Sharding-JDBC 中文注释源码 GitHub 地址

您对于源码的疑问每条留言都将得到认真回复。甚至不知道如何读源码也可以请教噢。

新的源码解析文章实时收到通知。每周更新一篇左右。

1. 依赖工具

2. 源码拉取

3. 数据库配置

4. MyCat 配置

5. MyCAT 启动

6. MyCAT 测试

7. 交流

1. 依赖工具

Maven

Git

JDK

MySQL

IntelliJ IDEA

2. 源码拉取

从官方仓库 https://github.com/MyCATApache/Mycat-Server 
Fork
出属于自己的仓库。为什么要 
Fork
？既然开始阅读、调试源码，我们可能会写一些注释，有了自己的仓库，可以进行自由的提交。😈

使用 
IntelliJ IDEA
从 
Fork
出来的仓库拉取代码。拉取完成后，
Maven
会下载依赖包，可能会花费一些时间，耐心等待下。

3. 数据库配置

我们要搭建的是非分片表的调试环境，需要创建一个数据库和表：

创建数据库：
db01
。

创建数据库表：
travelrecord
。

CREATE TABLE `travelrecord` (
`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

4. MyCAT 配置

为了避免对实现源码产生影响，我们选择对 
test
目录做变更。

1、在 
resources
目录下新建文件夹 
backups
，将原 
resources
下的所有文件移到 
backups
下，这样我们的环境就干干净了。

2、在 
resources
目录下新建 
schema.xml
文件，配置 
MyCAT
的逻辑库、表、数据节点、数据源。

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

<schema name="dbtest" checkSQLschema="true" sqlMaxLimit="100">
<table name="travelrecord" 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:33061" user="root" password="123456"> <!-- ‼️‼️‼️ url、user、password 设置成你的数据库 -->
</writeHost>
</dataHost>

</mycat:schema>

3、在 
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">dbtest</property>
</user>

</mycat:server>

5. MyCAT 启动

1、在 
java
目录下新建 
debugger
包，和原先已存在的包做区分。

2、在 
debbuger
包下新建 
MycatStartupTest.java
：

package debugger;

import io.mycat.MycatStartup;

/**
* {@link io.mycat.MycatStartup}测试
*
* Created by yunai on 2017/5/22.
*/
public class MycatStartupTest {

public static void main(String[] args) {
MycatStartup.main(args);
}

}

3、运行 
MycatStartupTest.java
，当看到输出日志 
MyCAT Server startup successfully. see logs in logs/mycat.log
即为启动成功。

截止目前，
test
目录如下：



6. MyCAT 测试

调试环境已经搭建完成，我们看看是否正确。

使用 
MySQL
客户端连接 
MyCAT
：

HOST ：127.0.0.1

PORT ：8066

USERNAME ：root

PASSWORD ：123456

mysql> insert into travelrecord(name) values ('haha');
Query OK, 1 rows affected (0.01 sec)

mysql> select * from travelrecord;
+--------------------+------+
| id                 | name |
+--------------------+------+
| 866707181398003712 | haha |
+--------------------+------+
1 rows in set (0.05 sec)

成功。😈😈😈

7. 交流

感谢阅读、收藏、关注。

知其然知其所以然。学习 MyCAT 会是一段很愉快的旅程。如果有你的交流，相信会更加愉快。欢迎添加微信：
wangwenbin-server
进行探讨。
内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理 点击这里给我发消息
标签：  Java MySQL 架构 Mycat 数据库中间件
相关文章推荐
新的分享
章节导航