并发条件下，update 语句中直接赋值和计算的区别是什么？

学习 redis 时的一个 demo

表结构#

商品信息表

CREATE TABLE `ims_hotmallstore_goods` (
`id` int(11) unsigned NOT NULL AUTO_INCREMENT,
`name` varchar(50) NOT NULL COMMENT '商品名称',
`type_id` int(11) NOT NULL COMMENT '商品分类',
`img` text COMMENT '商品图片',
`money` decimal(10,2) NOT NULL COMMENT '售价',
`money2` decimal(10,2) NOT NULL COMMENT '原价',
`is_show` int(11) NOT NULL DEFAULT '1' COMMENT '1.上架2.下架',
`uniacid` int(11) DEFAULT NULL COMMENT '小程序id',
`inventory` int(11) NOT NULL COMMENT '库存',
`details` text NOT NULL COMMENT '详情',
`store_id` int(11) NOT NULL COMMENT '商家id',
`sales` int(11) NOT NULL COMMENT '销量',
`logo` varchar(100) DEFAULT NULL,
`num` int(11) NOT NULL,
`is_gg` int(11) NOT NULL DEFAULT '2' COMMENT '是否开启规格',
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;

订单表

CREATE TABLE `ims_order` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`order_sn` char(32) NOT NULL,
`user_id` int(11) NOT NULL,
`status` int(11) NOT NULL DEFAULT '0',
`goods_id` int(11) NOT NULL DEFAULT '0',
`sku_id` int(11) NOT NULL DEFAULT '0',
`number` int(11) NOT NULL,
`price` int(10) NOT NULL COMMENT '价格：单位为分',
`create_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=7521 DEFAULT CHARSET=utf8 COMMENT='订单表';

订单日志表

CREATE TABLE `ims_order_log` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`status` int(11) NOT NULL DEFAULT '0',
`msg` text CHARACTER SET utf8,
`create_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
PRIMARY KEY (`id`),
KEY `status` (`status`)
) ENGINE=InnoDB AUTO_INCREMENT=10466 DEFAULT CHARSET=gb2312 COMMENT='订单日志表';

demo 源码#

<?php 
include "../vendor/autoload.php";
class Test {
private static $instance = null;
private static $pdo = null;
public static function Redis()
{
    if (self::$instance == null ) {
        $redis = new Predis\Client([
            'scheme' => 'tcp',
            'host'   => '127.0.0.1',
            'port'   => 6379,
        ]);
        self::$instance = $redis;
    }
    return self::$instance;
}

public static function Pdo(){
    if(self::$pdo==null){
        $config = array();
        $config['db']['host'] = 'localhost';
        $config['db']['username'] = 'homestead';
        $config['db']['password'] = 'secret';
        $config['db']['port'] = '3306';
        $config['db']['database'] = 'redisdemo';
        $config['temp'] =str_replace("\\", '/',dirname(__FILE__))."/cache/";//临时目录
        $config['db']['charset'] = 'utf8';
        $config['db']['pconnect'] = 0;
        $config['db']['tablepre'] = 'ims_';
        $config['domain'] = "http://".$_SERVER['HTTP_HOST']."/";//域名
        $pdo = new \Crh\DB($config);
        // $pdo = new \Slim\PDO\Database($dsn, $usr, $pwd);
        self::$pdo = $pdo;
    }
    return self::$pdo;
}

// 将商品库存循环到lpush的num里
public function doPageSaveNum()
{
    $redis=self::Redis();
    $pdo = self::Pdo();
    $goods_id=1;
    $sql="select id, num, money from ims_hotmallstore_goods where id=".$goods_id;
    $goods = $pdo->fetch($sql);

    if(!empty($goods)){
     for($i=1; $i<=$goods['num']; $i++){
         $redis->lpush('num',$i);
     }
     die('成功！');
    }else{
     $this->echoMsg(0,'商品不存在。');
    }
}

// 抢购下单
public function doPageGoodsStore()
{
        $pdo = self::Pdo();
        $goods_id=1;
        $sql="select id, num, money from ims_hotmallstore_goods where id=".$goods_id;
        $goods = $pdo->fetch($sql);
        $redis=self::Redis();
        $count=$redis->rpop('num');//每次从num取出1
        if($count==0){
            $this->echoMsg(0,'no num redis');
        }
        $this->doPageGoodsOrder($goods,1);

}

// 保存日志
public function echoMsg($status,$msg,$_data="")
{
    $pdo = self::Pdo();
    $data=json_encode(array('status'=>$status,'msg'=>$msg,'data'=>$_data),JSON_UNESCAPED_UNICODE);
    $order_log['status']=$status;
    $order_log['msg']=$msg;
    $order_log['create_time']=date('Y-m-d H:i:s');
    $goods = $pdo->insert('order_log', $order_log);
    die($data);
}
public function orderNo()
{
    return date('ymd').substr(implode(NULL, array_map('ord', str_split(substr(uniqid(), 7, 13), 1))), 0, 8);
}

// 下单更新库存
public function doPageGoodsOrder($goods,$goods_number)
{   
    $pdo = self::Pdo();
    $orderNo=$this->orderNo();
    $number=$goods['num']-$goods_number;
    if($number<0){
        $this->echoMsg(0,'已没有库存');
    }
    $user_id=rand(1,500);
    $order['user_id']=$user_id;
    $order['goods_id']=$goods['id'];
    $order['number']=$goods_number;
    $order['price']=$goods['money'];
    $order['status']=1;
    $order['sku_id']=2;
    $order['order_sn']=$orderNo;
    $order['create_time']=date('Y-m-d H:i:s');
    $pdo->insert('order', $order);
    // 问题所在
    // $sql="update ims_hotmallstore_goods set num=num-".$goods_number." where num>0 and id=".$goods['id'];
    $sql="update ims_hotmallstore_goods set num=$number where num>0 and id=".$goods['id'];
    $res = $pdo->query($sql);
    if(!empty($res)){
        $this->echoMsg(1,'库存扣减成功'.$number);
    }
    $redis=self::Redis();
    $redis->lpush('num',$goods_number);
    $this->echoMsg(0,'库存扣减失败'.$number);
}
}
// 调用--将商品库存循环到lpush的num里
if($_GET['i']==1){
$model = new Test;
$model->doPageSaveNum();
}
// 调用--高并发抢购下单
if($_GET['i']==2){
$model = new Test;
$model->doPageGoodsStore();
}

