如何設(shè)計(jì)一個秒殺系統(tǒng)

設(shè)計(jì)一個秒殺系統(tǒng)時(shí)，Redis可以作為一個高性能的工具來防止庫存超賣。以下是具體的設(shè)計(jì)思路和實(shí)現(xiàn)方法：

#?？虯I配圖神器#

1. 使用 Redis 的原子操作

Redis 提供了多種原子性操作命令，這些命令可以在高并發(fā)場景下確保數(shù)據(jù)的一致性。

INCR/DECR：通過遞增或遞減某個鍵的值來控制庫存。
GETSET：獲取當(dāng)前值并設(shè)置新值，保證操作的原子性。
Lua 腳本：將多個操作封裝在一個 Lua 腳本中執(zhí)行，Redis 會保證腳本內(nèi)的操作是原子性的。

示例代碼（使用 Lua 腳本）

local stock_key = KEYS[1]
local stock_count = tonumber(redis.call('get', stock_key))

if stock_count > 0 then
    redis.call('decr', stock_key)
    return 1  -- 表示扣減成功
else
    return 0  -- 表示庫存不足
end

2. 分布式鎖

在高并發(fā)場景下，可以通過分布式鎖來確保同一時(shí)間只有一個請求能夠修改庫存。

SETNX：嘗試設(shè)置一個鍵，如果鍵不存在則設(shè)置成功，否則失敗。
Redlock 算法：更復(fù)雜的分布式鎖實(shí)現(xiàn)，適合多 Redis 實(shí)例環(huán)境。

示例代碼（使用 SETNX）

String lockKey = "lock:product:" + productId;
boolean locked = redis.setnx(lockKey, "1");

if (locked) {
    try {
        // 扣減庫存邏輯
        redis.decr("stock:" + productId);
        return "秒殺成功";
    } finally {
        // 釋放鎖
        redis.del(lockKey);
    }
} else {
    return "秒殺失敗，庫存不足或正在處理其他請求";
}

3. 預(yù)減庫存

在用戶下單前，先進(jìn)行庫存預(yù)減操作，避免用戶提交訂單時(shí)庫存已不足。

在用戶加入購物車或點(diǎn)擊秒殺按鈕時(shí)，立即扣減 Redis 中的庫存。
如果后續(xù)訂單支付失敗或超時(shí)未支付，再將庫存歸還。

示例代碼（預(yù)減庫存）

String stockKey = "stock:" + productId;

// 嘗試扣減庫存
Long stock = redis.decr(stockKey);

if (stock >= 0) {
    return "秒殺成功，等待支付";
} else {
    // 庫存不足時(shí)回滾
    redis.incr(stockKey);
    return "秒殺失敗，庫存不足";
}

4. 限流與隊(duì)列

為了進(jìn)一步保護(hù)系統(tǒng)，可以引入限流和消息隊(duì)列機(jī)制。

限流：通過令牌桶或漏桶算法限制請求頻率。
消息隊(duì)列：將秒殺請求放入隊(duì)列中異步處理，減少對數(shù)據(jù)庫的壓力。

示例代碼（使用 Redis 實(shí)現(xiàn)限流）

String rateLimitKey = "rate:limit:" + userId;

// 每秒允許 5 次請求
long allowedRequests = 5;
long timestamp = System.currentTimeMillis();

if (redis.exists(rateLimitKey)) {
    long lastRequestTime = Long.parseLong(redis.get(rateLimitKey));
    if (timestamp - lastRequestTime < 1000 / allowedRequests) {
        return "請求過于頻繁，請稍后再試";
    }
}

// 更新最后請求時(shí)間
redis.set(rateLimitKey, String.valueOf(timestamp), 1, TimeUnit.SECONDS);
return "請求通過";