# 《Mycat核心技术》第19章：基于MySQL实现读写分离

作者：冰河
星球：http://m6z.cn/6aeFbs (opens new window)
博客：https://binghe.gitcode.host (opens new window)
文章汇总：https://binghe.gitcode.host/md/all/all.html (opens new window)
星球项目地址：https://binghe.gitcode.host/md/zsxq/introduce.html (opens new window)

沉淀，成长，突破，帮助他人，成就自我。

本章难度：★★☆☆☆
本章重点：以图文的形式介绍Myca基于MySQL实现读写分离的案例，掌握Mycat在实际案例场景中的应用，能够结合自身实际项目将Mycat灵活应用到自身实际项目中。

大家好，我是冰河~~

今天给大家介绍《Mycat核心技术》的第19章：以图文的形式给大家介绍下Myca基于MySQL实现读写分离的案例，好了，开始今天的内容。

这里大家需要注意的是MySQL的主从复制是依赖的MySQL自己的主从复制机制，Mycat不负责MySQL的主从复制，有关MySQL的主从复制配置，大家可以参考博文《MySQL之——主从复制的配置 (opens new window)》,好了，我们接下来进入今天的主题内容。

# 一、环境

操作系统：CentOS-6.5-x86_64-bin-DVD1.iso
JDK版本：jdk1.8
MyCat版本：Mycat-server-1.5.1-RELEASE-20170717215510-linux.tar.gz (下载源码自行编译的)
MyCat节点IP：192.168.209.133 主机名：binghe133 主机配置：4核CPU、4G内存
MySQL版本：mysql-5.6.32.tar.gz
主节点IP：192.168.209.131 主机名：binghe131 主机配置：4核CPU、4G内存
从节点IP：192.168.209.132 主机名：binghe132 主机配置：4核CPU、4G内存

# 二、MyCat介绍

MyCat的读写分离是基于后端MySQL集群的主从同步来实现的，而MyCat提供语句的分发功能。MyCat1.4开始支持MySQL主从复制状态绑定的读写分离机制，让读更加安全可靠。

# 三、MyCat的安装

# 3.1 设置MyCat的主机名和IP与主机名的映射

# vi /etc/sysconfig/network
NETWORKING=yes
HOSTNAME=binghe133

1
2
3

# vi /etc/hosts
127.0.0.1 binghe133
192.168.209.131 binghe131
192.168.209.132 binghe132
192.168.209.133 binghe133

1
2
3
4
5

# 3.2 配置Java环境变量

因为MyCat是用Java开发的，因此MyCat运行需要安装JDK（准确来说是JRE就够了），并且需要JDK1.7或以上版本

# vi /etc/profile
## java env
export JAVA_HOME=/usr/local/java/jdk1.7.0_80
export JRE_HOME=$JAVA_HOME/jre
export CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar:$JRE_HOME/lib/rt.jar
export PATH=$PATH:$JAVA_HOME/bin:$JRE_HOME/bin
# source /etc/profile
# java -version

1
2
3
4
5
6
7
8

# 3.3 上传安装包

上传Mycat-server-1.5.1-RELEASE-20170717215510-linux.tar.gz 到 MyCat服务器中的/home/mycat目录，并解压并移动到 /usr/local/mycat目录。

$ tar -zxvf Mycat-server-1.5.1-RELEASE-20170717215510-linux.tar.gz

# mv /home/mycat/mycat  /usr/local/
# cd /usr/local/mycat/
# ll

1
2
3

# 3.4 设置Mycat的环境变量

# vi /etc/profile
## mycat env
export MYCAT_HOME=/usr/local/mycat
export PATH=$PATH:$MYCAT_HOME/bin
# source /etc/profile

1
2
3
4
5

# 四、配置MyCat

# 4.1 确认MySQL主从复制正常

在配置MyCat前，请确认MySQL的主从复制安装配置已完成并正常运行。MySQL主从数据的同步在MySQL中配置，MyCat不负责数据同步的问题。

补充：

(1) MySQL主从复制配置中，如果涉及到函数或存储过程的同步复制，需要在/etc/my.cnf中的[mysqld]段中增加配置

log_bin_trust_function_creators=true 或在客户端中设置 set global log_bin_trust_function_creators = 1;

