Mycat实现MySQL的分库分表、读写分离、主从切换
admin
2023-04-30 12:23:39
0次
最近主要投入在平安云MySQL DRDS的项目中，本人主要负责zookeeper模块的配置及后台脚本的编写。为了加深对DRDS整体架构的认识，我觉得有必要手工搭建基于Mycat实现的Mysql分布式数据库集群，现和大家分享下搭建流程，后续会针对Mycat的各项配置作进一步研究，敬请期待。
Mycat及MySQL实例部署情况：
Mycat：
IP：10.20.8.57，Port：3310/3311
MySQL ：
db1-M1，IP：10.20.8.126，Port：3306
db1-M2，IP：10.20.8.126，Port：3307
db2-M1，IP：10.25.80.7，Port：3307
架构图如下：
配置Mycat
server.xml：
1
0
druidparser
2
0
3310
3311
0
1
1m
1k
0
389m
123456
db
false
schema.xml：
select user();
select user();
修改rule.xml中下列配置项：
id
mod-long
2
配置文件中各标签的含义可参考文章：MyCat关键配置说明
启动Mycat:
[root@SZB-L0059021 bin]# ./mycat start
Starting Mycat-server...
[root@SZB-L0059021 bin]# ./mycat status
Mycat-server is running (27020).
[root@SZB-L0059021 bin]# mysql -uroot -p123456 -Ddb -h227.0.0.1 -P3310分库分表验证：
mysql> show tables;
+--------------+
| Tables in db |
+--------------+
| t1 |
+--------------+
1 row in set (0.00 sec)
mysql> desc t1;
+---------+-------------+------+-----+---------+-------+
| Field | Type | Null | Key | Default | Extra |
+---------+-------------+------+-----+---------+-------+
| id | int(11) | YES | | NULL | |
| db_name | varchar(20) | YES | | NULL | |
+---------+-------------+------+-----+---------+-------+
2 rows in set (0.01 sec)
mysql> insert into t1(id,db_name) values(1,database());
Query OK, 1 row affected (0.01 sec)
mysql> insert into t1(id,db_name) values(2,database());
Query OK, 1 row affected (0.03 sec)
mysql> select * from t1;
+------+---------+
| id | db_name |
+------+---------+
| 2 | db1 | --id=2，对2取模为0，所以插入dn1
| 1 | db2 | --id=1，对2取模为1，所以插入dn2
+------+---------+
2 rows in set (0.01 sec)
上述查询结果可知，两次插入的数据分落入了db1、db2上，实现了分库读写分离验证：
mysql> select * from t1;
+------+---------+
| id | db_name |
+------+---------+
| 2 | db1 | --来自shard1上的db1-M2
| 1 | db2 | --来自shard2上的db2-M1
+------+---------+
2 rows in set (0.01 sec)
查看日志可知，上述查询结果来自dn1中db1-M2（端口3307）和dn2中的db2-M1：
2018-05-08 15:03:39.385 DEBUG [$_NIOREACTOR-0-RW] (io.mycat.server.NonBlockingSession.execute(NonBlockingSession.java:110)) - ServerConnection [id=1, schema=db, host=127.0.0.1, user=root,txIsolation=3, autocommit=true, schema=db]select * from t1, route={
1 -> dn1{SELECT *
FROM t1
LIMIT 100}
2 -> dn2{SELECT *
FROM t1
LIMIT 100}
}
...
2018-05-08 15:03:39.391 DEBUG [$_NIOREACTOR-0-RW] (io.mycat.backend.mysql.nio.handler.MultiNodeQueryHandler.rowEofResponse(MultiNodeQueryHandler.java:311)) - on row end reseponse MySQLConnection [id=29, lastTime=1525763019368, user=root, schema=db1, old shema=db1, borrowed=true, fromSlaveDB=true, threadId=511, charset=utf8, txIsolation=3, autocommit=true, attachment=dn1{SELECT *
FROM t1
LIMIT 100}, respHandler=io.mycat.backend.mysql.nio.handler.MultiNodeQueryHandler@66328ec4, host=10.20.8.126, port=3307, statusSync=null, writeQueue=0, modifiedSQLExecuted=false]
...
2018-05-08 15:03:39.392 DEBUG [$_NIOREACTOR-0-RW] (io.mycat.backend.mysql.nio.handler.MultiNodeQueryHandler.rowEofResponse(MultiNodeQueryHandler.java:311)) - on row end reseponse MySQLConnection [id=3, lastTime=1525763019387, user=root, schema=db2, old shema=db2, borrowed=true, fromSlaveDB=false, threadId=28, charset=utf8, txIsolation=3, autocommit=true, attachment=dn2{SELECT *
FROM t1
LIMIT 100}, respHandler=io.mycat.backend.mysql.nio.handler.MultiNodeQueryHandler@66328ec4, host=10.25.80.7, port=3307, statusSync=null, writeQueue=0, modifiedSQLExecuted=false]
...主从切换：
通过查看mycat/conf目录下的dnindex.properties文件，可以知道mycat正在使用的writeHost，0表示schema.xml中dataHost标签下的第一个writeHost。
[root@SZB-L0059021 conf]# cat dnindex.properties
#update
#Tue May 08 12:59:24 CST 2018
shard2=0
shard1=0 --此时状态正常，mycat选取每个dataHost标签中的第一个writeHost作为写入入口切换至10.20.8.126主机，并手动停掉db1-M1
10.20.8.126:3306:Master > mysqladmin -uroot -p123456 shutdown回到10.20.8.57（mycat主机），再次查看dnindex.properties
[root@SZB-L0059021 conf]# cat dnindex.properties
#update
#Tue May 08 15:12:12 CST 2018
shard2=0
shard1=1 --db1-M1被shutdown后，mycat在shard1上的writeHost切换至db1-M2切换至10.20.8.57（mycat所在主机），执行下述insert命令
mysql> insert into t1(id,db_name) values(4,database());
Query OK, 1 row affected (0.01 sec)
查看日志可知，Mycat此时选择通过db1-M2（端口3307）写入数据：
2018-05-08 15:13:44.987 DEBUG [$_NIOREACTOR-0-RW] (io.mycat.server.NonBlockingSession.releaseConnection(NonBlockingSession.java:341)) - release connection MySQLConnection [id=24, lastTime=1525763624968, user=root, schema=db1, old shema=db1, borrowed=true, fromSlaveDB=false, threadId=506, charset=utf8, txIsolation=3, autocommit=true, attachment=dn1{insert into t1(id,db_name) values(4,database())}, respHandler=SingleNodeHandler [node=dn1{insert into t1(id,db_name) values(4,database())}, packetId=1], host=10.20.8.126, port=3307, statusSync=null, writeQueue=0, modifiedSQLExecuted=true]由于dataHost中配置了writeType="0"，所以即使db1-M1重启恢复后，Mycat仍然会选择db1-M2作为shard1的
writeHost。
验证：
切换至10.20.8.126主机，并手动启动db1-M1
10.20.8.126:3306:Master > mysqld_safe &
在Mycat中插入验证数据
mysql> insert into t1(id,db_name) values(6,database());
Query OK, 1 row affected (0.02 sec)
查看日志可知，数据仍通过db1-M2（端口3307）写入：
2018-05-08 15:16:09.579 DEBUG [$_NIOREACTOR-0-RW] (io.mycat.server.NonBlockingSession.releaseConnection(NonBlockingSession.java:341)) - release connection MySQLConnection [id=32, lastTime=1525763769548, user=root, schema=db1, old shema=db1, borrowed=true, fromSlaveDB=false, threadId=514, charset=utf8, txIsolation=3, autocommit=true, attachment=dn1{insert into t1(id,db_name) values(6,database())}, respHandler=SingleNodeHandler [node=dn1{insert into t1(id,db_name) values(6,database())}, packetId=1], host=10.20.8.126, port=3307, statusSync=null, writeQueue=0, modifiedSQLExecuted=true]此时要想让Mycat在shard1上的writeHost重新变为db1-M1，只需修改dnindex.properties中的shard1=1为shard1=0，并重启Mycat即可。
相关内容
热门资讯
暗访九华山景区曝光餐馆厕所陈放...
澎湃新闻记者 林牧之 钟明5月13日，澎湃新闻刊发《给5A体个检丨安徽九华山：有餐馆把食材放厕所，紧...
原创 “...
在科幻电影设想的未来中，拥有超能力的AI Agent常藏身于耳机。 《钢铁侠》里，AI助理贾维斯为史...
2026年手游旗舰手机推荐：O...
对于热爱手游的玩家而言，选择一款合适的旗舰手机至关重要。这不仅关乎游戏过程中的流畅度与画质体验，更关...
AI要成京东的新大腿了
作者 | 刘杰 编辑 | 魏晓 2026年刚开局，京东就在AI上亮出了一套组合拳。 他直接把基础大模...
一支年轻影像团队的“算法升空”...
“五一”期间，北京南苑森林公园举办第一届森林运动会。一场常规的活动拍摄，却因为空域管理的现实约束变得...
国台办：买再多的武器都是螳臂当...
5月13日，国务院台办举行例行新闻发布会。总台记者就台湾军购费用引发舆论质疑提问。发言人张晗表示，我...
豫篮联赛：赛场劲吹“文旅风”
汉服小姐姐在看台上翩翩起舞。胡斌 摄洛阳队球员上篮。胡斌 摄“五一”小长假后，豫篮联赛伴随着初夏的热...
凡星闪耀丨《武林外传》中小米扮...
张清（右）在免费餐厅为大家服务。张清在《武林外传》中饰演“丐帮弟子”小米（右）。在郑州的城市烟火气中...
卫华：做走向世界的“起重管家”
卫华集团智能生产车间。常晶晶 摄作为全省服务业大会的参会企业，河南卫华重型机械股份有限公司(以下简称...
在加快国际消费中心城市建设中彰...
“服务业是推动经济高质量发展的重要引擎，也是强化国家中心城市核心竞争力的重要支柱。”5月12日，省委...