文档章节

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

芋道源码
 芋道源码
发布于 2017/05/24 22:02
字数 922
阅读 806
收藏 25

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

  1. RocketMQ / MyCAT / Sharding-JDBC 所有源码分析文章列表
  2. RocketMQ / MyCAT / Sharding-JDBC 中文注释源码 GitHub 地址
  3. 您对于源码的疑问每条留言将得到认真回复。甚至不知道如何读源码也可以请教噢
  4. 新的源码解析文章实时收到通知。每周更新一篇左右

1. 依赖工具

  • Maven
  • Git
  • JDK
  • MySQL
  • IntelliJ IDEA

2. 源码拉取

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

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

3. 数据库配置

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

  1. 创建数据库:db01
  2. 创建数据库表: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 目录如下:

test目录.png

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 进行探讨。

© 著作权归作者所有

芋道源码

芋道源码

粉丝 309
博文 75
码字总数 193913
作品 0
徐汇
后端工程师
私信 提问
加载中

评论(6)

talent-tan
talent-tan

引用来自“红薯”的评论

居然不是放码云

引用来自“talent-tan”的评论

我想过把我写的那部分弄到码云,不过,当时还是基于talent-nio写的,现在都经历了talent-nio-->talent-aio-->t-io,回头想想,还是算了

引用来自“芋艿V”的评论

t-io 不错呀😄
我说的是
https://github.com/MyCATApache/Mycat-Balance/tree/master/src/main/java/com/talent

不过我后来很快就退出mycat了,所以这块代码估计也没人用了。
东子
东子

引用来自“talent-tan”的评论

引用来自“红薯”的评论

居然不是放码云
我想过把我写的那部分弄到码云,不过,当时还是基于talent-nio写的,现在都经历了talent-nio-->talent-aio-->t-io,回头想想,还是算了

回复@talent-tan :
芋道源码
芋道源码

引用来自“红薯”的评论

居然不是放码云

引用来自“talent-tan”的评论

我想过把我写的那部分弄到码云,不过,当时还是基于talent-nio写的,现在都经历了talent-nio-->talent-aio-->t-io,回头想想,还是算了
t-io 不错呀😄
芋道源码
芋道源码

引用来自“红薯”的评论

居然不是放码云
😛blog在github,自己写的开源项目在码云。哈哈
talent-tan
talent-tan

引用来自“红薯”的评论

居然不是放码云
我想过把我写的那部分弄到码云,不过,当时还是基于talent-nio写的,现在都经历了talent-nio-->talent-aio-->t-io,回头想想,还是算了
红薯
红薯
居然不是放码云
Mycat - 实现数据库的读写分离与高可用

mysql主从实现 Mycat不负责任何的数据同步问题,mysql的主从复制还得从mysql层面来实现;如果没有实现mysql的主从复制,后文就都成 如果想学习Java工程化、高性能及分布式、深入浅出。微服务...

编程SHA
02/20
0
0
Mycat - 高可用与负载均衡实现,满满的干货!

前情回顾 Mycat - 实现数据库的读写分离与高可用中我们实现了mysql的读写分离与高可用,有几个点我们回顾下 如果想学习Java工程化、高性能及分布式、深入浅出。微服务、Spring,MyBatis,Net...

编程SHA
02/20
0
0
Mycat读写分离笔记Windows

Mycat读写分离笔记Windows 自己搭了一个运用Mycat中间件搭建了一个读写分离的demo,昨晚还在奋战当中,因为连接mycat的时候老是报错:No Mycat DataBases selected.尝试了很多的方法,然后还...

推荐码发放
2018/04/29
0
0
JAVAEE——宜立方商城13:订单系统实现、订单生成、Mycat数据库分片

1. 学习计划 1、订单系统实现 2、订单生成 3、Mycat数据库分片 2. 订单系统 2.1. 功能分析 1、在购物车页面点击“去结算”按钮,跳转到订单确认页面 a) 必须要求用户登录 b) 使用拦截器实现。...

kent鹏
2018/08/07
0
0
​深度分析 | MyCat与DBLE的对比性能调优

作者简介 蓝寅,开源分布式中间件DBLE项目负责人;持续专注于数据库方面的技术, 始终在一线从事开发;对数据复制,读写分离,分库分表的有深入的理解与实践。 问题起因: 用benchmarksqlfor...

爱可生
03/09
0
0

没有更多内容

加载失败,请刷新页面

加载更多

Java编程学习-Java虚拟机(JVM)以及跨平台原理

相信大家已经了解到Java具有跨平台的特性,可以“一次编译,到处运行”,在Windows下编写的程序,无需任何修改就可以在Linux下运行,这是C和C++很难做到的。 那么,跨平台是怎样实现的呢?这...

Java领航员
32分钟前
0
0
学JFinal不迷路,JFinal优质资源列表(欢迎反馈更新)

学JFinal不迷路,记录一下JFinal相关的资源、产品、讲师等信息(所有信息排名不分先后)。 一、相关站点: 1、JFinal官网-问答、分享、文档、交流、俱乐部 http://www.jfinal.com 2 、JFina...

山东-小木
36分钟前
1
0
项目学习(2)-order-job

在当前的系统中,因为并发量并不高,服务之间发起异步请求或者异步调用时,没有使用到消息中间件。 而是在各个服务(子系统)的数据库中,创建了event_queue事件对列表和event_handler事件处...

太猪-YJ
45分钟前
1
0
gradle grovvy中的闭包

1. 无参数的闭包 //这b1就是一个闭包def b1={ println "hello b1"}//定义方法,包含闭包类型的参数def method1(Closure closure){closure()}//执行method1method1(b1) 执行结果 ...

edison_kwok
今天
3
0
基于Spring Boot + Dubbo的全链路日志追踪(一)

一、 概要 当前公司后端整体架构为:Spring Boot + Dubbo。由于早期项目进度等原因,对日志这块没有统一的规范,基本上是每个项目自己管自己的日志。这也对后面的问题排查带来了很大的困难,...

明天以后
今天
7
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部