mycat部署和配置读写分离（二）

说明：
MyCAT 是使用 JAVA 语言进行编写开发，使用前需要先安装 JAVA 运行环境(JRE),由于 MyCAT 中使用了 JDK7 中的一些特性，所以要求必须在 JDK7 以上的版本上运行。

1. jdk1.8安装

详见jdk环境安装

2. Mysql安装

详见mysql8.0.11源码安装，实际使用的是mysql8.0.16

3. Mysql 主从配置

详见主从同步原理和mysql的主从同步详解

3.1 安装mycat服务

3.1.1 部署mycat

cd /root
wget http://dl.mycat.org.cn/1.6.7.6/20210303094759/Mycat-server-1.6.7.6-release-20210303094759-linux.tar.gz
tar -xf Mycat-server-1.6.7.6-release-20210303094759-linux.tar.gz -C /usr/local
cd /usr/local/mycat/conf

• /usr/local/mycat/conf/server.xml：定义用户以及系统相关变量，如端口等。其中用户信息是前端应用程序连接 mycat 的用户信息。
• /usr/local/mycat/conf/schema.xml：定义逻辑库，表、分片节点等内容。
• /usr/local/mycat/conf/rule.xml：定义分片规则
  

3.1.2 server.xml配置文件

server.xml文件跟读写分离策略关系不大，但是需要用此文件来配置连接MyCat的用户及权限等（关注user标签即可），因此在这里简单说明。

<user name="mycat" defaultAccount="true">  #通过mycat登录的用户名和密码
                <property name="password">123456</property>
                <property name="schemas">mycatDB</property> <!-- #逻辑库，真实不存在的库，可以自定义修改，但一定要对应上，要不然就会报错 -->
                <property name="defaultSchema">mycatDB</property>  <!-- #逻辑库，真实不存在的库，可以自定义修改 -->
                <!-- 表级 DML 权限设置 -->
                <!--            
                <privileges check="false">
                        <schema name="TESTDB" dml="0110" >               #0000分表表示数据库的增删改查,0比表示关闭，1表示打开，如果配置 name需和前面定义的一致
                                <table name="tb01" dml="0000"></table>   #0000分表表示数据表的增删改查,0比表示关闭，1表示打开
                                <table name="tb02" dml="1111"></table>
                        </schema>
                </privileges>           
                 -->
        </user>
        <user name="user">  <!-- 这个账号只能读不能写，见下面的定义readOnly -->
                <property name="password">user</property>
                <property name="schemas">mycatDB</property>
                <property name="readOnly">true</property>
                <property name="defaultSchema">mycatDB</property>
</user>

说明：

• server.xml文件里登录mycat的用户名和密码可以任意定义，这个账号和密码是为客户机登录mycat时使用的账号信息。
• 逻辑库名(如上面的mycatDB，也就是登录mycat后显示的库名，切换这个库之后，显示的就是代理的真实mysql数据库的表)要在schema.xml里面也定义，否则会导致mycat服务启动失败！
• 这里只定义了一个标签，所以把多余的都注释了。如果定义多个标签，即设置多个连接mycat的用户名和密码，那么就需要在schema.xml文件中定义多个对应的库！

3.1.3 schema.xml配置文件

schema.xml是最主要的配置项，此文件关联mysql读写分离策略！读写分离、分库分表策略、分片节点都是在此文件中配置的！MyCat作为中间件，它只是一个代理，本身并不进行数据存储，需要连接后端的MySQL物理服务器，此文件就是用来连接MySQL服务器的！

schema.xml文件分为三部分，分别时schema、dataNode、dataHost

• schema

<schema name="mycatDB" checkSQLschema="true" sqlMaxLimit="100" dataNode="dn1">  <!-- 其中name要和server.xml中定义的逻辑看必须一致；checkSQLschema 表示是否检测语法，一般不需要，因为要连接多个数据库，语法不一样；sqlMaxLimit 每个sql语句最多返回100条-->

<!-- 如果不进行分库分表，下面的配置可以不用管，注释即可 -->
                <!-- auto sharding by id (long) -->
                <!--splitTableNames 启用<table name 属性使用逗号分割配置多个表,即多个表使用这个配置-->
        <!--    <table name="travelrecord,address" dataNode="dn1,dn2,dn3" rule="auto-sharding-long" splitTableNames ="true"/>  -->
                <!-- <table name="oc_call" primaryKey="ID" dataNode="dn1$0-743" rule="latest-month-calldate"
                        /> -->
</schema>

• dataNode

<!-- dataNode用于配置物理数据库的名称,name可以自定义；dataHost自定义，但是需要和后面的dataHost有对应关系；database是真实存在的库 -->
<!-- <dataNode name="dn1$0-743" dataHost="localhost1" database="db$0-743" /> -->

• dataHost

<!-- dataHost 是用于配置读写分离的，name 自定义，但需要和dataNode中的dataHost完全一致；maxCon和minCon 表示最大最小连接数量；balance表示负载均衡策略；writeType已废弃，无需关注；dbType是mycat连接数据库的类型；dbDriver指数据库的驱动类型（如果dbType配的是Oracle,dbDriver则是jdbc）；switchType 配置故障切换类型，需要配合下面的心跳机制heartbeat；slaveThreshold 指的是从节点的数量-->

