文章详情

登录

短信预约-IT技能 免费直播动态提醒

选择考试省份

  • 北京
  • 上海
  • 天津
  • 重庆
  • 河北
  • 山东
  • 辽宁
  • 黑龙江
  • 吉林
  • 甘肃
  • 青海
  • 河南
  • 江苏
  • 湖北
  • 湖南
  • 江西
  • 浙江
  • 广东
  • 云南
  • 福建
  • 海南
  • 山西
  • 四川
  • 陕西
  • 贵州
  • 安徽
  • 广西
  • 内蒙
  • 西藏
  • 新疆
  • 宁夏
  • 兵团

请输入下面的图形验证码

提交验证

短信预约提醒成功

Mycat核心开发者带你轻松掌握Mycat路由转发！！

2024-12-03 17:12

关注

作者个人研发的在高并发场景下，提供的简单、稳定、可扩展的延迟消息队列框架，具有精准的定时任务和延迟队列处理功能。自开源半年多以来，已成功为十几家中小型企业提供了精准定时调度方案，经受住了生产环境的考验。为使更多童鞋受益，现给出开源框架地址：https://github.com/sunshinelyz/mykit-delay

写在前面

熟悉Mycat的小伙伴都知道，Mycat一个很重要的功能就是路由转发，那么，这篇文章就带着大家一起来看看Mycat是如何进行路由转发的，好了，不多说了，我们直接进入主题。

环境准备

软件版本

操作系统：CentOS-6.8

JDK版本：jdk1.8

Mycat版本：Mycat-server-1.6

MySQL：5.7

注意：这里，我将Mycat和MySQL安装在同一台虚拟机(IP：192.168.209.140 主机名为:binghe140)，大家也可以将Mycat和MySQL安装到不同的主机上，测试效果是一样的。

创建物理库

  1. mysql -uroot -proot -h192.168.209.140 -P3306 
  2.  
  3. drop database if exists db1; 
  4. create database db1; 
  5. drop database if exists db2; 
  6. create database db2; 
  7. drop database if exists db3; 
  8. create database db3; 

配置Mycat

schema.xml配置

 

  1. "1.0"?> 
  2. schema SYSTEM "schema.dtd"> 
  3. schema xmlns:mycat="http://org.opencloudb/" > 
  4.   
  5.  <schema name="binghe" checkSQLschema="false" sqlMaxLimit="100"> 
  6.   <table name="travelrecord" dataNode="dn1,dn2,dn3" rule="auto-sharding-long">table> 
  7.  schema> 
  8.  --  
  9.   /> --> 
  10.  name="dn1" dataHost="localhost1" database="db1" /> 
  11.  name="dn2" dataHost="localhost1" database="db2" /> 
  12.  name="dn3" dataHost="localhost1" database="db3" /> 
  13.  -- 
  14.   name="jdbc_dn1" dataHost="jdbchost" database="db1" />  
  15.  name="jdbc_dn2" dataHost="jdbchost" database="db2" />  
  16.  name="jdbc_dn3"  dataHost="jdbchost" database="db3" /> --> 
  17.  name="localhost1" maxCon="1000" minCon="10" balance="0" 
  18.   writeType="0" dbType="mysql" dbDriver="native" switchType="1"  slaveThreshold="100"> 
  19.   select user() 
  20.   -- can have multi write hosts --> 
  21.   "hostM1" url="127.0.0.1:3306" user="root" password="root"> 
  22.    
  23.   "hostM2" url="127.0.0.1:3306" user="root" password="root"> 
  24.   -- 
  25.    --password="123456" />--> 
  26.   --  --> 
  27.   
  28. schema> 

server.xml配置

  1. "1.0" encoding="UTF-8"?> 
  2. "server.dtd"> 
  3. "http://org.opencloudb/"> 
  4.   
  5.  name="defaultSqlParser">druidparser 
  6.   
  7.  <user name="binghe"> 
  8.   name="password">binghe.123 
  9.   name="schemas">binghe 
  10.  user> 
  11.  <user name="test"> 
  12.   name="password">test 
  13.   name="schemas">binghe 
  14.   name="readOnly">true 
  15.  user> 
  16.  

