使用mycat实现mysql读写分离
2018-05-06 本文已影响86人
江江的大猪
使用mycat实现mysql读写分离
mycat在数据层的作用和nginx在应用层很像,都是代理后面实际的服务。mycat实现了mysql协议,对外看起来就是一个mysql数据库,可以和使用普通mysql一样进行操作
- 首先去官网下载对应操作系统的mycat,现在的稳定版是1.6
- mycat还提供了一个mycat-web的服务用来可视化操作,还没研究
- 下载解压后修改conf中的schema.xml
这个配置是自顶向下的,理解起来应该从下往上看。dataHost对应实际的mysql集群,
<!--配置一个mycat的逻辑库,指定要用的dataNode,也就是在使用mycat的时候,里面会有一个lfz_scheme库,实际对应mysql集群中的lfz库-->
<schema name="lfz_schema" checkSQLschema="false" sqlMaxLimit="100" dataNode="dn1"/>
<!--配置一个节点,选在要使用的dataHost,和数据库-->
<dataNode name="dn1" dataHost="localhost1" database="lfz"/>
<!--
当MySQL按照之前的主从复制方式配置好集群以后,可以开启Mycat的读写分离机制,以以下的配置为例,
表明一个从节点hostS1与一个主节点hostM1组成了标准的一主一从的读写分离模式,参数balance决定了哪些MySQL服务器参与到读SQL的负载均衡中,
0为不开启读写分离,1为全部的readHost与standby writeHost参与select语句的负载均衡,比如我们配置了1主3从的MySQL主从环境,
并把第一个从节点MySQL配置为dataHost中的第二个writeHost,以便主节点宕机后,Mycat自动切换到这个writeHost上来执行写操作,
此时balance=1就意味着第一个writeHost不参与读SQL的负载均衡,其他3个都参与;balance=2则表示所有的writeHost不参与,
此时,只有2个readHost参与负载均衡。这里有一个细节需要你知道,readHost是从属于writeHost的,即意味着它从那个writeHost获取同步数据,
因此,当它所属的writeHost宕机了,则它也不会再参与到读写分离中来,即“不工作了”,这是因为 此时,它的数据已经“不可靠”了。
基于这个考虑,目前mycat 1.3和1.4版本中,若想支持MySQL一主一从的标准配置,并且在 主节点宕机的情况下,从节点还能读取数据,
则需要在Mycat里配置为两个writeHost并设置banlance=1。
-->
<dataHost name="localhost1" maxCon="100" minCon="5" balance="1"
writeType="0" dbType="mysql" dbDriver="native" switchType="2" slaveThreshold="100">
<heartbeat>show slave status</heartbeat>
<writeHost host="hostM1" url="localhost:3306" user="root"
password="root"/>
<writeHost host="hostS1" url="localhost:3307" user="root"
password="root"/>
</dataHost>
<!--
writeType=1仅仅对于galera for mysql集群这种多主多节点都能写入的集群起效,此时Mycat会随机选择一个writeHost并写入数据,
对于非galera for mysql集群,请不要配置writeType=1,会导致数据库不一致的严重问题。 Mycat目前支持自动方式、编程指定的两种读写分离方式:
自动方式,即一个查询SQL是自动提交模式,对应于connection.setAutocommit(true) 或者 set autocommit=1
编程指定方式,即一个查询SQL语句以/*balance*/注解来确定其是走读节点还是写节点。在1.3版本里,若事务内的的查询语句增加此注解,则强制其走读节点,
而1.4版本里继续强化,可以在非事务内的查询语句前增加此注解,强制走写节点,这个 增强是为了避免主从不同步的情况下要求查询到刚写入的数据而做的增强。
另外 1.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时则表示主从同步,可以安全切换,否则不会 切换。
switchType 目前有三种选择:
- -1 表示不自动切换
- 1 默认值,自动切换
- 2 基于MySQL主从同步的状态决定是否切换
-->
- 配置server.xml
<!--设置编码集和sql解析器,一般都是druidparser-->
<system>
<property name="charset">utf8mb4</property>
<property name="defaultSqlParser">druidparser</property>
</system>
<!--配置用户、密码、以及该用户能访问的逻辑库,我们在应用中就通过这个用户访问lfz_schema库-->
<user name="root">
<property name="password">root</property>
<property name="schemas">lfz_schema</property>
</user>
- 可以将log4j.xml的日志级别改为debug,观察mycat是不是真的做到读写分离了
- mycat start,启动mycat
- 登录mycat mysql -uroot -proot -P8066 -h127.0.0.1登录mycat
- 我在云机器上无法启动mycat,查看日志发现jvm申请的内存太多了,可以修改wrapper.conf修改
wrapper.java.additional.5=-XX:MaxDirectMemorySize=256M
wrapper.java.additional.10=-Xmx256M
wrapper.java.additional.11=-Xms256M