mysql读写分离实现事务_Mysql读写分离后的事务ce「建议收藏」

mysql读写分离实现事务_Mysql读写分离后的事务ce「建议收藏」1.概述很多人会有这样的疑问,mysql读写分离后,我的事务怎么处理呢。不是说mysql不支持跨库事务吗?那我引入mycat这个中间件后事务是否是安全的呢,它是怎么运作的呢。今天我们就来实验一下2.设置首先设置事务锁的过期时间是5innodb_lock_wait_timeout=5意思是前面有人已经锁定这一行准备更新了,而你现在又去更新这行,那你只能等,等5秒。前面的人还没进行事务提交,那…

大家好,又见面了,我是你们的朋友全栈君。

1 .概述

很多人会有这样的疑问,mysql读写分离后,我的事务怎么处理呢。

不是说mysql不支持跨库事务吗?

那我引入mycat这个中间件后事务是否是安全的呢,它是怎么运作的呢。

今天我们就来实验一下

2. 设置

首先设置事务锁的过期时间是5

innodb_lock_wait_timeout = 5

意思是前面有人已经锁定这一行准备更新了,而你现在又去更新这行,那你只能等,等5秒。前面的人还没进行事务提交,那你当前的进程就会报错

ERROR 1205 (HY000): Lock wait timeout exceeded; try restarting transaction

所以必须回滚。

3.主从库 各自开启事务实验,检验事务锁

来验证一下主库和从库 分别对同一行数据操作时 ,事务是否安全

主:

mysql> start transaction;

Query OK, 0 rows affected (0.00 sec)

mysql> select * from tb_books where id =2 for update;

+——+——-+———–+————+—-+

| name | price | bookCount | author | id |

+——+——-+———–+————+—-+

| 123 | 88 | 100 | beiduofen3 | 2 |

+——+——-+———–+————+—-+

1 row in set (0.08 sec)

表tb_books的id的主键,这里执行了行锁 ,然后去看看从服务器

从:

mysql> start transaction;

Query OK, 0 rows affected (0.00 sec)

mysql> update tb_books set price=77 where id =2;

Query OK, 1 row affected (0.16 sec)

Rows matched: 1 Changed: 1 Warnings: 0

可以看到即使主服务器已经 把id=2 这行数据已经锁定, 但是从服务器还是可以更新到id为2的这条记录

由此可见,简单的读写分离 事务并不同步 。MySQL不支持跨库事务

那么我们只能借助mycat来实现弱跨库事务了

4 . 通过mycat 分别开始事务后,检验事务锁

配置: 已经用mycat 配置好主从读写分离

我们登陆mycat ,新开2个窗口进程,分别叫mycat1 和 mycat2

===mycat1 进程===

mysql> start transaction;

Query OK, 0 rows affected (0.08 sec)

mysql> select * from tb_books where id=1 for update;

+——+——-+———–+————+—-+

| name | price | bookCount | author | id |

+——+——-+———–+————+—-+

| 123 | 33 | 100 | beiduofen2 | 1 |

+——+——-+———–+————+—-+

1 row in set (0.04 sec)

mysql> update tb_books set price=9 where id =1;

Query OK, 1 row affected (0.17 sec)

Rows matched: 1 Changed: 1 Warnings: 0

这里我们没有操作提交或回滚。

然后我们继续转到mycat2进程操作

===mycat2 进程===

我们在这进行同样的操作

mysql> start transaction;

Query OK, 0 rows affected (0.00 sec)

mysql> update tb_books set price=10 where id =1;

ERROR 1205 (HY000): Lock wait timeout exceeded; try restarting transaction

可以看到 mycat2进程 已经不能对id为1的记录进行操作 ,触发了行锁

而且在主数据库和从数据库的日志里 也没有发现此条sql日志。

由此看来应该是在mycat的层面上处理了。

并且如果该进程如果发生过事务 , 接下来的无论是select或update的操作都会发生在写主机上(不知道是不是我的设置问题), 无论执行多少次读的请求, 从主机都不会收到select的任务。(我的mycat策略是主数据库只负责写操作,从服务器只负责读操作)

