Mysql进阶之Mycat中间件(三) 主从复制 + Mycat读写分离-张柏沛IT博客

正文内容

Mysql进阶之Mycat中间件(三) 主从复制 + Mycat读写分离

栏目:MySQL 发布时间:2020-01-29 21:48 浏览量:268

主从复制 + Mycat读写分离

Mycat不负责进行主从复制,主从复制是在MySQL上进行配置的。
之前读写分离是在Web应用,也就是TP5的database.php中配置的。现在我们直接在Mycat中配置。

任务条件如下:
mycat所在主机:204.175.124.51
主节点IP:125.22.28.4
主节点的分片节点:test1/test2/test3
从节点IP:125.22.28.5 和 125.22.28.6
从节点同步主节点的test1/test2/test3
test1~3的表t1是一个大表,将其数据按取模算法水平切分到test1~3中。
主节点挂掉时,从节点依然可以查数据。
开启主从复制延时,当从节点有延时,则从主节点读取数据。


1. 主从复制

125.22.28.4操作:

配置文件

server-id=4
log-bin=/var/lib/mysql/binlog
log-bin-index=/var/lib/mysql/binlog.index
binlog_format=mixed
expire_logs_days    = 10
max_binlog_size   = 100M
lower_case_table_names=1    # 忽略表名大小写

 

创建授权用户

grant replication slave on *.* to "repl"@"125.22.28.%" identified by "xxxxx";


 
查看master状态

show master status;
+---------------+----------+--------------+------------------+-------------------+
| File          | Position | Binlog_Do_DB | Binlog_Ignore_DB | Executed_Gtid_Set |
+---------------+----------+--------------+------------------+-------------------+
| binlog.000001 |      448 |              |                  |                   |
+---------------+----------+--------------+------------------+-------------------+

 

125.22.28.5操作:
修改uuid
select uuid();
vi /var/lib/mysql/auto.cnf
将查询到的uuid在auto.cnf中更新。

配置文件

server-id=5
relay-log=/var/lib/mysql/slave-bin
relay-log-index=/var/lib/mysql/slave-bin.index
replicate-do-db=test1
replicate-do-db=test2
replicate-do-db=test3
replicate-do-db=mysql
slave-skip-errors=all
binlog_format=mixed
lower_case_table_names=1    # 忽略表名大小写

指向主节点:

stop slave;
reset slave;
change master to master_host="125.22.28.4",master_user="repl",master_password="xxxxx",master_log_file="binlog.000001",master_log_pos=448;
start slave;

查看slave状态:
show slave status;


125.22.28.6操作同上

在 125.22.28.4中授权一个mycat用户,用于给mycat连接,两个从节点也会生成该用户。

grant all privileges on *.* to "mycat"@"204.175.124.51" identified by "opson12356";

在 125.22.28.4中创建test1~3,在从节点也会生成。

 

 

2.搭建Mycat的读写分离
配置schema.xml

<mycat:schema xmlns:mycat="http://io.mycat/">
    <schema name="test" checkSQLschema="true" sqlMaxLimit="100" randomDataNode="dn1,dn2,dn3">
        <table name="t1" primaryKey="ID" dataNode="dn1,dn2,dn3" rule="mod-long"></table>
    </schema>
    
    <dataNode name="dn1" dataHost="host1" database="test1"></dataNode>
    <dataNode name="dn2" dataHost="host1" database="test2"></dataNode>
    <dataNode name="dn3" dataHost="host1" database="test3"></dataNode>
    
    <dataHost name="host1" maxCon="1000" minCon="10" balance="1" writeType="0" dbType="mysql" dbDriver="native" switchType="1" slaveThreshold="100">
        <heartbeat>show slave status</heartbeat>
        <writeHost host="hostM1" url="125.22.28.4:3306" user="mycat" password="opson12356">
            <readHost host="hostS1" url="125.22.28.5:3306" user="mycat" password="opson12356"></readHost>
            <readHost host="hostS2" url="125.22.28.6:3306" user="mycat" password="opson12356"></readHost>
        </writeHost>
    </dataHost> 
</mycat:schema>

需要注意的点:
<table>一定要指定primaryKey来指定分片的字段。