rule.xml配置

  1. "1.0" encoding="UTF-8"?> 
  2. rule SYSTEM "rule.dtd"> 
  3. rule xmlns:mycat="http://org.opencloudb/"> 
  4.  
    name="rule1"> 
  5.   <rule> 
  6.    id 
  7.    func1 
  8.   rule> 
  9.   
  10.   
  11.  
    name="rule2"> 
  12.   <rule> 
  13.    user_id 
  14.    func1 
  15.   rule> 
  16.   
  17.   
  18.  
    name="sharding-by-intfile"> 
  19.   <rule> 
  20.    sharding_id 
  21.    hash-int 
  22.   rule> 
  23.   
  24.  
    name="auto-sharding-long"> 
  25.   <rule> 
  26.    id 
  27.    rang-long 
  28.   rule> 
  29.   
  30.  
    name="mod-long"> 
  31.   <rule> 
  32.    id 
  33.    mod-long 
  34.   rule> 
  35.   
  36.  
    name="sharding-by-murmur"> 
  37.   <rule> 
  38.    id 
  39.    murmur 
  40.   rule> 
  41.   
  42.  
    name="sharding-by-month"> 
  43.   <rule> 
  44.    create_date 
  45.    partbymonth 
  46.   rule> 
  47.   
  48.  
    name="latest-month-calldate"> 
  49.   <rule> 
  50.    calldate 
  51.    latestMonth 
  52.   rule> 
  53.   
  54.   
  55.  
    name="auto-sharding-rang-mod"> 
  56.   <rule> 
  57.    id 
  58.    rang-mod 
  59.   rule> 
  60.   
  61.   
  62.  
    name="jch"> 
  63.   <rule> 
  64.    id 
  65.    jump-consistent-hash 
  66.   rule> 
  67.   
  68.   
  69.  <function name="murmur" 
  70.   class="org.opencloudb.route.function.PartitionByMurmurHash"> 
  71.   name="seed">0 
  72.   name="count">2 
  73.   name="virtualBucketTimes">160 
  74.  function> 
  75.  <function name="hash-int" 
  76.   class="org.opencloudb.route.function.PartitionByFileMap"> 
  77.   name="mapFile">partition-hash-int.txt 
  78.  function> 
  79.  <function name="rang-long" 
  80.   class="org.opencloudb.route.function.AutoPartitionByLong"> 
  81.   name="mapFile">autopartition-long.txt 
  82.  function> 
  83.  <function name="mod-long" class="org.opencloudb.route.function.PartitionByMod"> 
  84.   -- how many data nodes --> 
  85.   name="count">3 
  86.  function> 
  87.   
  88.  <function name="func1" class="org.opencloudb.route.function.PartitionByLong"> 
  89.   name="partitionCount">8 
  90.   name="partitionLength">128 
  91.  function> 
  92.  <function name="latestMonth" 
  93.   class="org.opencloudb.route.function.LatestMonthPartion"> 
  94.   name="splitOneDay">24 
  95.  function> 
  96.  <function name="partbymonth" 
  97.   class="org.opencloudb.route.function.PartitionByMonth"> 
  98.   name="dateFormat">yyyy-MM-dd 
  99.   name="sBeginDate">2020-01-01 
  100.  function> 
  101.   
  102.  <function name="rang-mod" class="org.opencloudb.route.function.PartitionByRangeMod"> 
  103.          name="mapFile">partition-range-mod.txt 
  104.  function> 
  105.   
  106.  <function name="jump-consistent-hash" class="org.opencloudb.route.function.PartitionByJumpConsistentHash"> 
  107.   name="totalBuckets">3 
  108.  function> 
  109. rule> 

登录Mycat

登录Mycat

命令行输入以下命令登录Mycat

  1. D:\>mysql -ubinghe -pbinghe.123 -h192.168.209.140 -P8066 
  2. Welcome to the MySQL monitor.  Commands end with ; or \g. 
  3. Your MySQL connection id is 2 
  4. Server version: 5.5.8-mycat-1.6.1-RELEASE-20170807215126 MyCat Server (OpenCloundDB) 
  5.   
  6. Copyright (c) 2000, 2016, Oracle and/or its affiliates. All rights reserved. 
  7.   
  8. Oracle is a registered trademark of Oracle Corporation and/or its 
  9. affiliates. Other names may be trademarks of their respective 
  10. owners. 
  11.   
  12. Type 'help;' or '\h' for help. Type '\c' to clear the current input statement. 
  13.   
  14. mysql> 

创建表测试

输入以下命令查看创建表的路由

  1. create table travelrecord (id bigint not null primary key,user_id varchar(100),traveldate DATE, fee decimal,days int);  

