MySQL 加锁控制并发的方法

前言

锁总体可以分为乐观锁和悲观锁，简单说，乐观锁用版本号控制，悲观锁用锁控制。

下面是待会要用来测试的数据

# 添加一个user表
CREATE TABLE `users` (
 `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'ID',
 `name` varchar(255) NOT NULL COMMENT '姓名',
 PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;
# 插入3条数据
INSERT INTO `users` (`id`, `name`)
VALUES
 (1, '雪山飞猪'),
 (2, 'chenqionghe'),
 (3, 'cqh');

查询结果如下：

一、乐观锁

核心原理是增加一个version的字段来控制。
举个场景，我们希望并发更新单行记录的时候的时候，只有一个进程更新成功，如下

UPDATE users SET name="雪山飞猪" WHERE id=3
UPDATE users SET name="chenqionghe" WHERE id=3

上面这两个sql最终都会更新成功，且以最后更新结果为主。

解决办法是添加一个version字段

添加version字段

ALTER TABLE users ADD `version` INT NOT NULL DEFAULT '0'

解决办法是添加一个version字段，每个更新时where条件都加上它，并且也更新它

UPDATE users SET name="雪山飞猪",version=version+1 WHERE id=3 AND version=0
UPDATE users SET name="chenqionghe",version=version+1 WHERE id=3 AND version=0

这次变成了只会更新成功一次，谁先抢到这条记录以谁为主，因为当前一个进程更新成功后版本号已经变化了，第二个进程找不到这条记录了。
这就是最简单的CAS机制。

二、悲观锁

其实类似Go语言里的Mutex和RwMutex读锁

读锁

也叫共享锁或S锁，当给数据表加上共享锁的时候，表就变成了只读模式。
我们可以锁全表，也可以锁全表或部分行，如下

全表锁（LOCK TABLE 表 READ）

语法如下

LOCK TABLE 表 READ
UNLOCK TABLE;

我们来测试一个，第一个进程执行

LOCK TABLE users READ;

第二个进程执行正常读

SELECT * FROM users WHERE id=1;

可以正常查询。我们再来执行一下更新

UPDATE users SET name="chenqionghe" WHERE id=1

出现了等待。

我们给第一个进程解锁

再看第二个进程，已经更新成功

行锁（SELECT ... LOCK IN SHARE MODE）

BEGIN;
SELECT * FROM users WHERE id IN (1,2) LOCK IN SHARE MODE
COMMIT;

必须配合事务使用，BEIN开始后，锁定的行，外部只能查询，不能更新

我们来测试一下，第一个进程执行

BEGIN;
SELECT * FROM users WHERE id IN (1,2) LOCK IN SHARE MODE

这里锁定了id为1和2的记录行。我们第二个进程执行更新

UPDATE users SET name="雪山飞猪" WHERE id=1

又一次出现了等待。
好，这时候我们将第一个进程的事务提交

COMMIT;

第二个进程更新成功了，如下

写锁

也排他锁、独占锁，理解成读和写都不行了，语法如下

全表锁（LOCK TABLE 表 WRITE）

LOCK TABLE users WRITE;

这时候已经锁定全表，我们再用另一个进程查询一下id为1的数据

SELECT * FROM users WHERE id=1

可以看到，查询已经发生了等待。
我们再将第一个进程解锁

UNLOCK TABLE

这时候，第二个进程立马查询成功

行锁（SELECT ... FOR UPDATE）

当我们对数据进行更新的时候（INSERT、DELETE、UPDATE）的时候，数据库会自动使用排它锁，防止其他事务操作该数据

BEGIN;
SELECT * FROM users WHERE id IN (1,2) LOCK IN SHARE MODE
COMMIT;

我们再来测试一下，第一个进程锁定id为1和2的记录

BEGIN;
SELECT * FROM users WHERE id IN (1,2) FOR UPDATE

注意：这时候事务没提交

我们先用第二个进程来更新id为3的记录（未被锁定）

UPDATE users SET name="chenqionghe" WHERE id=3

执行成功了。
我们再来更新一个id为1的记录

UPDATE users SET name="chenqionghe" WHERE id=1

发生了等待，说明已经被锁定了。
好，我们提交第一个进程的事务

COMMIT;

再去看第二个进程，已经更新成功

简单说乐观锁用version控制，悲观锁的表锁一般用不着，行的读锁用LOCK IN SHARE MODE，写锁用FRO UPDATE，就是这么简单！

以上就是MySQL 加锁控制并发的方法的详细内容，更多关于MySQL 加锁控制并发的资料请关注我们其它相关文章！

赞 (0)

相关推荐

  • mysql多版本并发控制MVCC的实现

    事务隔离级别设置 set global transaction isolation level read committed; //全局的 set session transaction isolation level read committed; //当前会话 修改事务提交方式(是否自动提交,mysql默认自动提交) SET AUTOCOMMIT = 1; //自动提交,为0手动提交 不同数据库引擎MVCC模式各不相同,典型有乐观和悲观并发控制. innodb 说明: InnoDB的MVCC

  • Tomcat+Mysql高并发配置优化讲解

    Tomcat+Mysql高并发配置优化讲解

    1.Tomcat优化配置 (1)更改Tomcat的catalina.bat 将java变成server模式,增大jvm的内存,在文件开始位置增加 setJAVA_OPTS=-server -Xms1024m -Xmx2048m -Xss512K -XX:PermSize=128m-XX:MaxPermSize=256m setCATALINA_OPTS=-server -Xms512m -Xmx512m 如下图: Xms:初始内存 Xmx:最大内存 (2)更改Tomcat的Server.xml

  • PHP+MySQL高并发加锁事务处理问题解决方法

    本文实例讲述了PHP+MySQL高并发加锁事务处理问题解决方法.分享给大家供大家参考,具体如下: 1.背景: 现在有这样的需求,插入数据时,判断test表有无username为'mraz'的数据,无则插入,有则提示"已插入",目的就是想只插入一条username为'mraz'的记录. 2.一般程序逻辑如下: $conn = mysqli_connect('127.0.0.1', 'root', '111111') or die(mysqli_error()); mysqli_selec

  • MySQL 数据库如何解决高并发问题

    前言 我们都知道初创公司一开始都是以单体应用为首要架构,一般都是单体单库的形式.但是版本以及版本的迭代,数据库需要承受更多的高并发已经成了 架构设计 需要考虑的点. 那么解决问题,就得说到方案.但是方案有很多,我们该怎么选择呢? 优化与方案 基本上,我们优化要从几个关键字入手: 短距离 , 少数据 , 分散压力 . 短距离 所谓的短距离,指的是从前端到数据库的路径要短. 页面静态.有些页面的数据是在某些时段是不变的,那么这个页面可以静态化,这样可以提高访问的速度. 使用缓存.缓存大家都知道,快的

  • PHP利用Mysql锁解决高并发的方法

    前面写过利用文件锁来处理高并发的问题的,现在我们说另外一个处理方式,利用Mysql的锁来解决高并发的问题 先看没有利用事务的时候并发的后果 创建库存管理表 CREATE TABLE `storage` ( `id` int(11) unsigned NOT NULL AUTO_INCREMENT, `number` int(11) DEFAULT NULL, PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=l

  • MySQL语句加锁的实现分析

    摘要: MySQL两条SQL语句锁的分析 看一下下面的SQL语句加什么锁 SLQ1:select * from t1 where id = 10; SQL2:delete from t1 where id = 10; (1)id 是不是主键 (2)当前系统的隔离级别是什么 (3)id列如果不是主键,那么id列上有索引吗 (4)id列上如果有二级索引,那么这个索引是二级索引吗 (5)两个SQL的执行计划是什么?索引扫描还是全表扫描 实际的执行计划需要根据MySQL的输出为准 组合一:id列是主键,

  • MySQL并发更新数据时的处理方法

    MySQL并发更新数据时的处理方法

    UPDATE是否会加锁? SQL语句为如下时,是否会加锁? UPDATE table1 SET num = num + 1 WHERE id=1; 答案是不会 实际上MySQL是支持给数据行加锁(InnoDB)的,并且在UPDATE/DELETE等操作时确实会自动加上排它锁.只是并非只要有UPDATE关键字就会全程加锁,针对上面的MySQL语句而言,其实并不只是一条UPDATE语句,而应该类似于两条SQL语句(伪代码): a = SELECT * FROM table1 WHERE id=1;

  • Mysql事务并发问题解决方案

    在开发中遇到过这样一个问题 一个看视频记录,更新到100就表示看完了,后面再有请求不继续更新了. 结果是: 导致,里面很多数据出现问题. 推测是以下的情况才会导致 第一条请求 事务在执行中,还未提交(因为本地有时候比较难再现,于是手动在程序中,第一条记录处理的时候,sleep了几秒,就达到这种效果了) 第二条请求 事务已经开始执行,这个时候查到的历史最大值不是100,才会去进行了更新 网上看了一下解决方案: 悲观锁 直接锁行记录 这个我在本地测试,确实有效,一个事务开始没结束,第二个事务一个等待

  • MySQL 加锁控制并发的方法

    MySQL 加锁控制并发的方法

    前言 锁总体可以分为乐观锁和悲观锁,简单说,乐观锁用版本号控制,悲观锁用锁控制. 下面是待会要用来测试的数据 # 添加一个user表 CREATE TABLE `users` ( `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'ID', `name` varchar(255) NOT NULL COMMENT '姓名', PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSE

  • node 使用 async 控制并发的方法

    node 使用 async 控制并发的方法

    目标 建立一个 lesson5 项目,在其中编写代码. 代码的入口是 app.js,当调用 node app.js 时,它会输出 CNode(https://cnodejs.org/ ) 社区首页的所有主题的标题,链接和第一条评论,以 json 的格式. 注意:与上节课不同,并发连接数需要控制在 5 个. 输出示例: [ { "title": "[公告]发招聘帖的同学留意一下这里", "href": "http://cnodejs.or

  • 使用async、enterproxy控制并发数量的方法详解

    使用async、enterproxy控制并发数量的方法详解

    聊聊并发与并行 并发,在操作系统中,是指一个时间段中有几个程序都处于已启动运行到运行完毕之间,且这几个程序都是在同一个处理机上运行,但任一个时刻点上只有一个程序在处理机上运行. 并发我们经常提及之,不管是web server,app并发无处不在,操作系统中,指一个时间段中几个程序处于已经启动运行到完毕之间,且这几个程序都是在同一处理机上运行,并且任一个时间点只有一个程序在处理机上运行.很多网站都有并发连接数量的限制,所以当请求发送太快的时候会导致返回值为空或报错.更有甚者,有些网站可能因为你发出

  • Golang 语言控制并发 Goroutine的方法

    goroutine 是 Go语言中的轻量级线程实现,由 Go 运行时(runtime)管理.Go 程序会智能地将 goroutine 中的任务合理地分配给每个 CPU. 01介绍 Golang 语言的优势之一是天生支持并发,我们在 Golang 语言开发中,通常使用的并发控制方式主要有 Channel,WaitGroup 和 Context,本文我们主要介绍一下 Golang 语言中并发控制的这三种方式怎么使用?关于它们各自的详细介绍在之前的文章已经介绍过,感兴趣的读者朋友们可以按需翻阅. 02

  • mysql存储过程原理与使用方法详解

    本文实例讲述了mysql存储过程原理与使用方法.分享给大家供大家参考,具体如下: 存储过程包含了一系列可执行的sql语句,存储过程存放于MySQL中,通过调用它的名字可以执行其内部的一堆sql 存储过程的优点 #1. 用于替代程序写的SQL语句,实现程序与sql解耦 #2. 可以通过直接修改存储过程的方式修改业务逻辑(或bug),而不用重启服务器 #3. 执行速度快,存储过程经过编译之后会比单独一条一条执行要快 #4. 减少网络传输,尤其是在高并发情况下这点优势大,存储过程直接就在数据库服务器上

  • mysql 5.5 安装配置方法图文教程

    mysql 5.5 安装配置方法图文教程

    回忆一下mysql 5.5 安装配置方法,整理mysql 5.5 安装配置教程笔记,分享给大家. MySQL下载地址:http://dev.mysql.com/downloads/installer/ 1.首先进入的是安装引导界面 2.然后进入的是类型选择界面,这里有3个类型:Typical(典型).Complete(完全).Custom(自定义).这里建议 选择"自定义"(Custom)安装,这样可以自定义选择MySQL的安装目录,然后点"Next"下一步,出现自

  • mysql锁定单个表的方法

    mysql锁定单个表的方法 复制代码 代码如下: mysql>lock table userstat read; mysql>unlock tables; 页级的典型代表引擎为BDB. 表级的典型代表引擎为MyISAM,MEMORY以及很久以前的ISAM. 行级的典型代表引擎为INNODB. -我们实际应用中用的最多的就是行锁. 行级锁的优点如下: 1).当很多连接分别进行不同的查询时减小LOCK状态. 2).如果出现异常,可以减少数据的丢失.因为一次可以只回滚一行或者几行少量的数据. 行级锁

  • 一篇文章搞懂MySQL加锁机制

    一篇文章搞懂MySQL加锁机制

    目录 前言 锁的分类 乐观锁和悲观锁 共享锁(S锁)和排他锁(X锁) 按加锁粒度区分 全局锁 表级锁(表锁和MDL锁) 意向锁 行锁 间隙锁 next-key lock(临键锁) 加锁规则 死锁和死锁检测 总结 前言 在数据库中设计锁的目的是为了处理并发问题,在并发对资源进行访问时,数据库要合理控制对资源的访问规则. 而锁就是用来实现这些访问规则的一个数据结构. 在对数据并发操作时,没有锁可能会引起数据的不一致,导致更新丢失. 锁的分类 乐观锁和悲观锁 乐观锁: 对于出现更新丢失的可能性比较乐观

  • GO中sync包自由控制并发示例详解

    目录 资源竞争 sync.Mutex sync.RWMutex sync.WaitGroup sync.Once sync.Cond 资源竞争 channel 常用于并发通信,要保证并发安全,主要使用互斥锁.在并发的过程中,当一个内存被多个 goroutine 同时访问时,就会产生资源竞争的情况.这块内存也可以称为共享资源. 并发时对于共享资源必然会出现抢占资源的情况,如果是对某资源的统计,很可能就会导致结果错误.为保证只有一个协程拿到资源并操作它,可以引入互斥锁 sync.Mutex. syn

  • 线上MYSQL同步报错故障处理方法总结(必看篇)

    前言 在发生故障切换后,经常遇到的问题就是同步报错,数据库很小的时候,dump完再导入很简单就处理好了,但线上的数据库都150G-200G,如果用单纯的这种方法,成本太高,故经过一段时间的摸索,总结了几种处理方法. 生产环境架构图 目前现网的架构,保存着两份数据,通过异步复制做的高可用集群,两台机器提供对外服务.在发生故障时,切换到slave上,并将其变成master,坏掉的机器反向同步新的master,在处理故障时,遇到最多的就是主从报错.下面是我收录下来的报错信息. 常见错误 最常见的3种情

随机推荐