<dataHost name="localhost1" maxCon="1000" minCon="10" balance="0"
                          writeType="0" dbType="mysql" dbDriver="native" switchType="1"  slaveThreshold="100">
                <heartbeat>select user()</heartbeat>  <!-- 心跳sql语句，需要配置故障切换类型 -->
                <!-- can have multi write hosts -->

                <!-- 写节点的配置：host 自定义即可；url 数据库的url连接地址；user 和 password指访问这个库的用户名和密码;如果是一主一从就配置一个writeHost和一个readHost，一主多从>就配置一个writeHost和多个readHost，多主多从就配置多个writeHost和多个readHost -->
                <writeHost host="hostM1" url="localhost:3306" user="root"
                                   password="123456">
                       <!-- can have multi read hosts -->
                       <!-- 读节点的配置： host 自定义即可；url 数据库的url连接地址；user 和 password指访问这个库的用户名和密码 -->
                       <readHost host="hostS1" url="localhost:3316" user="root" password="123456" />
                </writeHost>

                <!-- <writeHost host="hostM2" url="localhost:3316" user="root" password="123456"/> -->
</dataHost>

3.1.4 标签属性

Balance属性

• balance=“0”：不开启读写分离机制，所有读操作都发送到当前可用的writeHost 上,即读请求仅发送到writeHost上。
• balance=“1”：
  读请求随机分发到当前writeHost对应的readHost和standby的writeHost上。即全部的readHost与stand
  by writeHost 参与select 语句的负载均衡，简单的说，当双主双从模式(M1 ->S1 ， M2->S2，并且 M1 与
  M2 互为主备)，正常情况下，M2,S1,S2 都参与 select 语句的负载均衡
  balance=“2”：读请求随机分发到当前dataHost内所有的writeHost和readHost上。即所有读操作都随机的在writeHost、
  readhost 上分发。
• balance=“3”：读请求随机分发到当前writeHost对应的readHost上。即所有读请求随机的分发到 wiriterHost
  对应的 readhost 执行,writerHost 不负担读压力，注意 balance=3 只在 1.4 及其以后版本有，1.3 没有。

writeType属性（已废弃，直接跳过）

• writeType=“0”：所有写操作发送到配置的第一个
  writeHost，第一个挂了切到还生存的第二个writeHost，重新启动后以切换后的为准，切换记录在配置文件中:dnindex.properties
  .
• writeType=“1”：所有写操作都随机的发送到配置的writeHost。
• writeType=“2”：没实现。

switchType 属性,主从切换（双主failover）

• switchType=“-1”：不自动切换
• switchType=“1”：默认值，自动切换
• switchType=“2”：基于MySQL主从同步的状态来决定是否切换。需修改heartbeat语句（即心跳语句）：show slave status
• switchType=“3”：基于Mysql Galera
  Cluster（集群多节点复制）的切换机制。需修改heartbeat语句（即心跳语句）：show status like ‘wsrep%’

dbType属性
指定后端连接的数据库类型，目前支持二进制的mysql协议，还有其他使用JDBC连接的数据库。例如：mongodb、oracle、spark等。

dbDriver属性
指定连接后端数据库使用的Driver，目前可选的值有native和JDBC。

• native
  使用native的话，因为这个值执行的是二进制的mysql协议，所以可以使用mysql和maridb。
• JDBC
  其他类型的数据库则需要使用JDBC驱动来支持。从1.6版本开始支持postgresql的native原始协议。
  如果使用JDBC的话需要将符合JDBC 4标准的驱动JAR包放到MYCAT\lib目录下，并检查驱动JAR包中包括如下目录结构的文件：META-INF\services\java.sql.Driver。在这个文件内写上具体的Driver类名，例如：com.mysql.jdbc.Driver。

3.1.5 读写分离配置

cat server.xml

...
...
...
        <user name="mycat" defaultAccount="true">
                <property name="password">mycat123</property>
                <property name="schemas">mycatDB</property>
                <property name="defaultSchema">mycatDB</property>
        </user>
...
...
...

cat schema.xml

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

        <schema name="mycatDB" checkSQLschema="false" sqlMaxLimit="100" dataNode="dn1">
        </schema>
        <dataNode name="dn1" dataHost="localhost1" database="external_service" />
        <dataHost name="localhost1" maxCon="1000" minCon="10" balance="3" writeType="0" dbType="mysql" dbDriver="native" switchType="1"  slaveThreshold="100">
                <heartbeat>show slave status</heartbeat>
                <writeHost host="hostM1" url="10.99.200.110:3306" user="dba" password="dba110">
                     <readHost host="hostS1" url="10.99.200.111:3306" user="dba" password="dba111" />
                </writeHost>
        </dataHost>
</mycat:schema>

3.1.6 启动服务

修改mycat的启动内存（/usr/local/mycat/conf/wrapper.conf）

启动方式

cd /usr/local/mycat/bin 
./mycat console|stop|start|restart|dump    #前台启动|停止|后台启动|导入

登录验证
主从同步ok

手动使得主从的数据不一致

验证读写分离

读的是从节点的数据