要新进来的进程或这个进程已经断开,才会按读写分离规则分配。

5.日志和总结

这里记录下mycat触发行锁时 的日志

2020-02-03 04:55:04.437 DEBUG [$_NIOREACTOR-0-RW] (io.mycat.backend.datasource.PhysicalDatasource.releaseChannel(PhysicalDatasource.java:442)) – release channel MySQLConnection [id=12, lastTime=1580734504421, user=slaveuser, schema=testtest, old shema=testtest, borrowed=true, fromSlaveDB=true, threadId=62, charset=utf8, txIsolation=3, autocommit=true, attachment=null, respHandler=null, host=192.168.133.135, port=3306, statusSync=null, writeQueue=0, modifiedSQLExecuted=false]

2020-02-03 04:55:04.437 DEBUG [$_NIOREACTOR-0-RW] (io.mycat.backend.datasource.PhysicalDatasource.releaseChannel(PhysicalDatasource.java:442)) – release channel MySQLConnection [id=6, lastTime=1580734504421, user=root, schema=testtest, old shema=testtest, borrowed=true, fromSlaveDB=false, threadId=28, charset=utf8, txIsolation=3, autocommit=true, attachment=null, respHandler=null, host=localhost, port=3306, statusSync=null, writeQueue=0, modifiedSQLExecuted=false]

额外的一点知识

select * from information_schema.innodb_trx\G;

通过这个语句可以看到系统里的锁

总结一下。

单单读写分离配置后 事务安全需要借助mycat

6.参考

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/134264.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • 空间尺度分析_特征尺度的选取原则

    空间尺度分析_特征尺度的选取原则特征点尺度变换高斯核是唯一可以产生多尺度空间的核,高斯模板具有圆对称性,通过高斯卷积操作对原始像素值重新分配权重,距离中心越远的相邻像素值权重分配相对较小。二维矩阵变换的高斯平滑操作可以通过在水平和竖直方向上分别进行一维高斯矩阵变换相加得到。尺度是自然客观存在的,不是主观创造的,高斯卷积只是表现尺度空间的一种形式。示例代码如下:voidCreateScaleSpace(cv::M…

    2022年10月14日
  • 测试 windows live writer

    测试 windows live writer

  • oracle sequence用法_oracle session

    oracle sequence用法_oracle session1.   AboutSequences(关于序列)序列是数据库对象一种。多个用户可以通过序列生成连续的数字以此来实现主键字段的自动、唯一增长,并且一个序列可为多列、多表同时使用。序列消除了串行化并且提高了应用程序一致性。(想象一下没有序列的日子怎么办?)2.   CreatingSequences(创建序列)前提:PrerequisitesTocreateasequ

    2022年10月19日
  • oracle创建表空间的SQL语句

    oracle创建表空间的SQL语句oracle创建表空间语句:createtablespaceshopping–创建一个叫shopping的表空间datafile’shopping.dbf’–物理文件名size50m–大小autoextend…

  • Windows 10配置远程开机[通俗易懂]

    Windows 10配置远程开机[通俗易懂]简介最近有个需求,在外边或者是上班的时候想从家里的电脑拿点资料,虽然家里的路由器有公网IP地址,但是电脑总不能一直开着吧,然后就想到可以远程通过网卡唤醒电脑。前提条件拥有一个公网IP(一般可以找运营商申请),如果拥有的公网IP是动态的话,需要绑定DDNS域名,DDNS域名可以自行注册。 电脑主板支持网络唤醒功能。配置方法主板开启网络唤醒功能,如图:设置网络适配器支持唤醒…

  • h5实现长按复制文本_ios13如何复制链接

    h5实现长按复制文本_ios13如何复制链接前段时间有位朋友让帮忙做一个手机h5页面长按复制的功能,先上图安卓实现起来没问题,有时候ios会报错,无奈手边也没有iPhone手机,折腾了好几次才完成,直接上关键代码<scriptsrc=”js/jquery.ui.draggable.js”type=”text/javascript”></script><scripttype=”text/…

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号