订单并发问题及解决方案
订单并发问题分析及解决
问题：
当多人同时购买同一件商品时，有可能会产生订单并发问题。
例如：
id为16的商品库存有10件，两人同时购买这件商品，每人购买5件，产生订单并发问题之后，两个下单都成功，但是商品的库存变为5件。
订单并发解决方案：
1）悲观锁
在事务中查询数据的时候尝试对数据进行加锁(互斥锁), 获取到锁的事务可以对数据进行操作，获取不到锁的事务会阻塞，直到锁被释放。
悲观锁有死锁问题，不推荐使用
2）乐观"锁"
乐观锁本质上不是加锁，查询数据的时候不加锁，对数据进行修改的时候需要进行判断,修改失败需要重新进行尝试。
3）任务队列
将下单的代码封装成celery任务函数，在下单API中只是发出下单的任务消息，同时celery的worker工作进程进行只创建一个。
mysql事务隔离级别：
隔离级别 说明
Repeatable read 可重复读 在一个事务中执行同一个查询语句时，获取到的查询结果永远和第一次获取到结果一致，即使其他事务已经修改了
对应的数据并且也进行了提交，当前事务也获取不到更新之后结果。
Read committed 读取已提交 其他事务只有修改了对应的数据并且也进行了提交，当前事务就能获取更新之后的结果。
mysql数据库的事务默认隔离级别是: Repeatable read 可重复读
修改mysql事务隔离级别
# 1. 修改mysql数据库配置文件
sudo vi /etc/mysql/mysql.conf.d/mysqld.cnf
# 2. 添加配置项
27 [mysqld]
28 #
29 # * Basic Settings
30 #
31 user = mysql
32 pid-file = /var/run/mysqld/mysqld.pid
33 socket = /var/run/mysqld/mysqld.sock
34 port = 3306
35 basedir = /usr
36 datadir = /var/lib/mysql
37 tmpdir = /tmp
38 lc-messages-dir = /usr/share/mysql
39 skip-external-locking
40 # 将mysql事务的隔离级别设置为读取已提交
41 transaction-isolation=READ-COMMITTED
# 3. 重启mysql服务
sudo service mysql restart
最后商品库存变成了 -3 （超卖了3）
压测记录结果：
压测并发有点少，因为我机子最大打开2048个文件，网络用的4g，也受网络影响等因素，如果压测的本地机器和网络好更准些。
回顾：如果 $result = Yii::$app->getDb()->createCommand("UPDATE goods SET number = number - 1 WHERE id = 1 LIMIT 1")->execute(); // 更新库存 这一句不是这么更新 set `库存字段` = `库存字段` - 1 ，而是计算好再更新进去 $number = $number -1 就不会出现负数或设置库存字段属性为UNSINGED,但不能真正解决掉问题，因为实际还是多执行3次，这么写是为了测试负数，也就是这句里面
if ($model->number > 0) { 实际执行了103次，超出100的库存, 也就是说当 库存$model->number等于1时 同时并发3请求执行到这里，这3个并发查询出来的库存都为1的时候都执行了更新库存导致的。
解决超卖问题：
/**
* 提前把商品库存入队列
*/
public function actionSetStore()
{
$redis = Yii::$app->redis;
$model = Goods::find()->where(['id' => 1])->one(); //商品信息
for ($i = 0; $i < $model->number; $i++)
{
$redis->lpush('goods_store', 1);
}
}
/**
* 下单
* @return string
* @throws \yii\db\Exception
*/
public function actionIndex()
{
$redis = Yii::$app->redis; // 使用redis做一些统计
$count = $redis->lpop('goods_store'); // 出队列
if ($count) { // 判断库存是否出完队列
// 更新库存等逻辑
$result = Yii::$app->getDb()->createCommand("UPDATE goods SET number = number - 1 WHERE id = 1 LIMIT 1")->execute();
}
else {
die('卖完了');
}
die('成功');
}
订单并发解决 Redis队列
/** * 下单 * @return string * @throws \yii\db\Exception */ public function actionIndex() { $redis = Yii::$app->redis; // 使用redis做一些统计 $redis->incr('total'); // 自增（记录一共成功进来了多少个请求） //$redis->del('total'); //$redis->del('update'); //$redis->del('success'); //$redis->del('faild');die; //var_dump('total:' . $redis->get('total')); //var_dump('success: ' . $redis->get('success')); //var_dump('faild:' . $redis->get('faild')); //var_dump('update:' . $redis->get('update'));die; $model = Goods::find()->where(['id' => 1])->one(); // 购买的商品信息 if ($model->number > 0) { // 判断库存是否大于0 $redis->incr('update'); // 记录并发时进来的请求数 $result = Yii::$app->getDb()->createCommand("UPDATE goods SET number = number - 1 WHERE id = 1 LIMIT 1")->execute(); // 更新库存 if($result){ // 更新成功插入订单数据， 这里应该是要写事务的 $orderModel = new Orders(); $orderModel->price = $model->price; $orderModel->name = $model->name; $orderModel->create_time = time(); $orderModel->save(false); $redis->incr('success'); // 记录更新成功数 }else{ $redis->incr('faild'); // 记录更新成功数 } } die('成功'); return $this->render('index'); } k6压测：非阻塞的文件排他锁
$fp = fopen('lock.txt','w+');
$lock_status = flock($fp,LOCK_EX|LOCK_NB); // 文件执行非阻塞锁定.
if(!$lock_status) { //当该文件被锁定时,无法再次被锁定
echo "网络繁忙，请稍后再试";
return;
}
// 执行库存查询，订单生产 库存减少等操作.
// 当时间执行结束以后，执行释放锁.
$unlock_status = flock($fp,LOCK_UN);
if ($unlock_status) {
echo "解锁成功";
}
fclose($fp);