(2) 如果要做读写分离下的主从切换，那么从节点也有可能会变为写节点，因此从节点就不能设置为只读 read_only=1 。

(3) Linux版本的MySQL，需要设置为MySQL大小写不敏感，否则可能会发生找不到表的问题。可在/etc/my.cnf的[mysqld]段中增加lower_case_table_names=1 。

# 4.2 配置MyCat的schema.xml

schema.xml是MyCat最重要的配置文件之一，用于设置MyCat的逻辑库、表、数据节点、dataHost等内容，

[root@binghe133 conf]$ cd /usr/local/root/conf/
[root@binghe133 conf]$ vi schema.xml

1
2

<?xml version="1.0"?>
<!DOCTYPE mycat:schema SYSTEM "schema.dtd">
<mycat:schema xmlns:mycat="http://org.opencloudb/">
      <!-- 定义MyCat的逻辑库，逻辑库的概念与MySQL中的 database 概念相同 -->
      <!-- schema name="rc_schema1" checkSQLschema="false" sqlMaxLimit="100" dataNode="rc_dn1"></schema -->
		<!--schema name="pay_schema1" checkSQLschema="false" sqlMaxLimit="100" dataNode="pay_dn1"></schema-->
      <schema name="lyz_schema1" checkSQLschema="false" sqlMaxLimit="100" dataNode="lyz_dn1"></schema>
      <schema name="lyz_schema2" checkSQLschema="false" sqlMaxLimit="100" dataNode="lyz_dn2"></schema>
		<!-- 其中checkSQLschema表明是否检查并过滤SQL中包含schema的情况，如逻辑库为 TESTDB，则可能写为select * from TESTDB.edu_user，此时会自动过滤TESTDB，SQL变为select * from edu_user，若不会出现上述写法，则可以关闭属性为false -->
		<!--sqlMaxLimit默认返回的最大记录数限制，MyCat1.4版本里面，用户的Limit参数会覆盖掉MyCat的sqlMaxLimit默认设置-->
      <!-- 定义MyCat的数据节点 -->
      <dataNode name="lyz_dn1" dataHost="dtHost2" database="lyzdb1" />
      <dataNode name="lyz_dn2" dataHost="dtHost2" database="lyzdb2" />
	<!-- dataNode 中的 name 数据表示节点名称， dataHost表示数据主机名称， database表示该节点要路由的数据库的名称 -->
      <!-- dataHost配置的是实际的后端数据库集群（当然，也可以是非集群） -->
      <!-- 注意：schema中的每一个dataHost中的host属性值必须唯一，否则会出现主从在所有dataHost中全部切换的现象 -->
      <!-- 定义数据主机dtHost1，只连接到MySQL读写分离集群中的Master节点，不使用MyCat托管MySQL主从切换 -->
      <!--
      <dataHost name="dtHost1" maxCon="500" minCon="20" balance="0"
           writeType="0" dbType="mysql" dbDriver="native" switchType="1" slaveThreshold="100">
           <heartbeat>select user()</heartbeat>
           <writeHost host="hostM1" url="192.168.1.205:3306" user="root" password="lyz" />
      </dataHost>
      -->
      <!-- 使用MyCat托管MySQL主从切换 -->
      <!-- 定义数据主机dtHost2，连接到MySQL读写分离集群，并配置了读写分离和主从切换 -->
      <dataHost name="dtHost2" maxCon="500" minCon="20" balance="1"
           writeType="0" dbType="mysql" dbDriver="native" switchType="2" slaveThreshold="100">
           <!-- 通过show slave status检测主从状态，当主宕机以后，发生切换，从变为主，原来的主变为从，这时候show slave status就会发生错误，因为原来的主没有开启slave，不建议直接使用switch操作，而是在DB中做主从对调。 -->

           <heartbeat>show slave status</heartbeat>
           <!-- can have multi write hosts -->
           <writeHost host="hostM2" url="192.168.209.131:3306" user="root" password="root" />
           <writeHost host="hostS2" url="192.168.209.132:3306" user="root" password="root" />
      </dataHost>

      <!-- 参数balance决定了哪些MySQL服务器参与到读SQL的负载均衡中 -->
		<!-- balance="0"，为不开启读写分离，所有读操作都发送到当前可用的writeHost上-->
      <!-- balance="1"，全部的readHost与stand by writeHost参与select语句的负载均衡-->
      <!-- balance="2"，所有读操作都随机的在writeHost、readHost上分发-->
      <!-- MyCat1.4版本中，若想支持MySQL一主一从的标准配置，并且在主节点宕机的情况下，从节点还能读取数据，则需要在MyCat里配置为两个writeHost并设置balance="1" -->
      <!-- writeType="0"，所有写操作都发送到可用的writeHost上 -->
      <!-- writeType="1"，仅仅对于galera for mysql集群这种多主多节点都能写入的集群起效，此时Mycat会随机选择一个writeHost并写入数据，对于非galera for mysql集群，请不要配置writeType=1，会导致数据库不一致的严重问题 -->
