资讯专栏INFORMATION COLUMN

PHP利用Mysql锁解决高并发

Coly / 1018人阅读

摘要:前面写过利用文件锁来处理高并发的问题的,现在我们说另外一个处理方式,利用的锁来解决高并发的问题先看没有利用事务的时候并发的后果创建库存管理表创建订单管理表测试代码我们预置库存是十个,然后执行测试查看结果

前面写过利用文件锁来处理高并发的问题的,现在我们说另外一个处理方式,利用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=latin1
创建订单管理表
CREATE TABLE `order` (
  `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
  `number` int(11) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=34 DEFAULT CHARSET=latin1
测试代码
$pdo = new PDO("mysql:host=127.0.0.1;port=3306; dbname=test","root","123456");
$sql="select `number` from  storage where id=1 limit 1";
$res = $pdo->query($sql)->fetch();
$number = $res["number"];

if($number>0)
{
    $sql ="insert into `order`  VALUES (null,$number)";
   
    $order_id = $pdo->query($sql);
    if($order_id)
    {

        $sql="update storage set `number`=`number`-1 WHERE id=1";
        $pdo->query($sql);
    }
}
我们预置库存是十个,然后执行ab测试查看结果
mysql> select * from storage
    -> ;
+----+--------+
| id | number |
+----+--------+
|  1 |     -2 |
+----+--------+
1 row in set (0.00 sec)

mysql> select * from `order`;
+----+--------+
| id | number |
+----+--------+
| 22 |     10 |
| 23 |     10 |
| 24 |      8 |
| 25 |      8 |
| 26 |      7 |
| 27 |      6 |
| 28 |      4 |
| 29 |      3 |
| 30 |      2 |
| 31 |      2 |
| 32 |      2 |
| 33 |      1 |
+----+--------+
12 rows in set (0.00 sec)

得到了订单共有12个,而库存表的库存也减到了-2,这显然不符合实际逻辑的;

下面我们来看利用数据库行锁来解决这个问题
修改代码如下
$pdo = new PDO("mysql:host=127.0.0.1;port=3306; dbname=test","root","123456");
$pdo->beginTransaction();//开启事务
$sql="select `number` from  storage where id=1 for UPDATE ";//利用for update 开启行锁
$res = $pdo->query($sql)->fetch();
$number = $res["number"];

if($number>0)
{
    $sql ="insert into `order`  VALUES (null,$number)";

    $order_id = $pdo->query($sql);
    if($order_id)
    {

        $sql="update storage set `number`=`number`-1 WHERE id=1";
        if($pdo->query($sql))
        {
            $pdo->commit();//提交事务
        }
        else
        {
            $pdo->rollBack();//回滚
        }

    }
    else
    {
        $pdo->rollBack();//回滚
    }
}
查看结果
mysql> select * from storage;
+----+--------+
| id | number |
+----+--------+
|  1 |      0 |
+----+------
--+
1 row in set (0.00 sec)

mysql> select * from `order`;
+----+--------+
| id | number |
+----+--------+
|  1 |     10 |
|  2 |      9 |
|  3 |      8 |
|  4 |      7 |
|  5 |      6 |
|  6 |      5 |
|  7 |      4 |
|  8 |      3 |
|  9 |      2 |
| 10 |      1 |
+----+--------+
10 rows in set (0.00 sec)

很明显在利用了mysql锁之后,对库存进行了有效的控制,很好的解决了第一段代码里面,因为并发引起的一些逻辑性的问题

文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。

转载请注明本文地址:https://www.ucloud.cn/yun/29399.html

相关文章

  • 秒杀系统优化方案之缓存、队列、设计思路

    摘要:一为什么难秒杀系统难做的原因库存只有一份,所有人会在集中的时间读和写这些数据。又例如抢票,亦与秒杀类似,瞬时流量更甚。 一、为什么难     秒杀系统难做的原因:库存只有一份,所有人会在集中的时间读和写这些数据。例如小米手机每周二的秒杀,可能手机只有1万部,但瞬时进入的流量可能是几百几千万。又例如12306抢票,亦与秒杀类似,瞬时流量更甚。 主要需要解决的问题有两个: 高并发对数据库...

    dinfer 评论0 收藏0
  • Mysql机制与PHP文件处理并发简单思路

    摘要:以购买商品举例从数据库获取库存的数量。这里暂时就不测试了,下面会针对并发的处理给出测试结果。第二种方案,使用的文件锁。特点当调用锁一个文件时,如果没有获取锁,直接返回,不会出现阻塞。的表锁和的文件锁在应对并发数量上也有差别,自己可以多测试。 以购买商品举例: ① 从数据库获取库存的数量。② 检查一下库存的数量是否充足。③ 库存的数量减去买家购买的数量(以每个用户购买一个为例)。④ 最后...

    sunsmell 评论0 收藏0

发表评论

0条评论

Coly

|高级讲师

TA的文章

阅读更多
最新活动
阅读需要支付1元查看
<