mycat实践

Posted 秦梁的小站

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了mycat实践相关的知识,希望对你有一定的参考价值。

本次实践基于ubuntu系统;
mycat:1.6.5;
采用 docker拉起3个 mysql容器,端口分别位于33061,33062,33063。

安装 java

 
   
   
 
  1. sudo apt-get install openjdk-8-jdk-headless

安装 mycat

mycat安装包解压到 /usr/local下:

 
   
   
 
  1. sudo chown -R $USER /usr/local/mycat

启动 mycat

 
   
   
 
  1. /usr/local/mycat/bin/mycat start

查看 logs/wrapper.log监控启动状态

使用 mycat

1.配置mycat
  • 在 server.xml中配置可访问用户:

 
   
   
 
  1. <user name="mycat">

  2.    <property name="password">mycat</property>

  3.    <property name="schemas">db1</property>

  4. </user>

这里的 db1必须是 schema.xml中配置的,否则报错。

  • 在 schema.xml中配置参数:

 
   
   
 
  1. <?xml version="1.0"?>

  2. <!DOCTYPE mycat:schema SYSTEM "schema.dtd">

  3. <mycat:schema xmlns:mycat="http://io.mycat/">

  4.    // schema标签的name对应server.xml中的schema

  5.    <schema name="db1" checkSQLschema="true" sqlMaxLimit="1000000">

  6.        <table name="user" primaryKey="id" autoIncrement="true" dataNode="dn$1-3" rule="mod-long" />

  7.    </schema>

  8.    <dataNode name="dn1" dataHost="node1" database="node" />

  9.    <dataNode name="dn4" dataHost="node1" database="node" />

  10.    <dataNode name="dn7" dataHost="node1" database="node" />

  11.    <dataNode name="dn11" dataHost="node1" database="node" />

  12.    <dataNode name="dn2" dataHost="node2" database="node" />

  13.    <dataNode name="dn5" dataHost="node2" database="node" />

  14.    <dataNode name="dn8" dataHost="node2" database="node" />

  15.    <dataNode name="dn11" dataHost="node2" database="node" />

  16.    <dataNode name="dn3" dataHost="node3" database="node" />

  17.    <dataNode name="dn6" dataHost="node3" database="node" />

  18.    <dataNode name="dn9" dataHost="node3" database="node" />

  19.    <dataNode name="dn12" dataHost="node3" database="node" />

  20.    // dataHost的name对应dataNode中的dataHost

  21.    <dataHost name="node1" maxCon="1000" minCon="10" balance="1" writeType="0" dbType="mysql" dbDriver="native" switchType="1"  slaveThreshold="100">

  22.        <heartbeat>select user()</heartbeat>

  23.        // 在这里配置docker拉起来的3个容器

  24.        <writeHost host="hostM1" url="192.168.1.5:33061" user="root" password="root">

  25.        </writeHost>

  26.    </dataHost>

  27.    <dataHost name="node2" maxCon="1000" minCon="10" balance="1" writeType="0" dbType="mysql" dbDriver="native" switchType="1"  slaveThreshold="100">

  28.        <heartbeat>select user()</heartbeat>

  29.        <writeHost host="hostM2" url="192.168.1.5:33062" user="root" password="root">

  30.        </writeHost>

  31.    </dataHost>

  32.    <dataHost name="node3" maxCon="1000" minCon="10" balance="1" writeType="0" dbType="mysql" dbDriver="native" switchType="1"  slaveThreshold="100">

  33.        <heartbeat>select user()</heartbeat>

  34.        <writeHost host="hostM3" url="192.168.1.5:33063" user="root" password="root">

  35.        </writeHost>

  36.    </dataHost>

  37. </mycat:schema>

  • 进入mycat数据库层:

 
   
   
 
  1. root@063b64a0619f:/# mysql -u mycat -p -P 8066 -h HOST

此处 HOSTmycat安装所在的ip。

 
   
   
 
  1. mysql> show databases;

  2. +----------+

  3. | DATABASE |

  4. +----------+

  5. | db1      |

  6. +----------+

  7. 1 row in set (0.01 sec)