</mycat:schema>

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44

MyCat1.4开始支持MySQL主从复制状态绑定的读写分离机制，让读更加安全可靠，配置如下：

MyCat心跳检查语句配置为 show slave status ，dataHost 上定义两个新属性：switchType="2" 与 slaveThreshold="100"，此时意味着开启MySQL主从复制状态绑定的读写分离与切换机制，MyCat心跳机制通过检测 show slave status 中的 "Seconds_Behind_Master", "Slave_IO_Running", "Slave_SQL_Running" 三个字段来确定当前主从同步的状态以及Seconds_Behind_Master主从复制时延，当Seconds_Behind_Master 大于slaveThreshold时，读写分离筛选器会过滤掉此Slave机器，防止读到很久之前的旧数据，而当主节点宕机后，切换逻辑会检查Slave上的Seconds_Behind_Master是否为0，为0时则表示主从同步，可以安全切换，否则不会切换。

# 4.3 配置 server.xml

server.xml 主要用于设置系统变量、管理用户、设置用户权限等。

[root@binghe133 conf]$ vi server.xml

<?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>
		<property name="charset">utf8mb4</property>
		  <!-- <property name="useCompression">1</property>-->
		  <!--1为开启mysql压缩协议-->
		  <!-- <property name="processorBufferChunk">40960</property> -->
		  <!--
		  <property name="processors">1</property>
		  <property name="processorExecutor">32</property>
		   -->
			   <!--默认是65535 64K 用于sql解析时最大文本长度 -->
			   <!--<property name="maxStringLiteralLength">65535</property>-->
			   <!--<property name="sequnceHandlerType">0</property>-->
			   <!--<property name="backSocketNoDelay">1</property>-->
			   <!--<property name="frontSocketNoDelay">1</property>-->
			   <!--<property name="processorExecutor">16</property>-->
			   <!-- <property name="mutiNodeLimitType">1</property> 0：开启小数量级（默认） ；1：开启亿级数据排序
					  <property name="mutiNodePatchSize">100</property> 亿级数量排序批量
					 <property name="processors">32</property> <property name="processorExecutor">32</property>
					 <property name="serverPort">8066</property> <property name="managerPort">9066</property>
					 <property name="idleTimeout">300000</property> <property name="bindIp">0.0.0.0</property>
					 <property name="frontWriteQueueSize">4096</property>
				<property name="processors">32</property>
			   -->
		  </system>
		  <!-- 用户1，对应的MyCat逻辑库连接到的数据节点对应的主机为MySQL主从复制配置中的Master节点，没实现读写分离，读写都在该Master节点中进行  -->
		  <!--
		  <user name="user1">
			   <property name="password">roncoo.1</property>
			   <property name="schemas">rc_schema1,pay_schema1</property>
		  </user>
		  -->
		  <!-- 用户2，对应的MyCat逻辑库连接到的数据节点对应的主机为主从复制集群，并通过MyCat实现了读写分离 -->
		  <user name="lyz">
			   <property name="password">lyz.123</property>
			   <property name="schemas">lyz_schema1,lyz_schema2</property>
		  </user>
		  <!-- 用户3，只读权限-->
		  <user name="userlyz">
			   <property name="password">lyz.123</property>
			   <property name="schemas">lyz_schema1,lyz_schema2</property>
			   <property name="readOnly">true</property>
		  </user>
</mycat:server>

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47

