Mycat分布式数据库架构解决方案--Mycat实现读写分离

echo编辑整理，欢迎转载，转载请声明文章来源。欢迎添加echo微信(微信号：t2421499075)交流学习。 百战不败，依不自称常胜，百败不颓，依能奋力前行。——这才是真正的堪称强大！！！

---

安装完成以后，咱们对Mycat的重要配置文件进行了解析，到这里已经对Mycat有了必定的认识，那么咱们开始来启动Mycat并链接，作一些简单的配置和使用操做。

Mycat快速入门

• 准备工做：
• • 请如今服务器上面安装Mycat，安装教程：https://blog.csdn.net/xlecho/...
• • 了解一下他的核心配置文件：Server.xml详解、schema.xml详解、rule.xml详解
• • 准备三台服务器，都须要安装mysql
• • 搭建一主两从的MySQL读写分离环境：Mycat分布式数据库架构解决方案--搭建MySQL读写分离环境--一主多从
• • 下载一份Mycat的原码（在服务器上面编写不方便，本地更改好，替换服务器配置文件更方便）Mycat下载

Mycat配置所可能使用的命令

• 进入mycat安装的bin目录，启动命令：./startup_nowrap.sh
• 进入mycat安装的bin目录，中止命令：./mycat stop
• 查看是否存在运行mycat的进程: ps -ef
• 查看mycat时时运行日志，进入logs目录：more mycat.log
• 配置文件中删除一整行：vi打开配置文件，而后双击d键就会删除光标所在的一行
• 配置文件中删除一整块：点击v，而后移动左右键，光标移动就会选中移动区域，再点击x便可删除

配置Mycat

使用Mycat实现读写分离其实比较简单，只要关注他的两个配置文件schema.xml/server.xml。

• schema.xml主要负责数据库的链接配置
• server.xml主要负责Mycat登陆链接配置

schema

<?xml version="1.0"?>
<!DOCTYPE mycat:schema SYSTEM "schema.dtd">
<mycat:schema xmlns:mycat="http://io.mycat/">
    <schema name="userDB" checkSQLschema="true" sqlMaxLimit="100">
        <table name="user" primaryKey="id" dataNode="dn1" />
    </schema>

    <dataNode name="dn1" dataHost="host1" database="test" />

    <!-- 读写分离 -->
    <dataHost name="host1" maxCon="1000" minCon="10" balance="1" writeType="0" dbType="mysql" dbDriver="native" switchType="-1"  slaveThreshold="100">
        <heartbeat>select user()</heartbeat>
        <writeHost host="hostM" url="192.168.222.132:3306" user="root" password="123456">
            <readHost host="hostS1" url="192.168.222.133:3306" user="root" password="123456" />
            <readHost host="hostS2" url="192.168.222.134:3306" user="root" password="123456" />
        </writeHost>
    </dataHost>
</mycat:schema>

server

<?xml version="1.0" encoding="UTF-8"?>
<!-- - - Licensed under the Apache License, Version 2.0 (the "License");
        - you may not use this file except in compliance with the License. - You
        may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0
        - - Unless required by applicable law or agreed to in writing, software -
        distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT
        WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the
        License for the specific language governing permissions and - limitations
        under the License. -->