rule="mod-long" 分片算法为取模

dataNode="dn1,dn2,dn3"  三个分片节点(库),有几个库就指定几个dataNode

<dataHost>  balance="1" 使用读写分离的负载均衡,只有备份写节点和读节点才会进行读操作。写节点不会进行读操作只进行写操作。

switchType="2" slaveThreshold="100"  从节点同步延时超过100就自动切换

<heartbeat>show slave status</heartbeat>    读写分离的heartbeat要使用show slave status语句,而不是select user()语句。

<readHost>包在了<writeHost>里面,那么当主机点<writeHost>崩溃的时候,从节点<readHost>就无法进行读操作。

遇到的几个问题:
1.<readHost>只能被包在<writeHost>里面,如果<readHost>和<writeHost>放在同级,启动mycat时就会报错。
2.mysql端记得设置忽略表名大小写,lower_case_table_names=1 ,不然会遇到很多麻烦。字段大小写是会自动忽略的。


3.配置server.xml 
增加用户

<user name="u1">
    <property name="password">xxx</property>
    <property name="schemas">test</property>
</user>

4.启动mycat 

mycat start   # 后台运行,mycat console 是前台运行
mycat status  # 查看状态

5.连接测试
mysql -h204.175.124.51 -uu1 -P8066 -pxxxxx
use test 

# 插入一条语句
insert into t1 (`id`,`name`,`type_id`) values (320,'mls2ki',1);

# 查询
select * from t1;


实验记录如下:
尝试关闭主节点主机的MySQL服务再查询。发现报错说 
backend connect: java.lang.Throwable: java.net.ConnectException: Connection refused
说明主节点挂掉,从节点查询就会失败,符合配置文件的设置。

尝试关闭所有从节点的MySQL服务再查询。
发现报错说
backend connect: java.lang.Throwable: java.net.ConnectException: Connection refused
说明从节点挂掉之后,mycat不会从主节点进行查询(balance="1"的作用)。

关闭其中从节点1,开启从节点2,发现依然可以查询。
关闭其中从节点2,开启从节点1,发现依然可以查询。
说明负载均衡实现了(balance="1"的作用)。


现在我们希望主节点关闭之后,从节点依旧可以进行读操作,可以将schema.xml的<dataHost>部分修改为:

<dataHost name="host1" maxCon="1000" minCon="10" balance="1" writeType="0" dbType="mysql" dbDriver="native" switchType="-1" slaveThreshold="100">
    <heartbeat>show slave status</heartbeat>
    <writeHost host="hostM1" url="125.22.28.4:3306" user="mycat" password="opson12356"></writeHost>
    <writeHost host="hostS1" url="125.22.28.5:3306" user="mycat" password="opson12356"></readHost>
    <writeHost host="hostS2" url="125.22.28.6:3306" user="mycat" password="opson12356"></readHost>
</dataHost> 

其关键是
将之前的两个<readHost>标签改为<writeHost>标签。这样主节点hostM1挂掉后,从节点依旧可以查询。
将swichType改为-1,这样主节点挂掉之后,从节点不会切换为主节点来写入数据,因为如果从节点写入数据,会造成多节点的数据不统一。

这个例子也说明:
从节点并非一定要用<readHost>标签。用<writeHost>的节点也可以是从节点。为了区分writeHost的节点是主节点还是从节点,可以用hostM1和hostS1来区分,当然这只是个名字,除了区分并没有实际作用。

实验记录如下:
尝试关闭主节点主机的MySQL服务再在Mycat查询,依然可以查询。但是在mycat中无法写入,说明从节点并没有切换为主节点担任写的任务
发现插入之后,查询到的数据没有新数据,有同步延时。此时可以将switchType改为2,balance改为2,当有延迟的时候就会从主节点读取而不会从从节点读取。但是如果主节点挂掉,从节点就会顶替主节点进行写,这是不好的地方。

如果您需要转载,可以点击下方按钮可以进行复制粘贴;本站博客文章为原创,请转载时注明以下信息

张柏沛IT技术博客 > Mysql进阶之Mycat中间件(三) 主从复制 + Mycat读写分离

热门推荐
推荐新闻