# 4.4 防火墙中打开8066和9066端口

MyCat的默认数据端口为8066，mycat通过这个端口接收数据库客户端的访问请求。管理端口为9066，用来接收mycat监控命令、查询mycat运行状况、重新加载配置文件等。

[root@binghe133 mycat]# vi /etc/sysconfig/iptables

增加：

## MyCat
-A INPUT -m state --state NEW -m tcp -p tcp --dport 8066 -j ACCEPT
-A INPUT -m state --state NEW -m tcp -p tcp --dport 9066 -j ACCEPT

1
2
3

重启防火墙：

[root@binghe133 mycat]# service iptables restart

# 4.5 修改log日志级别为debug

修改log日志级别为debug，以便通过日志确认基于MyCat的MySQL数据库集群读写分离的数据操作状态（可以在正式上生产前改成info级别）

[root@binghe133 conf]$ vi /usr/local/mycat/conf/log4j.xml

# 4.6 启动root

[root@binghe133 bin]$ cd /usr/local/root/bin/

(1) 控制台启动，这种启动方式在控制台关闭后，root服务也将关闭，适合调试使用：

[root@binghe133 bin]$ ./root console

(2) 可以采用以下后台启动的方式：

[root@binghe133 bin]$ ./root start
Starting root-server...

1
2

（对应的，重启: root restart ， 关闭: root stop ）

# 4.7 MyCat连接测试

(1) 如果本地Windows安装有MySQL，可以使用已有的mysql客户端远程操作Mycat

(2) Nativecat连接Mycat

# 4.8 读写分离测试

(1) 监听MyCat日志

[root@binghe133 ~]$ cd /usr/local/mycat/logs/
[root@binghe133 logs]$ tail -f mycat.log

1
2

(2) 读测试

$ mysql -uuserlyz -plyz.123 -h192.168.209.233 -P8066
mysql> show databases;

1
2

mysql> use lyz_schema2;

mysql> show tables;

mysql> select * from lyz_user_02;

执行上面的查询语句，此时对应的MyCat日志信息如下：

多次执行 select * from lyz_user_02 语句，Mycat打印出来的日志信息显示读操作请求都是路由到Slave节点（192.168.209.132）

(2) 写测试

mysql> insert into lyz_user_02 (userName, pwd) values('binghe', 'lyz。123');

执行上面的新增插入语句后，此时对应的Mycat日志信息如下：

多次执行以上插入语句，发现新增数据都是从 Master节点（192.168.209.131）插进入的，并且Slave节点通过Binlog同步了Master节点中的数据。

综上，基于MyCat的读写分离集群配置成功。

下一篇，将为大家介绍MyCat集群部署（HAProxy + MyCat）相关的内容。

好了，今天就到这儿吧，我是冰河，我们下期见~~

# 星球服务

加入星球，你将获得：

1.项目学习：微服务入门必备的SpringCloud Alibaba实战项目、手写RPC项目—所有大厂都需要的项目【含上百个经典面试题】、深度解析Spring6核心技术—只要学习Java就必须深度掌握的框架【含数十个经典思考题】、Seckill秒杀系统项目—进大厂必备高并发、高性能和高可用技能。

2.框架源码：手写RPC项目—所有大厂都需要的项目【含上百个经典面试题】、深度解析Spring6核心技术—只要学习Java就必须深度掌握的框架【含数十个经典思考题】。

3.硬核技术：深入理解高并发系列（全册）、深入理解JVM系列（全册）、深入浅出Java设计模式（全册）、MySQL核心知识（全册）。

4.技术小册：深入理解高并发编程（第1版）、深入理解高并发编程（第2版）、从零开始手写RPC框架、SpringCloud Alibaba实战、冰河的渗透实战笔记、MySQL核心知识手册、Spring IOC核心技术、Nginx核心技术、面经手册等。

5.技术与就业指导：提供相关就业辅导和未来发展指引，冰河从初级程序员不断沉淀，成长，突破，一路成长为互联网资深技术专家，相信我的经历和经验对你有所帮助。

冰河的知识星球是一个简单、干净、纯粹交流技术的星球，不吹水，目前加入享5折优惠，价值远超门票。加入星球的用户，记得添加冰河微信：hacker_binghe，冰河拉你进星球专属VIP交流群。