结果如下：

  1. mysql> explain create table travelrecord (id bigint not null primary key,user_id varchar(100),traveldate DATE, fee decimal,days int); 
  2. +-----------+-----------------------------------------------------------------------------------------------------------------------+ 
  3. | DATA_NODE | SQL                                                                                                                   | 
  4. +-----------+-----------------------------------------------------------------------------------------------------------------------+ 
  5. | dn1       | create table travelrecord (id bigint not null primary key,user_id varchar(100),traveldate DATE, fee decimal,days int) | 
  6. | dn2       | create table travelrecord (id bigint not null primary key,user_id varchar(100),traveldate DATE, fee decimal,days int) | 
  7. | dn3       | create table travelrecord (id bigint not null primary key,user_id varchar(100),traveldate DATE, fee decimal,days int) | 
  8. +-----------+-----------------------------------------------------------------------------------------------------------------------+ 
  9. 3 rows in set (0.00 sec) 
  10.   
  11. mysql> 

说明创建表的SQL语句被Mycat路由到dn1,dn2,dn3三个节点上，也就是说在3个节点上都执行了创建表的SQL。

我们输入建表语句：

  1. mysql> create table travelrecord (id bigint not null primary key,user_id varchar(100),traveldate DATE, fee decimal,days int); 
  2. Query OK, 0 rows affected (0.18 sec) 

此时，将会在dn1,dn2,dn3三个节点上创建travelrecord表。

录入数据测试

录入到dn1节点

我们在命令行输入如下SQL语句

  1. explain insert into travelrecord (id,user_id,traveldate,fee,days) values(100001,'binghe','2020-11-10',510.5,3); 

结果如下：

  1. mysql> explain insert into travelrecord (id,user_id,traveldate,fee,days) values(100001,'binghe','2017-08-07',510.5,3); 
  2. +-----------+-------------------------------------------------------------------------------------------------------------+ 
  3. | DATA_NODE | SQL                                                                                                         | 
  4. +-----------+-------------------------------------------------------------------------------------------------------------+ 
  5. | dn1       | insert into travelrecord (id,user_id,traveldate,fee,days) values(100001,'binghe','2017-08-07',510.5,3) | 
  6. +-----------+-------------------------------------------------------------------------------------------------------------+ 
  7. 1 row in set (0.00 sec) 

说明Mycat将SQL路由到了dn1节点。

我们执行插入语句：

  1. mysql> insert into travelrecord (id,user_id,traveldate,fee,days) values(100001,'binghe','2020-11-10',510.5,3); 
  2. Query OK, 1 row affected, 1 warning (0.01 sec) 
  3.   
  4. mysql> 

录入到dn2节点

我们在命令行输入如下语句：

  1. explain insert into travelrecord (id,user_id,traveldate,fee,days) values(8000004,'binghe','2017-08-07',510.5,3); 

结果如下：

  1. mysql> explain insert into travelrecord (id,user_id,traveldate,fee,days) values(8000004,'binghe','2020-11-10',510.5,3); 
  2. +-----------+--------------------------------------------------------------------------------------------------------------+ 
  3. | DATA_NODE | SQL                                                                                                          | 
  4. +-----------+--------------------------------------------------------------------------------------------------------------+ 
  5. | dn2       | insert into travelrecord (id,user_id,traveldate,fee,days) values(8000004,'binghe','2020-11-10',510.5,3) | 
  6. +-----------+--------------------------------------------------------------------------------------------------------------+ 
  7. 1 row in set (0.00 sec) 

说明Mycat将SQL路由到了dn2节点，我们执行插入语句：

  1. mysql> insert into travelrecord (id,user_id,traveldate,fee,days) values(8000004,'binghe','2017-08-07',510.5,3); 
  2. Query OK, 1 row affected, 1 warning (0.06 sec) 

路由到dn3节点

我们在命令行输入如下语句

  1. explain insert into travelrecord (id,user_id,traveldate,fee,days) values(10000004,'binghe','2017-08-07',510.5,3); 

结果为：

  1. mysql> explain insert into travelrecord (id,user_id,traveldate,fee,days) values(10000004,'binghe','2020-11-10',510.5,3); 
  2. +-----------+---------------------------------------------------------------------------------------------------------------+ 
  3. | DATA_NODE | SQL                                                                                                           | 
  4. +-----------+---------------------------------------------------------------------------------------------------------------+ 
  5. | dn3       | insert into travelrecord (id,user_id,traveldate,fee,days) values(10000004,'binghe','2020-11-10',510.5,3) | 
  6. +-----------+---------------------------------------------------------------------------------------------------------------+ 
  7. 1 row in set (0.00 sec) 

