需要做网站建设的公司,最近时事新闻热点事件,如何在自己做的网站中顶置内容,wordpress取消菜单文章目录前言MySQL读写分离原理搭建MySQL读写分离集群MySQL8.0之前MySQL8.0之后后记前言
上一期介绍并实现了MySQL的主从复制#xff0c;由于主从复制架构仅仅能解决数据冗余备份的问题#xff0c;从节点不对外提供服务#xff0c;依然存在单节点的高并发问题
所以在主从复…
文章目录前言MySQL读写分离原理搭建MySQL读写分离集群MySQL8.0之前MySQL8.0之后后记前言
上一期介绍并实现了MySQL的主从复制由于主从复制架构仅仅能解决数据冗余备份的问题从节点不对外提供服务依然存在单节点的高并发问题
所以在主从复制的基础上演变出了MySQL读写分离集群
MySQL读写分离原理
在MySQL读写分离中master节点专门用来做数据的修改操作(如create、update、insert、delete等)在主库上写然后主库通过主从复制把数据的更改通过binlog同步到所有从库上
再将所有的查询操作都映射到从库上这样就可以很好的分摊读写的压力不用全部请求都集中在主库上这样MySQL的并发处理能力就能得到极大的提高
**在MySQL8.0之前**这个过程需要一个中间件(如MyCatSharding-JDBC等)识别解析客户端的所有请求将所有的写操作映射到master节点而读操作都转到slave从库上
MySQL8.0之后MySQL自身已支持读写分离支持一主多从的读写分离多主多从的还是需要引入中间件实现
一主多从的读写分离
注意MySQL8.0之后该一主多从的读写分离可不依赖中间件
搭建MySQL读写分离集群
MySQL8.0之前
1、下载MyCat安装包
下载MyCathttp://dl.mycat.org.cn 2、分别配置schema.xml和server.xml
我这里配置虚拟库meet0and1-schema映射到主从节点上的meet0and1真实库
?xml version1.0?
!DOCTYPE mycat:schema SYSTEM schema.dtd
mycat:schema xmlns:mycathttp://io.mycat/!-- 定义MyCat的虚拟逻辑库dataNode映射真实数据节点 -- schema namemeet0and1-schema checkSQLschemafalse sqlMaxLimit800 dataNodemeet0and1Node /!-- 定义MyCat的数据节点name必须和dataNode值一致dataHost映射真实主机database映射真实的库 --dataNode namemeet0and1Node dataHostmeet0and1Host databasemeet0and1 /!-- 配置数据主机name必须和dataHost一致 --dataHost namemeet0and1Host maxCon1000 minCon10 balance1writeType0 dbTypemysql dbDrivernative switchType-1 slaveThreshold100!--心跳检测--heartbeatselect user()/heartbeat!--主节点写--writeHost hosthostM1 url192.168.31.161:3306 userroot password123456!--从节点读--readHost hosthostS1 url192.168.31.162:3306 userroot password123456 //writeHost/dataHost
/mycat:schema?xml version1.0 encodingUTF-8?
!DOCTYPE mycat:server SYSTEM server.dtd
mycat:server xmlns:mycathttp://io.mycat/!-- 这里配置的都是一些系统属性--system!-- 默认的sql解析方式 --property namedefaultSqlParserdruidparser/propertyproperty namecharsetutf8mb4/property/system!-- 配置登录mycat的用户信息 --user namerootproperty namepassword123456/property!-- 该用户可以操作哪个逻辑库 --property nameschemasmeet0and1-schema/property/user
/mycat:server3、启动MyCat
在mycat的bin目录下启动MyCat
# 以前台窗口启动
./mycat console
# 以后台守护进程启动
./mycat start
./mycat status
./mycat stop
./mycat restart4、MyCat实现MySQL读写分离
修改properties连接MySQL配置
# MyCat的server.xml中配置的用户和密码
spring.datasource.usernameroot
spring.datasource.password123456
# MyCat服务的端口8066meet0and1-schemaMyCat中配置映射到meet0and1的虚拟库
spring.datasource.urljdbc:mysql://192.168.31.161:8066/meet0and1-schema?serverTimezoneGMT%2B8useUnicodetruecharacterEncodingutf-8
spring.datasource.typecom.alibaba.druid.pool.DruidDataSource
spring.datasource.driver-class-namecom.mysql.cj.jdbc.Driver**注意**Spring中事务是支持传播的MyCat为避免在一个查询中又执行了更新操作而将连接请求转到slave从库导致主从数据不一致的情况所以MyCat会开启了事务的连接请求都转到master主库
如下面的findAll方法查询操作应该走从库但由于在类上开启了事务若方法上的事务传播属性不设置为SUPPORTS执行这个方法就会走master主库
Service
Transactional(rollbackFor Exception.class)
public class SysUserService {Autowiredprivate SysUserDao sysUserDao;/*** Propagation.SUPPORTS支持事务的传播* 有事务则融入如其他含有事务的方法调用这个方法时融入调用方的事务* 没有则不开启事务它自身的方法不开启事务且这里覆盖了类上配置的事务* (方法上的事务优先级大于类上开启的事务)*/Transactional(propagation Propagation.SUPPORTS)public ListSysUser findAll() {return sysUserDao.findAll();}/*** 执行写操作会走master主库*/public void save(SysUser sysUser) {sysUserDao.save(sysUser);}}MySQL8.0之后
MySQL8.0之后一主多从的读写分离可不再依赖任何中间件
1、连接MySQL时只有url配置有变化
# 语法默认配置的第一个节点为主(写)库后面的都为从(读)库
jdbc:mysql:replication://主(写)库,从(读)库1,从(读)库2,从(读)库N/库名示例
spring.datasource.urljdbc:mysql:replication://192.168.31.161:3306,192.168.31.162:3306/meet0and1?serverTimezoneGMT%2B8useUnicodetruecharacterEncodingutf-82、只有显示设置方法的事务为只读(readOnly true)并且单独执行它时才会走从(读)库
只有事务为只读的查询操作才走从(读)库
为保证主从节点数据的一致性当有其它service方法调用时无论他们是否包含事务即使不包含更新操作(insert/update/delete)走的都是主(写)库如下面几种
Service
public class SysUserService {Autowiredprivate SysUserMapper sysUserMapper;/*** 这里只有设置事务为只读且单独执行该方法时才走从(读)库*/Transactional(readOnly true)public ListSysUser findAll(){return sysUserMapper.findAll();}Transactionalpublic void hasTranFind(){// 走主(写)库findAll().forEach(System.out::println);}public void notTranFind(){// 走主(写)库findAll().forEach(System.out::println);}public void notTranSave(SysUser sysUser){// 走主(写)库findAll().forEach(System.out::println);sysUserMapper.save(sysUser);}/*** 该方法执行会报错Connection is read-only. Queries leading to data modification are not allowed* 设置只读的事务方法中不能有非查询操作*/Transactional(readOnly true)public ListSysUser findAll2(SysUser sysUser){sysUserMapper.save(sysUser);return sysUserMapper.findAll();}}后记
现在MyCat的社区和项目维护不是很友好MySQL8.0之后自身虽支持一主多从的读写分离
但在并发极高的大型项目中要实现分库分表读写分离和分布式主键等功能还是推荐Sharding-JDBC
