库存超出常见解决方案整理

小艾

PHP

发布于：Apr 16, 2022

650 words

3 min

原文链接：使用laravel解决库存超出的几个方案

库存超出是一个常见的幂等问题，下面介绍一下解决超卖问题常见的一些方案

Redis 存储库存
Redis 原子锁
Mysql 悲观锁
Mysql 乐观锁

准备

准备一张实验表：

+-------+------------------+------+-----+---------+----------------+
| Field | Type             | Null | Key | Default | Extra          |
+-------+------------------+------+-----+---------+----------------+
| id    | int(11) unsigned | NO   | PRI | NULL    | auto_increment |
| name  | varchar(10)      | YES  |     | NULL    |                |
| num   | int(11)          | YES  |     | NULL    |                |
+-------+------------------+------+-----+---------+----------------+

使用 go 模拟并发：

package main

import (
    "fmt"
    "github.com/PeterYangs/tools/http"
    "sync"
)

func main() {
    client := http.Client()
    wait := sync.WaitGroup{}
    for i := 0; i < 50; i++ {
        wait.Add(1)
        go func(w *sync.WaitGroup) {
            defer w.Done()
            res, _ := client.Request().GetToString("http://www.api/test1?id=1")
            fmt.Println(res)
        }(&wait)
    }
    wait.Wait()
}

错误示范


function test()
{

    $id = request()->input('id');
    $product = Product::where('id', $id)->firstOrFail();

    if ($product->num <= 0) {
        return "卖光啦！！";
    }

    $product->decrement('num');
    return "success";
}

查看库存：

库存超出。

Redis 存储库存

public function test()
{
    $id = request()->input('id');
    $redis = new \Redis();
    $num = $redis->rawCommand('get', 'product_' . $id);
    if ($num <= 0) {
        return "卖完啦！";
    }

    //减库存
    $result = $redis->rawCommand('decrby', 'product_' . $id, 1);
    //减多了回滚
    if ($result < 0) {
        $redis->rawCommand('incrby', 'product_' . $id, 1);
        return "卖完啦！";
    }
    return 'success';
}

库存正常。

Redis 原子锁

public function test()
{
    $id = request()->input('id');
    $lock = \Cache::lock("product_" . $id, 10);
    try {

        //最多等待5秒，5秒后未获取到锁，则抛出异常
        $lock->block(5);
        $product = TbModel::where('id', $id)->firstOrFail();

        if ($product->num <= 0) {
            return "卖光啦！！";
        }

        $product->decrement('num');
        return 'success';
    }catch (LockTimeoutException $e) {
        return '当前人数过多';
    } finally {
        optional($lock)->release();
    }
}

库存正常。

Mysql 悲观锁

public function test()
{
    $id = request()->input('id');

    try {
        \DB::beginTransaction();
        $product = Product::where('id', $id)->lockForUpdate()->first();

        if ($product->num <= 0) {
            return "卖光啦！！";
        }

        $product->decrement('num');
        \DB::commit();
        return "success";
    } catch (\Exception $exception) {
        return "error";
    }
}

库存正常。

Mysql 乐观锁

public function test()
{
    $id = request()->input('id');
    $product = TbModel::where('id', $id)->first();
    if ($product->num <= 0) {
        return "卖光啦！！";
    }

    //修改前检查库存和之前是否一致，不一致说明已经有变动，则放弃更改
    $res = \DB::update('UPDATE `tb` SET num = num -1 WHERE id = ? AND num=?', [$id, $product->num]);
    if (!$res) {
        return '当前人数过多';
    }
  
    return 'success';
}