说明Mycat将SQL路由到了dn3节点，我们同样执行插入语句的操作

  1. mysql>  insert into travelrecord (id,user_id,traveldate,fee,days) values(10000004,'binghe','2017-08-07',510.5,3); 
  2. Query OK, 1 row affected, 1 warning (0.01 sec) 

查询测试

查询所有数据

在命令行执行如下语句：

  1. explain select * from travelrecord; 

结果为：

  1. mysql> explain select * from travelrecord; 
  2. +-----------+--------------------------------------+ 
  3. | DATA_NODE | SQL                                  | 
  4. +-----------+--------------------------------------+ 
  5. | dn1       | SELECT * FROM travelrecord LIMIT 100 | 
  6. | dn2       | SELECT * FROM travelrecord LIMIT 100 | 
  7. | dn3       | SELECT * FROM travelrecord LIMIT 100 | 
  8. +-----------+--------------------------------------+ 
  9. 3 rows in set (0.01 sec) 

说明查询所有的数据，Mycat是将SQL语句路由到了所有的数据分片，即dn1,dn2,dn3节点上。

根据id查询指定数据

我们分别在命令行中执行如下SQL:

  1. explain select * from travelrecord where id = 1000004; 
  2. explain select * from travelrecord where id = 8000004; 
  3. explain select * from travelrecord where id = 10000004; 

得到的结果依次如下：

  1. mysql> explain select * from travelrecord where id = 1000004; 
  2. +-----------+---------------------------------------------------------+ 
  3. | DATA_NODE | SQL                                                     | 
  4. +-----------+---------------------------------------------------------+ 
  5. | dn1       | SELECT * FROM travelrecord WHERE id = 1000004 LIMIT 100 | 
  6. +-----------+---------------------------------------------------------+ 
  7. 1 row in set (0.06 sec) 
  8.   
  9. mysql> explain select * from travelrecord where id = 8000004; 
  10. +-----------+---------------------------------------------------------+ 
  11. | DATA_NODE | SQL                                                     | 
  12. +-----------+---------------------------------------------------------+ 
  13. | dn2       | SELECT * FROM travelrecord WHERE id = 8000004 LIMIT 100 | 
  14. +-----------+---------------------------------------------------------+ 
  15. 1 row in set (0.00 sec) 
  16.   
  17. mysql> explain select * from travelrecord where id = 10000004; 
  18. +-----------+----------------------------------------------------------+ 
  19. | DATA_NODE | SQL                                                      | 
  20. +-----------+----------------------------------------------------------+ 
  21. | dn3       | SELECT * FROM travelrecord WHERE id = 10000004 LIMIT 100 | 
  22. +-----------+----------------------------------------------------------+ 
  23. 1 row in set (0.00 sec) 

说明：按照分片字段查询，Mycat只会将SQL路由到指定的数据分片。

删表测试

在命令行输入如下SQL：

  1. explain drop table travelrecord; 

结果如下

  1. mysql> explain drop table travelrecord; 
  2. +-----------+-------------------------+ 
  3. | DATA_NODE | SQL                     | 
  4. +-----------+-------------------------+ 
  5. | dn1       | drop table travelrecord | 
  6. | dn2       | drop table travelrecord | 
  7. | dn3       | drop table travelrecord | 
  8. +-----------+-------------------------+ 
  9. 3 rows in set (0.00 sec) 

有结果可知，删表操作和创建表操作一样，Mycat在本实例中都会将SQL路由到所有的数据分片。

注意：本文的Mycat路由结果针对本文的配置实例，其他配置下，Mycat的路由结果可能会有不同。

好了，我们今天就到这儿吧，我是冰河，我们下期见~~

本文转载自微信公众号「冰河技术」，可以通过以下二维码关注。转载本文请联系冰河技术公众号。

 

来源：冰河技术内容投诉

免责声明：

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的，并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据，供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题

  • 2024年上半年信息系统项目管理师第二批次真题及答案解析（完整版）

    难度     813人已做
    查看

  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看

  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看

  • 2024年上半年软考高项第一、二批次真题考点汇总（完整版）

    难度     435人已做
    查看

  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机

Mycat核心开发者带你轻松掌握Mycat路由转发！！

后端开发Mycat路由2024-12-03

Mycat核心开发者带你看尽Mycat三大核心配置文件！！

后端开发Mycat核心2024-12-03
位置：首页-资讯-后端开发
咦！没有更多了？去看看其它编程学习网 内容吧
首页课程
资料下载问答资讯