代码已被折叠，点此展开

使用#

初始化数据
http://redis.test/demo/test.php?i=1
使用
http://redis.test/demo/test.php?i=2

结果#

以抢购 100 件商品为例，商品表 num=100
在函数 doPageGoodsOrder 中，如果使用如下 sql

$sql="update ims_hotmallstore_goods set num=$number where num>0 and id=".$goods['id'];

即直接更新数据，不在 sql 中运算，在使用 apache ab 测试时

ab -n 1000 -c 100 http://redis.test/demo/test.php?i=2

发现：

商品表，num 字段不为 0
订单表，生成 456 份订单
日志表，1000 条日志，其中抢购成功的即 status=1 的是 100 条

如果在 sql 中计算，即：

$sql="update ims_hotmallstore_goods set num=num-".$goods_number." where num>0 and id=".$goods['id'];

结果正常，num=0，订单 100 条，日志 1000 条

问题#

为什会出现这种现象（猜测是锁，但不了解具体的机制，正在学习）
这个 demo，是否能算一个解决超卖的基本方法

谢谢！

sql 并发 redis

// 抢购下单 public function doPageGoodsStore() { $pdo = self::Pdo(); $goods_id=1; /**诺，问题所在对于 redis 来说，它属于单线程的原子性操作，但是 mysql 不是。所以这里拿商品数据，你是通过查询数据库获取的。而又因为你算库存的时候，通过查询数据库获取到的库存来计算，在并发情况下自然会引起不正确，这里的库存数，建议也通过 redis 中存储的热数据来计算比如 $stock = $redis->llen('num'); **/ $sql="select id, num, money from ims_hotmallstore_goods where id=".$goods_id; }

讨论数量: 7

畅畅

126 声望

并发高的情况下，必须要用 mysql 的更新锁。
问题出在上面判断库存的时候：

假设 A 取到的是剩余 100 库存，并发时 B 取到的也是 100 库存
当 A 自行减法算出库存为 99 并更新，这时 C 拿到的库存可能是 100，也可能是 99
当 C 自行减一后，算出 98 时，这时候可能 B 算出来是 99 并更新到库存
当 D 获得库存时，可能是 99 还可能是 100
以上就会出现这种情况。

解决方案：
使用 mysql 事务处理，在获取库存之前开始处理事务并锁定表，然后结束事务，laravel 文档中有这一条代码

DB::table('users')->where('votes', '>', 100)->lockForUpdate()->get();

5年前评论

crhhoho （楼主）

您好，通过您的解释我大概明白了为什么"先运算再赋值到sql语句"行不通。但是还有一点疑惑，代码中并没有使用事务或执行lock相关的操作，请问是否在sql语句中执行计算会自行触发锁呢？

畅畅（作者）

@crhhoho 不行奥，必须使用锁，而且还得是在事务中，当前也可以用redis做队列，来单线程处理购买的逻辑

ngnix

1 声望

可以了解一下数据库的锁的机制在对数据发生变更的时候 mysql 是自带锁的

35 声望

应该是插入订单成功了；而更新库存时，当库存为 0 以后的库存更新失败。
可以加上事务，当库存更新失败时，订单插入也回滚

颠倒的玉石

课程读者 166 声望 / 技术小垃圾 @ 山西证券

可以用 redis 的原子操作

lxping

88 声望

补充第二个问题，看下来是不会的，但是会出现数据的错误，最直接的就是你能看到的超库存。

当然，这个还有一些隐藏的问题。因为并发，数据库压力比较大，如果实时去 update 和 insert 的话，会出现一些单点故障，比如数据库奔溃。

我一般入库的做法是在热度过后再批量入库。

实测了一下使用$redis->llen('num');拿库存，并不能解决问题哦使用 $stock = $redis->llen('num'); 替代sql库存查询并发读取的时候，还是可能拿到相同的 库存值这个问题我后面再思考了一下，结合各位的回复，主要问题还是出在并发读取时，拿到了相同的库存值如果用update table set num = 计算后的库存值 where ··· 会不可避免的发生库存数值异常

萧晔离

Laravel 9.x 译者 42 声望 / 打杂总管 @ 广电区块链

mark

redline

4 声望

讨论应以学习和精进为目的。请勿发布不友善或者负能量的内容，与人为善，比聪明更重要！

帮助

并发条件下，update 语句中直接赋值和计算的区别是什么？

表结构#

demo 源码#

使用#

结果#

问题#

推荐文章：

社区赞助商

关于 LearnKu

资源推荐

服务提供商

其他信息

并发条件下，update 语句中直接赋值和计算的区别是什么？

表结构#

demo 源码#

使用#

结果#

问题#

推荐文章：

社区赞助商

关于 LearnKu

资源推荐

服务提供商

其他信息

请登录