保姆级教程!手把手带你用数据库中间件 Mycat+SpringBoot 完成分库分表
不存在单库大数据,高并发的性能瓶颈;
应用端改造较少;
提高了系统的稳定性跟负载能力。
缺点:
拆分规则难以抽象;
分片事务一致性难以解决;
数据多次扩展难度跟维护量极大;
跨库 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>: 表示数据库节点, 这个节点不一定是单节点,可以
配置成读写分离.
<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;
评论