写点什么

保姆级教程!手把手带你用数据库中间件 Mycat+SpringBoot 完成分库分表

用户头像
极客good
关注
发布于: 刚刚

不存在单库大数据,高并发的性能瓶颈;


应用端改造较少;


提高了系统的稳定性跟负载能力。


缺点


拆分规则难以抽象;


分片事务一致性难以解决;


数据多次扩展难度跟维护量极大;


跨库 join 性能较差

五、什么是 Mycat

它是一个开源的分布式数据库系统,是一个实现了 MySQL 协议的的 Server,前端用户可以把它看作是一个数据库代理,用 MySQL 客户端工具和命令行访问,而其后端可以用 MySQL 原生(Native)协议与多个 MySQL 服务器通信,也可以用 JDBC 协议与大多数主流数据库服务器通信,其核心功能是分表分库,即将一个大表水平分割为 N 个小表,存储在后端 MySQL 服务器里或者其他数据库里。


常见应用场景:


单纯的读写分离,此时配置最为简单,支持读写分离,主从切换;


分表分库,对于超过 1000 万的表进行分片,最大支持 1000 亿的单表分片;


多租户应用,每个应用一个库,但应用程序只连接 Mycat,从而不改造程序本身,实现多租户化;


报表系统,借助于 Mycat 的分表能力,处理大规模报表的统计;? 替代 Hbase,分析大数据;


作为海量数据实时查询的一种简单有效方案,比如 100 亿条频繁查询的记录需要在 3 秒内查询出来结果,除了基于主键的查询,还可能存在范围查询或其他属性查询,此时 Mycat 可能是最简单有效的选

六、SpringBoot+Mycat+MySQL 实现分表分库案例

关于分库分表,Mycat 已经帮我们在内部实现了路由的功能,我们只需要在 Mycat 中配置以下切分规则即可,对于开发者来说,我们就可以把 Mycat 看做是一个数据库,接下来我们开始搭建环境:

步骤一:

Mycat 是使用 java 写的数据库中间件,所以要运行 Mycat 前要准备要 jdk 的环境,要求是 jdk1.7 以上的环境。所以需要在系统中配置 JAVA_HOME 的环境变量.

步骤二:

从官网下载 Mycat,[http://dl.mycat.io/1.6-RELEASE](


)?/ 我们是基于 CentOS7 来搭建 Mycat 环境的,所以下载版本:Mycat-server-1.6-RELEASE-20161028204710-linux.tar.gz

步骤三:

将下载好的安装包上传到服务器上并解压. 解压之后目录结构如下:


步骤四:

配置切分规则:将如下配置复制粘贴覆盖 mycat/conf/schema.xml 的内容。


<?xml version="1.0"?><!DOCTYPE mycat:schema SYSTEM "schema.dtd"><mycat:schema xmlns:mycat="http://io.mycat/">


<schema ><table />


</schema>


<dataNode />


<dataNode />


<dataHost >


<heartbeat>select user()</heartbeat>


<writeHost host="server1" url="127.0.0.1:3306" user="root" password="WolfCode_2017"/>


</dataHost></mycat:schema>


<schema>: 表示的是在 mycat 中的逻辑库配置,逻辑库名称为:TESTDB


<table>: 表示在 mycat 中的逻辑表配置,逻辑表名称为:user, 映射到两个数据库节点 dataNode 中, 切分规则为:rule1(在 rule.xml 配置)


<dataNode>: 表示数据库节点, 这个节点不一定是单节点,可以


【一线大厂Java面试题解析+核心总结学习笔记+最新架构讲解视频+实战项目源码讲义】
浏览器打开:qq.cn.hn/FTf 免费领取
复制代码


配置成读写分离.


<dataHost>: 真实的数据库的地址配置


<heartbeat>: 用户心跳检测


<writeHost>: 写库的配置


将如下配置复制粘贴覆盖 mycat/conf/rule.xml 的内容。


这里定义的是切分规则,是按照 id 列进行切分,切分规则是采取取模的方式,<property >2</property>: 这里配置了我们有拆分了多个库 (表),需要和前面配置<table />中的 dataNode 个数一致,否则会出错.

步骤五:

在数据库中创建两个数据库 db01,db02.每个库中执行如下建表语句:


CREATE TABLE user (id bigint(20) NOT NULL,name varchar(255) DEFAULT NULL,PRIMARY KEY (id)) ENGINE=InnoDB DEFAULT CHARSET=utf8;

步骤六:

启动 mycat, 执行 mycat/bin/startup_nowrap.sh


步骤七:搭建 SpringBoot 环境,执行插入语句.application.properties 配置如下:



UserMapper.java 代码如下:


@Mapperpublic interface UserMapper {@Insert("insert into user(id,name) value (#{id},#{name})")int insert(User user);@Select("select * from user")List<User> selectAll();}


UserController.java 代码如下:


@RestController@RequestMapping("/user")public class UserController {@Autowiredprivate UserMapper userMapper;

用户头像

极客good

关注

还未添加个人签名 2021.03.18 加入

还未添加个人简介

评论

发布
暂无评论
保姆级教程!手把手带你用数据库中间件Mycat+SpringBoot完成分库分表