Mysql的锁机制与PHP文件锁处理高并发简单思路

以购买商品举例:mysql

① 从数据库获取库存的数量。
② 检查一下库存的数量是否充足。
③ 库存的数量减去买家购买的数量(以每一个用户购买一个为例)。
④ 最后完成购买。sql

仅仅这几行逻辑代码在并发的状况下会出现问题,本身能够想象一下。
这里暂时就不测试了,下面会针对并发的处理给出测试结果。
建立表:数据库

CREATE TABLE `warehouse` (
  `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'id',
  `stock` int(11) NOT NULL DEFAULT '0' COMMENT '库存',
  PRIMARY KEY (`id`)
) ENGINE=MyISAM AUTO_INCREMENT=3 DEFAULT CHARSET=utf8

第一种方案,使用Mysql的锁(跟表引擎没有关系)。
共享锁:全部人能够读一个资源,但只有获取锁的人能够操做;
排它锁:只有得到所的对象能够操做资源,其余的不能操做,读都不能够。
语法:并发

LOCK TABLE a READ,b WRITE,c READ,d WRITE;(能够锁多张表,在锁表的过程当中只能操做被锁的表,不能操做其余表)。
UNLOCK TABLES;(释放表)。
@$mysql = mysql_connect('localhost','root','');
mysql_query('set names utf8');
mysql_select_db('test');
mysql_query('LOCK TABLE `warehouse` WRITE');  //锁表以后同一时间只有一我的能操做,也就是只有一我的能获取到锁
$sql = 'SELECT `stock` FROM warehouse';
$res = mysql_query($sql);
$row= mysql_fetch_array($res);
$stock = $row[0];
if( $stock < 1) {
    die('库存不足');
}else{
    $new_stock = intval($stock - 1);
    mysql_query('UPDATE warehouse SET `stock` = '.$new_stock);
    mysql_query('UPDATE TABLES');
}

锁表的缺点是:会出现阻塞,若是同时锁多张表的话,还会影响整个网站相关表的加载。
第二种方案,使用PHP的文件锁。
特色:当调用flock锁一个文件时,若是没有获取锁,直接返回FALSE,不会出现阻塞。
排它锁:flock($fp,LOCK_EX);
共享锁:flock($fp,LOCK_SH);
释放锁:flock($fp,LOCK_UN);测试

@$mysql = mysql_connect('localhost','root','');
mysql_query('set names utf8');
mysql_select_db('test');
$fp = fopen('./lock.txt','r');
$try = 10;  //声明一个变量表示要获取的次数,防止死循环
do{
    $lock = flock($fp, LOCK_EX);
    if(!$lock)
        usleep(5000); //若是没有获取到锁,释放CPU,休息5000毫秒
}while(!$lock && --$try >=0 );
    if($lock) {
    $sql = 'SELECT `stock` FROM warehouse';
    $res = mysql_query($sql);
    $row = mysql_fetch_array($res);
    $stock = $row[0];
    if( $stock < 1) {
        die('库存不足');
    }else{
        $new_stock = intval($stock - 1);
        mysql_query('UPDATE warehouse SET `stock` = '.$new_stock);
    }
    flock($fp, LOCK_UN);
    fclose($fp);

}else{ die('系统繁忙!'); }

第三种方案,简单的SQL语句就能够避免仓库为负数。fetch

@$mysql = mysql_connect('localhost','root','');
mysql_query('set names utf8');
mysql_select_db('test');
mysql_query('UPDATE warehouse SET `stock` = `stock` -1 WHERE `stock` > 0');  //能够避免库存为负数

测试的方法是,找到Apache下的ab.exe,拖入CMD终端,而后输入指定参数测试。
具体参数说明Google一下你就知道,好比耗时之类的...这里不作详细说明。网站

clipboard.png
PS:Mysql的表锁和PHP的文件锁在应对并发数量上也有差异,本身能够多测试。总之方案还有不少spa

相关文章
相关标签/搜索