zoukankan      html  css  js  c++  java
  • mycat分库分表demo

    关于Mycat,它是一个阿里的开源项目,用来解决分库分表的海量数据存储和查询优化,关于它的简介,可以直接参考介绍:Mycat简介。

    下面对自己的demo做个记录:

    我之前从192.168.68.3克隆了一台服务器192.168.68.6(关于克隆可以看我前面的文章),在192.168.68.6上面安装了mysql(mysql安装可以参考我前面的文章)

    在192.168.68.3中可以没有mysql(实际中已经安装好了mysql的读写分离,我怕用这个当作mysql会对68.4/68.5机器上的数据造成影响),下面会提到这台机器需要jdk,然后用这台机器来安装mycat,控制其它机器的mysql进行读写操作。

    0.准备工作

    Mycat是用java写的,所以运行环境需要jdk的支持。我之前没有装,所以把安装步骤说一下:

    可以先试下自己有没有装java环境,我输入java提示没有该命令

    1)linux版jdk下载:http://www.oracle.com/technetwork/java/archive-139210.html

    由于我的虚拟机是64位centos6.5,我下的是1.7.0_80的解压版的

    下载之后,我还是放在了/software文件夹下

    学会用rz来传文件,直接yum install -y lrzsz安装上传文件工具,安装好之后,进入到要上传的路径下,直接rz命令,就可以将本地的文件上传到该路径下。

    2)解压

    我把他解压到了/user/local路径下 tar -zxvf jdkxxxxx -C /user/local

    3)配置环境变量

    解压后,jdk的bin目录所在的路径是/usr/local/jdk1.7.0_80

    所以在/etc/profile

    export JAVA_HOME=/usr/local/jdk1.7.0_80
    export PATH=$JAVA_HOME/bin:$PATH
    然后source一下,source /etc/profile使配置文件生效

    这样再java就有该命令了

    1.下载Mycat

    官方下载地址:http://dl.mycat.io/

    我下的是1.6的解压版

    2.解压mycat

    同样使用rz工具将它上传到/software文件夹下 并解压到/user/local路径下(解压后的文件名就叫做mycat)

    进入到/usr/local/mycat/bin/

    它下面的mycat是启动文件

    ./mycat start 启动

    ./mycat stop 停止

    ./mycat restart 重启

    ./mycat status 查看mycat的启动状态

    这样mycat就安装好了

    3.mycat分库分表实例

    1)需求

    前面也提到了,mycat安装在了192.168.68.3这台机器上,并且前提装好了jdk。

    192.168.68.6装了个单机版的mysql。在这个上面,创建3个数据库db1/db2/db3,这几个库中都建一张item(商品表)

    建表语句很简单

    CREATE TABLE `item` (
      `id` int(11) NOT NULL COMMENT '主键id',
      `name` varchar(20) DEFAULT NULL COMMENT '名称',
      PRIMARY KEY (`id`)
    ) ENGINE=InnoDB DEFAULT CHARSET=utf8;


    到时想测试下操作192.168.68.3的mycat,进行读和写操作。它是怎么把数据存到192.168.68.6的三个库的各个表中,以及怎么读取 的。

    在安装目录的/usr/local/mycat/conf文件夹下,是mycat的各种配置文件存储的地方。

    而简单的分库分表操作,需要修改这三个配置文件

    schema.xml

    server.xml

    rule.xml

    而文件的修改,如果直接看可能不太方便,可以用notepad++等工具远程连接

    插件的下载,地址如下:https://github.com/ashkulz/NppFTP/releases/

    插件的安装,地址如下:https://www.cnblogs.com/beijinglaolei/p/7710825.html

    schema.xml配置

    <?xml version="1.0"?>
    <!DOCTYPE mycat:schema SYSTEM "schema.dtd">
    <mycat:schema xmlns:mycat="http://io.mycat/">
     
        <schema name="TESTDB" checkSQLschema="false" sqlMaxLimit="100">
            <!-- auto sharding by id (long) -->
            <table name="item" dataNode="dn1,dn2,dn3" rule="mod-long" />
        </schema>
        <!-- <dataNode name="dn1$0-743" dataHost="localhost1" database="db$0-743"
            /> -->
        <dataNode name="dn1" dataHost="localhost1" database="db1" />
        <dataNode name="dn2" dataHost="localhost1" database="db2" />
        <dataNode name="dn3" dataHost="localhost1" database="db3" />
     
        <dataHost name="localhost1" maxCon="1000" minCon="10" balance="0"
                  writeType="0" dbType="mysql" dbDriver="native" switchType="1"  slaveThreshold="100">
            <heartbeat>select user()</heartbeat>
            <!-- can have multi write hosts -->
            <writeHost host="hostM1" url="192.168.68.6:3306" user="root"
                       password="root">
            </writeHost>
        </dataHost>
    </mycat:schema>
    server.xml

    <user name="root">
            <property name="password">root</property>
            <property name="schemas">TESTDB</property>
            
            <!-- 表级 DML 权限设置 -->
            <!--         
            <privileges check="false">
                <schema name="TESTDB" dml="0110" >
                    <table name="tb01" dml="0000"></table>
                    <table name="tb02" dml="1111"></table>
                </schema>
            </privileges>        
             -->
        </user>
    注意用户名连接的schema的TESTDB要和schema.xml和保持一致

    而连接的默认端口是8066

    我用的sqlyog工具,发现查不到表,而用命令行的客户端连接,或使用Navicat连接都没问题

    INSERT INTO item(id, NAME) VALUES(1, 'a');
    INSERT INTO item(id, NAME) VALUES(2, 'b');
    INSERT INTO item(id, NAME) VALUES(3, 'c');
    INSERT INTO item(id, NAME) VALUES(4, 'd');
    INSERT INTO item(id, NAME) VALUES(5, 'f');
    INSERT INTO item(id, NAME) VALUES(6, 'g');
    SELECT * FROM item; 

    插入了6条数据,可以看到查询出来的不是按照顺序的。

    而看192.168.68.6的db1/db2/db3的库

    db1:

    db2:

    db3:

    虽然分库了,但可以通过排序将不同库中的数据在查询后,在mycat中排序

    这可能算是最简单的demo了。后续如果继续深入学习,还会将学习笔记进行更新。
     

  • 相关阅读:
    分布式系统实践解读丨详解高内聚低耦合
    Git:改变世界的一次代码提交
    一分钟带你认识深度学习中的知识蒸馏
    99%的人都能看懂的分布式系统「补偿」机制
    一大波人气博主袭来,现场直播华为全联接2020!
    快速了解前端开发HTML的正确姿势
    华为云IoT智简联接,开启物联世界新纪元
    从一个小程序说起2 C++快速入门03
    从一个小程序说起 C++快速入门02
    PE格式详细讲解6(上) 系统篇06|解密系列
  • 原文地址:https://www.cnblogs.com/hzcya1995/p/13317303.html
Copyright © 2011-2022 走看看