<!DOCTYPE mycat:server SYSTEM "server.dtd">
<mycat:server xmlns:mycat="http://io.mycat/">
    <!-- Mycat中有两个重要的标签，分别是user、system -->
    <!-- system标签与系统配置有关 -->
    <system>
        <!-- 配置该属性的时候必定要保证mycat的字符集和mysql 的字符集是一致的。
        若是须要配置特殊字符集，如：utf8mb4，则能够在index_to_charset.properties中配置，配置格式
        为“ID=字符集”,例如：“224=utf8mb4”-->
        <property name="charset">utf8</property>
        <!-- 1为开启实时统计、0为关闭 -->
        <property name="useSqlStat">0</property>
        <!-- 0为须要密码登录、1为不须要密码登录 ,默认为0，设置为1则须要指定默认帐户-->
        <property name="nonePasswordLogin">0</property>
        <property name="useHandshakeV10">1</property>
        <!-- 1为开启全加班一致性检测、0为关闭 -->
        <property name="useGlobleTableCheck">0</property>
        <!-- SQL 执行超时 单位:秒-->
        <property name="sqlExecuteTimeout">300</property>
        <!-- 指定使用 Mycat 全局序列的类型。 0 为本地文件方式，1 为数据库方式，2 为时间戳序列方式，3 为分布式ZK ID 生成器，4 为 zk 递增 id 生成。 -->
        <property name="sequnceHandlerType">5</property>
        <!-- 必须带有MYCATSEQ_或者 mycatseq_进入序列匹配流程 注意MYCATSEQ_有空格的状况 -->
        <property name="sequnceHandlerPattern">(?:(\s*next\s+value\s+for\s*MYCATSEQ_(\w+))(,|\)|\s)*)+</property>
        <!-- 子查询中存在关联查询的状况下,检查关联字段中是否有分片字段 .默认 false -->
        <property name="subqueryRelationshipCheck">false</property>
        <property name="sequenceHanlderClass">io.mycat.route.sequence.handler.HttpIncrSequenceHandler</property>
        <!-- 默认为type 0: DirectByteBufferPool | type 1 ByteBufferArena | type 2 NettyBufferPool -->
        <property name="processorBufferPoolType">0</property>
        <!-- 分布式事务开关，0为不过滤分布式事务，1为过滤分布式事务（若是分布式事务内只涉及全局表，则不过滤），2为不过滤分布式事务,可是记录分布式事务日志-->
        <property name="handleDistributedTransactions">0</property>
        <!-- off heap for merge/order/group/limit      1开启   0关闭 -->
        <property name="useOffHeapForMerge">0</property>
        <!-- 单位为m -->
        <property name="memoryPageSize">64k</property>
        <!-- 单位为k -->
        <property name="spillsFileBufferSize">1k</property>
        <property name="useStreamOutput">0</property>
        <!-- 单位为m -->
        <property name="systemReserveMemorySize">384m</property>
        <!--是否采用zookeeper协调切换  -->
        <property name="useZKSwitch">false</property>
        <!--若是为 true的话 严格遵照隔离级别,不会在仅仅只有select语句的时候在事务中切换链接-->
        <property name="strictTxIsolation">false</property>
        <property name="useZKSwitch">true</property>
    </system>

        <!-- name="root" 定义登陆用户名 -->
    <user name="root">
        <!-- 定义了登陆密码 -->
        <property name="password">123456</property>
        <property name="schemas">userDB</property>
    </user>
</mycat:server>

配置完成以后，咱们启动Mycat便可：

进入bin目录
./mycat start

验证是否已经成功实现读写分离

首先咱们在主服务器上增长两条数据，因为咱们实现mysql主从复制，这个时候增长的两条数据，其余两台从服务器都会同时增长。数据以下：

在主服务器上添加的数据因为MySQL主从复制，因此在每一台服务器上看到的都是同样的数据，可是在从服务器上添加的数据主服务器和另一台服务器上不会有，咱们就利用这个特性添加。

在从服务器192.168.222.134上添加一条数据，以下：

134服务器上就具有了其余服务器不具有的数据，因为咱们在schema中配置了写功能服务器13二、读133/134两台，因此Mycat读取数据的时候应该是随机读取133/134中的某一台，咱们登录Mycat而后打开user表，多刷新几回就能够看到id为5的那条数据时有时无

登录Mycat报错，先检查Mycat是否已经成功启动，若是没有启动能够进入mycat文件下logs目录中，打开wrapper.log查看缘由

注意：

• 配置登陆用户的时候，咱们的server要对应上咱们schemas中的逻辑库，否则会报错。
• 访问不到Mycat的时候检查端口8066，查看是否开放了端口

---

作一个有底线的博客主