MySQL的锁实现
乐观锁
乐观锁 ( Pessimistic Locking ),总是会很乐观的认为,每次去读数据的时候都认为他人会批改,所以每次在读数据的时候都会上锁, 这样他人想读取数据就会阻塞直到它获取锁 (共享资源每次只给一个线程应用,其它线程阻塞,用完后再把资源转让给其它线程)。 传统的关系型数据库里边就用到了很多乐观锁机制,比方行锁,表锁等,读锁,写锁等,都是在做操作之前先上锁。
乐观锁
乐观锁( Optimistic Locking ),总是会乐观的认为,每次去读数据的时候都认为他人不会批改,所以不会上锁, 然而在更新的时候会判断一下在此期间有没有其余线程更新该数据, 能够应用版本号机制和CAS算法实现。 乐观锁实用于多读的利用类型,这样能够进步吞吐量。CAS是英文单词Compare and Swap的缩写,翻译过去就是比拟并替换。CAS机制中应用了3个根本操作数:内存地址V,旧的预期值A,要批改的新值B。更新一个变量的时候,只有当变量的预期值A和内存地址V当中的理论值雷同时,才会将内存地址V对应的值批改为B。
乐观锁应用
创立一个数据库
DROP DATABASE IF EXISTS locktest;CREATE DATABASE locktest;USE locktest;DROP TABLE IF EXISTS warehouse;CREATE TABLE IF NOT EXISTS warehouse ( id INTEGER NOT NULL, stock INTEGER DEFAULT 0, version INTEGER DEFAULT 1, PRIMARY KEY (id)) ENGINE = INNODB;INSERT INTO warehouse VALUE (1, 200, 1);SELECT * FROM warehouse;
id stock version 1 200 1 关上2个MySQL终端,并敞开主动提交:set autocommit = 0;
autocommit 只对反对事务的引擎起作用,如InnoDB,默认状况下autocommit的值为1,MySQL默认对写操作会主动开启事务,autocommit = 1时会在操作执行commit提交操作
set autocommit = 0;
第1个终端执行查问 这里咱们应用for update关键字给表上锁
select * from warehouse where id = 1 for update;
mysql> select * from warehouse where id = 1 for update; +----+-------+---------+| id | stock | version |+----+-------+---------+| 1 | 0 | 1 |+----+-------+---------+ 1 row in set (0.04 sec)
这时咱们在第2个终端也执行一次查问,会发现查问被挂起了
mysql> select * from warehouse where id = 1 for update; ............有限期待中................
- 这里是因为咱们首先敞开了主动提交,第1个终端的查问操作没有提交,这时候在第2个终端执行的查问语句会挂起,期待前一个操作提交
咱们把第1个终端的操作更新提交了
update warehouse set stock = stock - 1 where id = 1;commit;
咱们会发现第2个终端的查问终于执行了,咱们能够发现这个操作被挂起了15秒,直到前一个操作提交了事务
mysql> select * from warehouse where id = 1 for update; +----+-------+---------+| id | stock | version |+----+-------+---------+| 1 | 199 | 1 |+----+-------+---------+ 1 row in set (15.32 sec)mysql>
- 这里咱们能够得出个论断,在执行A操作时,MySQL乐观锁能够阻止B操作,直至第一次操作提交事务,B操作才会被执行,理论应用能够解决一些商城超买的并发问题(当然,高并发必定要应用Redis等缓存服务器,不然以数据库的性能和速度齐全不够用)
高并发测试
筹备接口
咱们这里应用PHP编写一个抢购的接口
$dsn = array('host' => '127.0.0.1', //设置服务器地址'port' => '3306', //设端口'dbname' => 'locktest', //设置数据库名'username' => 'root', //设置账号'password' => 'root', //设置明码'charset' => 'utf8', //设置编码格局'dsn' => 'mysql:host=127.0.0.1;dbname=locktest;port=3306;charset=utf8',);//连贯$options = array(PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION, //默认是PDO::ERRMODE_SILENT, 0, (疏忽错误模式)PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC, // 默认是PDO::FETCH_BOTH, 4);try{$db = new PDO($dsn['dsn'], $dsn['username'], $dsn['password'], $options);}catch(PDOException $e){die('数据库连贯失败:' . $e->getMessage());}$list = $db->query('SELECT * FROM `warehouse` WHERE `id` = 1')->fetchAll();if ($list[0]['stock'] >= 1){$db->exec("UPDATE `warehouse` SET `stock` = `stock` - 1 WHERE `id` = 1");print_r("买到了一个");}else{print_r("库存没有了:" . $list[0]['stock']);}
装置jmeter
- JMeter是Apache组织开发的基于Java的压力测试工具。用于对软件做压力测试,它最后被设计用于Web利用测试,但起初扩大到其余测试畛域。
- 下载jmeter
- 点击这个下载
- 将jmeter解压到一个中央,进入bin目录,关上jmeter.sh或者jmeter.bat都能够(sh须要当时装置sh脚本解释器,bat则应用cmd关上)
- 关上来是这样子的
- 右击增加一个线程组
- 在增加一个http申请
- 增加一个查问后果树
- 咱们这里能够设置并发,线程数设置500,意思是同一时间内500条线程同时拜访接口,循环次数设置为5。意思是每个线程循环拜访5次
- 将方才咱们的接口填入HTTP申请外面
开始测试
- 点击绿色的开始按钮
- 这里如果第一次点击开始,会提醒你是否保留jmx配置文件,咱们找个中央保留即可
- 查看后果
- 咱们发现库存变成正数了,这是不被容许的,如果这是个商城,超买了是会承当不少损失的,事实上咱们在接口里进行了库存判断,然而因为是并发执行,所以会存在同时查询数据库,呈现超买的问题
在接口外面的查问SQL里应用乐观锁,这里须要开启事务
批改后:// 开启事务$db->beginTransaction();$list = $db->query('SELECT * FROM `warehouse` WHERE `id` = 1 FOR UPDATE')->fetchAll();if ($list[0]['stock'] >= 1){$db->exec("UPDATE `warehouse` SET `stock` = `stock` - 1 WHERE `id` = 1");print_r("买到了一个");$db->commit();}else{print_r("库存没有了:" . $list[0]['stock']);}
- 咱们先把数据库里的库存加回200,在试一遍,咱们会发现超买的问题解决了
- 点击绿色的开始按钮
应用乐观锁的论断
- 咱们在接口外面的SELECT查问里应用表锁 锁定了库存表,这样会让其他人先停下来,等到咱们把库存-1,在提交事务后,其他人能力进行查问,这样就避免了超买的问题
- 能够晓得每次查问都会锁表,所以在多读的场景下乐观锁会有额定不必要的开销,更适宜多写的环境
- 因为乐观锁会很王道的锁表,所以如果锁表的接口呈现问题,会导致后续的查问永远挂起,造成死锁的状况
- 锁表只能在反对事务的数据库引擎下应用
- 高并发如秒杀流动之类的场景,举荐应用Redis等缓存服务器