这里的db1是schema标签中对应的名称,这是一个虚拟库。

 
   
   
 
  1. mysql> use db1;

  2. Reading table information for completion of table and column names

  3. You can turn off this feature to get a quicker startup with -A

  4. Database changed

  5. mysql> show tables;

  6. +----------------------------+

  7. | Tables in datacache        |

  8. +----------------------------+

  9. | user                       |

  10. +----------------------------+

  11. 5 rows in set (0.01 sec)

这里的user表实际上目前也是个虚拟表,只有当在子节点中创建表之后,这个表才有意义。

 
   
   
 
  1. mysql> CREATE TABLE IF NOT EXISTS `user` (

  2.    ->  `id` varchar(20) NOT NULL DEFAULT '0' COMMENT 'ID',

  3.    ->  `name` varchar(20) NOT NULL DEFAULT '' COMMENT '',

  4.    ->  `created_at` datetime NOT NULL DEFAULT now() COMMENT '',

  5.    ->  PRIMARY KEY (`id`)

  6.    -> ) ENGINE=MyISAM DEFAULT CHARSET=utf8;

  7. Query OK, 0 rows affected, 1 warning (0.01 sec)

1.这里的 id不采用int类型,是因为我采用的全局序列是默认的本地时间戳方式,int长度不够;
2.这里创建表结构,必须在对用的所有dataNode上创建相同的表,如果只是在mycat库中创建,只会在第一个dataNode中创建成功,并不能在所有dataNode中一起创建,我想这是mycat仍然会进行优化的地方吧。

  • 插入数据:

 
   
   
 
  1. mysql> INSERT INTO `user` (`name`,`date`) VALUES ('mycat','2017-10-10');

  2. Query OK, 1 row affected (0.01 sec)

 
   
   
 
  1. mysql> select * from user;

  2. +----+-------+---------------------+

  3. | id | name  | created_at          |

  4. +----+-------+---------------------+

  5. |  1 | mycat | 2018-02-01 07:12:26 |

  6. +----+-------+---------------------+

  7. 1 row in set (0.01 sec)

1.当插入多条数据时,数据会根据 mod-long的分片方式分散到不同节点上;
2.如果以时间维度作为筛选条件,会遍历所有节点,所以,根据我的业务需求,我将分片方式改为 sharding-by-month

原本是分布在3个节点上的相同database上,但是发现当我插入一条数据,就会产生3条数据;
解决方式是分布到不同的database上。

 
   
   
 
  1. <schema name="db1" checkSQLschema="true" sqlMaxLimit="1000000">

  2.    <table name="user" primaryKey="id" autoIncrement="true" dataNode="dn$1-12" rule="sharding-by-month" />

  3. </schema>

  4. <dataNode name="dn1" dataHost="node1" database="node1" />

  5. <dataNode name="dn4" dataHost="node1" database="node2" />

  6. <dataNode name="dn7" dataHost="node1" database="node3" />

  7. <dataNode name="dn11" dataHost="node1" database="node4" />

  8. <dataNode name="dn2" dataHost="node2" database="node1" />

  9. <dataNode name="dn5" dataHost="node2" database="node2" />

  10. <dataNode name="dn8" dataHost="node2" database="node3" />

  11. <dataNode name="dn11" dataHost="node2" database="node4" />

  12. <dataNode name="dn3" dataHost="node3" database="node1" />

  13. <dataNode name="dn6" dataHost="node3" database="node2" />

  14. <dataNode name="dn9" dataHost="node3" database="node3" />

  15. <dataNode name="dn12" dataHost="node3" database="node4" />

这样虽然需要创建12个database,数据准确性问题得到解决。

以上


以上是关于mycat实践的主要内容,如果未能解决你的问题,请参考以下文章

Mycat生产实践---数据迁移与扩容实践

实践-基于Docker搭建的mycat分片应用

MyCat & MySQL多节点的Docker虚拟化实践

Mycat入门:垂直拆分实践

Mycat开发实践---Mycat的网络通信框架

MyCAT入门实践