# 星球重磅福利

跟冰河一起从根本上提升自己的技术能力，架构思维和设计思路，以及突破自身职场瓶颈，冰河特推出重大优惠活动，扫码领券进行星球，直接立减149元，相当于5折， 这已经是星球最大优惠力度！

领券加入星球，跟冰河一起学习《SpringCloud Alibaba实战》、《手撸RPC专栏》和《Spring6核心技术》，更有已经上新的《大规模分布式Seckill秒杀系统》，从零开始介绍原理、设计架构、手撸代码。后续更有硬核中间件项目和业务项目，而这些都是你升职加薪必备的基础技能。

100多元就能学这么多硬核技术、中间件项目和大厂秒杀系统，如果是我，我会买他个终身会员！

# 其他方式加入星球

链接：打开链接 http://m6z.cn/6aeFbs (opens new window) 加入星球。
回复：在公众号 冰河技术 回复星球领取优惠券加入星球。

特别提醒： 苹果用户进圈或续费，请加微信 hacker_binghe 扫二维码，或者去公众号 冰河技术 回复星球扫二维码加入星球。

# 星球规划

后续冰河还会在星球更新大规模中间件项目和深度剖析核心技术的专栏，目前已经规划的专栏如下所示。

# 中间件项目

《大规模分布式定时调度中间件项目实战（非Demo）》：全程手撸代码。
《大规模分布式IM（即时通讯）项目实战（非Demo）》：全程手撸代码。
《大规模分布式网关项目实战（非Demo）》：全程手撸代码。
《手写Redis》：全程手撸代码。
《手写JVM》全程手撸代码。

# 超硬核项目

《从零落地秒杀系统项目》：全程手撸代码，在阿里云实现压测（已上新）。
《大规模电商系统商品详情页项目》：全程手撸代码，在阿里云实现压测。
其他待规划的实战项目，小伙伴们也可以提一些自己想学的，想一起手撸的实战项目。。。

既然星球规划了这么多内容，那么肯定就会有小伙伴们提出疑问：这么多内容，能更新完吗？我的回答就是：一个个攻破呗，咱这星球干就干真实中间件项目，剖析硬核技术和项目，不做Demo。初衷就是能够让小伙伴们学到真正的核心技术，不再只是简单的做CRUD开发。所以，每个专栏都会是硬核内容，像《SpringCloud Alibaba实战》、《手撸RPC专栏》和《Spring6核心技术》就是很好的示例。后续的专栏只会比这些更加硬核，杜绝Demo开发。

小伙伴们跟着冰河认真学习，多动手，多思考，多分析，多总结，有问题及时在星球提问，相信在技术层面，都会有所提高。将学到的知识和技术及时运用到实际的工作当中，学以致用。星球中不少小伙伴都成为了公司的核心技术骨干，实现了升职加薪的目标。

# 联系冰河

# 加群交流

本群的宗旨是给大家提供一个良好的技术学习交流平台，所以杜绝一切广告！由于微信群人满 100 之后无法加入，请扫描下方二维码先添加作者 “冰河” 微信(hacker_binghe)，备注：星球编号。

冰河微信

# 公众号

分享各种编程语言、开发技术、分布式与微服务架构、分布式数据库、分布式事务、云原生、大数据与云计算技术和渗透技术。另外，还会分享各种面试题和面试技巧。内容在 冰河技术 微信公众号首发，强烈建议大家关注。

公众号：冰河技术

# 视频号

定期分享各种编程语言、开发技术、分布式与微服务架构、分布式数据库、分布式事务、云原生、大数据与云计算技术和渗透技术。另外，还会分享各种面试题和面试技巧。

视频号：冰河技术

# 星球

加入星球 冰河技术 (opens new window)，可以获得本站点所有学习内容的指导与帮助。如果你遇到不能独立解决的问题，也可以添加冰河的微信：hacker_binghe，我们一起沟通交流。另外，在星球中不只能学到实用的硬核技术，还能学习实战项目！

关注冰河技术 (opens new window)公众号，回复 星球 可以获取入场优惠券。

知识星球：冰河技术

← 第18章：路由转发实例解析第20章：Mycat集群部署 →