秒杀系统难点解决方案

1_秒杀系统难点解决方案

请求削峰到mq (否则返回抢购失败),
redis处理下单请求,基于lua脚本扣减库存>>>>扣减成功(否则返回抢购失败),
然后以数据库能承受的程度开启线程批量消费数据 ,小粒度化使用乐观锁,再次保证库存扣减安全 .

sql脚本

# 修改商品库存
update item 
set quantity = quantity - 1 
where id = 1 and quantity  > 0

lua脚本 KEYS为skuId，values是对应需要扣减的库存

-- 可能回滚的列表，一个记录要回滚的skuid一个记录库存
local id_list= {}
local quantity_list= {}

-- 调用放传递的keys 和 values  execute(RedisScript<T> script, List<K> keys, Object... args)
local keys = KEYS
local values = ARGV;

local function deduction(key,num)
    keys[1] = key;
    local value = redis.call("get",keys[1])
    if not value then
        value = 0;
    end
    value = value + num
    -- 变更后库存数量小于
    if(value<0)
    then
        -- 发生超卖
        return false;
    end
    redis.call("set",keys[1],value)

    return true
end

local function rollback()
    for i,k in ipairs (id_list) do
        -- 还原库存
        keys[1] = k;
        redis.call("incrby",keys[1],0-quantity_list[i])
    end
end

local function execute()
    -- i 类java for循环 for(int i=0;i<?;i++) 下标
    -- k 为遍历的值 具体值，非下标
    for i, k in ipairs (values)
    do
        -- num 变更数量
        -- key 为缓存key
        local num = tonumber(k)
        local key=  keys[i]
        -- 进行库存扣减，为false 代表扣减失败，要进行回滚
        local result = deduction(key,num)

        -- 回滚
        if (result == false)
        then
            rollback()
            return false
        else
            -- 记录可能要回滚的数据
            table.insert(id_list,key)
            table.insert(quantity_list,num)
        end

    end
    return true;
end

return execute()