前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >Mycat(配置篇)

Mycat(配置篇)

作者头像
happyJared
发布2018-09-20 10:21:18
1.8K0
发布2018-09-20 10:21:18
举报
文章被收录于专栏:happyJaredhappyJared

Mycat目录说明

  • bin:启动目录
  • conf:配置文件目录
    • server.xml:是Mycat服务器参数调整和用户授权的配置文件
    • schema.xml:是逻辑库定义和表以及分片定义的配置文件
    • rule.xml: 是分片规则的配置文件,分片规则的具体一些参数信息单独存放为文件,也在这个目录下,配置文件修改需要重启MyCAT
    • log4j.xml: 日志存放在logs/log中,每天一个文件,日志的配置是在conf/log4j.xml中,根据自己的需要可以调整输出级别为debug,debug级别下,会输出更多的信息,方便排查问题
    • autopartition-long.txt,partition-hash-int.txt,sequence_conf.properties, sequence_db_conf.properties 分片相关的id分片规则配置文件
  • lib:jar包目录
  • logs :日志目录
  • tmlogs:临时日志目录

配置文件目录说明图:

Mycat3大配置文件
Mycat3大配置文件

Mycat3大配置文件

3大配置文件说明

server.xml

  包含了Mycat需要的系统配置信息,用户配置信息以及逻辑库配置信息,源代码中的映射类为:SystemConfig.class

  • 添加如下配置:相当于建立了一个叫做mycat用户,对应密码为mycat,该用户管理了mycats这个逻辑库。当然了,也可以为用户添加管理多个逻辑库,以,(英文逗号)分隔开即可
代码语言:javascript
复制
    <user name="mycat">
        <property name="password">mycat</property>
        <property name="schemas">mycats</property><!--schemas:逻辑库名称,具体配置在scheme.xml中-->
    </user>
schema.xml

  可以说是最重要的配置文件,管理着 MyCat 的逻辑库、表、分片规则、DataNode 以及 DataSource

  • schema是实际逻辑库的配置,多个schema代表多个逻辑库
  • dataNode是逻辑库对应的分片,如果配置多个分片则需要添加多个dataNode即可
  • dataHost是实际的物理库配置,可以根据业务需要配置多主、主从等其他配置,多个dataHost代表分片对应的物理库地址,下面的writeHost、readHost代表该分片是否配置多写,主从,读写分离等高级特性
  • 添加如下配置:水平切分,数据按Id取模均匀划分到两个数据库中
代码语言:javascript
复制
    <schema name="mycats" checkSQLschema="false" sqlMaxLimit="100">
        <!-- 逻辑表配置 -->
        <table name="tb_user" dataNode="dn1,dn2" rule="mod-long" /><!--name:实际物理库的数据表名;dataNode:表对应的分片;rule:分片规则名称,具体配置在rule.xml中-->
    </schema>

    <dataNode name="dn1" dataHost="host1" database="mycat1" /><!--name:分片名称;database:实际物理库的数据库名-->
    <dataNode name="dn2" dataHost="host1" database="mycat2" />

    <dataHost name="host1" maxCon="100" minCon="10" balance="0" writeType="0" dbType="mysql" dbDriver="native">
       <heartbeat>select user()</heartbeat><!--mysql心跳检测命令-->
       <writeHost host="hostM1" url="localhost:3306" user="root" password="xxx" /><!--实际物理库的配置信息-->
    </dataHost>
rule.xml

  定义了表拆分所涉及到的规则定义。根据业务可以灵活的对表使用不同的分片算法(目前已实现十余种不同的分片规则,对应所在源码包为:io.mycat.route.function),或者对表使用相同的算法但具体的参数不同。

  • 添加如下配置:水平切分,数据按Id取模均匀划分到两个数据库中
代码语言:javascript
复制
    <tableRule name="mod-long"> <!-- 对应表的分片规则 -->
        <rule>
            <columns>id</columns><!-- 对应数据表要取模的字段名称 -->
            <algorithm>mod-long</algorithm><!-- 对应function的名称 -->
        </rule>
    </tableRule>
    
    <function name="mod-long" class="io.mycat.route.function.PartitionByMod"><!-- name:对应tableRule的名称;class:切分规则对应的切分类 -->
        <!--  scheme.xml中有多少个dataNode就改成多少个 -->
        <property name="count">2</property>
    </function>

代码测试(SpringBoot + JPA)

  • 准备:在对应的数据库中建好相关的表(下一篇文章将给出JPA自动建表解决方案)
代码语言:javascript
复制
DROP TABLE IF EXISTS `tb_user`;
CREATE TABLE `tb_user` (
  `id` bigint(20) NOT NULL,
  `name` varchar(255) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
  • 添加application.yml:
代码语言:javascript
复制
spring:
  jpa:
    show-sql: true
    hibernate:
      ddl-auto: update
      naming:
        strategy: org.hibernate.cfg.ImprovedNamingStrategy
    properties:
      hibernate:
        dialect: org.hibernate.dialect.MySQL5Dialect
  datasource:
    url: jdbc:mysql://localhost:8066/mycats?characterEncoding=UTF-8&useSSL=false&autoReconnect=true&rewriteBatchedStatements=true
    username: mycat
    password: mycat
  • 添加User Entity
代码语言:javascript
复制
@Entity
@Table(name = "tb_user")
@Data
public class User {

    @Id
    private Long id;

    private String name;

}
  • 添加UserDao
代码语言:javascript
复制
public interface UserDao extends JpaRepository<User, Long> {

    Page<User> findByNameLike(String name, Pageable pageable);

}
  1. 测试添加
代码语言:javascript
复制
@Test
public void testAdd() {
    for (long i = 0; i < 50; i++) {
        User user = new User();
        user.setId(i);
        user.setName("ls" + i);
        userDao.save(user);
    }
}

测试结果:数据按id取模的方式划分到了两个数据库中

水平切分(id取模)
水平切分(id取模)

水平切分(id取模)

  1. 测试模糊查询+分页
代码语言:javascript
复制
@Test
public void testFind() {
    Pageable pageable = new PageRequest(0, 10, Sort.Direction.ASC, "id");
    List<User> userList = userDao.findByNameLike("%ls1%", pageable).getContent();
    userList.forEach(System.out::println);
}

测试结果:按照模糊匹配及id升序的方式输出结果

测试模糊查询+分页
测试模糊查询+分页

测试模糊查询+分页

  1. 删除及修改请自行测试

参考链接

Mycat官网 Mycat从零开始 Mycat权威指南 GitHub:Mycat-Server Wiki:Mycat-Server Issues:Mycat-Server mysql中间件研究(Atlas,Cobar,TDDL) mysql中间件研究(Atlas,Cobar,TDDL,Mycat,Heisenberg,Oceanus,Vitess,OneProxy)

本文参与 腾讯云自媒体分享计划,分享自作者个人站点/博客。
原始发表:2018.03.07 ,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • Mycat目录说明
  • 配置文件目录说明图:
  • 3大配置文件说明
    • server.xml
      • schema.xml
        • rule.xml
        • 代码测试(SpringBoot + JPA)
        • 参考链接
        相关产品与服务
        消息队列 TDMQ
        消息队列 TDMQ (Tencent Distributed Message Queue)是腾讯基于 Apache Pulsar 自研的一个云原生消息中间件系列,其中包含兼容Pulsar、RabbitMQ、RocketMQ 等协议的消息队列子产品,得益于其底层计算与存储分离的架构,TDMQ 具备良好的弹性伸缩以及故障恢复能力。
        领券
        问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档