快捷導(dǎo)航

Redis分布式鎖解決超賣(mài)問(wèn)題的使用示例

更新時(shí)間：2023年09月11日 11:21:10 作者：猿究院楊樹(shù)林

超賣(mài)問(wèn)題通常出現(xiàn)在多用戶(hù)并發(fā)操作的情況下,即多個(gè)用戶(hù)嘗試購(gòu)買(mǎi)同一件商品,導(dǎo)致商品庫(kù)存不足或者超賣(mài),本文就來(lái)介紹一下超賣(mài)問(wèn)題,感興趣的可以了解一下

前言

超賣(mài)問(wèn)題通常出現(xiàn)在多用戶(hù)并發(fā)操作的情況下，即多個(gè)用戶(hù)嘗試購(gòu)買(mǎi)同一件商品，導(dǎo)致商品庫(kù)存不足或者超賣(mài)。解決超賣(mài)問(wèn)題的方法有很多：樂(lè)觀(guān)鎖、Redis分布式鎖、消息隊(duì)列等。分布式鎖是一種多節(jié)點(diǎn)共享的同步機(jī)制，通過(guò)在多個(gè)節(jié)點(diǎn)之間協(xié)調(diào)訪(fǎng)問(wèn)資源，確保在同一時(shí)間只有一個(gè)節(jié)點(diǎn)能夠獲取鎖并執(zhí)行關(guān)鍵操作。在電商網(wǎng)站中，可以將每個(gè)商品的庫(kù)存作為共享資源，使用分布式鎖來(lái)控制并發(fā)訪(fǎng)問(wèn)。

分布式鎖的目的是保證在分布式部署的應(yīng)用集群中，多個(gè)服務(wù)在請(qǐng)求同一個(gè)方法或者同一個(gè)業(yè)務(wù)操作的情況下，對(duì)應(yīng)業(yè)務(wù)邏輯只能被一臺(tái)機(jī)器上的一個(gè)線(xiàn)程執(zhí)行，避免出現(xiàn)并發(fā)問(wèn)題。

分布式鎖要滿(mǎn)足的條件：

多進(jìn)程互斥：同一時(shí)刻，只有一個(gè)進(jìn)程可以獲取鎖
● 阻塞鎖（可選）：獲取鎖失敗時(shí)可否重試
重入鎖（可選）：獲取鎖的代碼遞歸調(diào)用時(shí)，依然可以獲取鎖
保證鎖可以釋放：任務(wù)結(jié)束或出現(xiàn)異常，鎖一定要釋放，避免死鎖

Redis分布式鎖：

在實(shí)現(xiàn)Redis分布式鎖之前，我們先來(lái)看看為什么Redis能實(shí)現(xiàn)分布式鎖：

在Redis中，利用Redis的setnx命令，這個(gè)命令的特征時(shí)如果多次執(zhí)行，只有第一次執(zhí)行會(huì)成功，可以實(shí)現(xiàn)互斥的效果。這滿(mǎn)足了多線(xiàn)程互斥的要求。

SETNX lock thread1

在Redis中，利用Redis的del命令，可以刪除一個(gè)key,即釋放鎖。

DEL lock

如果獲取鎖成功后服務(wù)宕機(jī)，發(fā)生了不釋放鎖的問(wèn)題，Redis也可以通過(guò)給Key加有效時(shí)間，讓超時(shí)自動(dòng)釋放。這樣一來(lái)，也滿(mǎn)足了保證鎖可以釋放，達(dá)到了分布式鎖必須滿(mǎn)足的條件!

EXPIRE lock 10

并且，也不用擔(dān)心在EXPIRE設(shè)置有效期之前服務(wù)宕機(jī)，Redis的set命令可以滿(mǎn)足setnx和expirr的原子性，用一個(gè)指令完成兩個(gè)步驟！

set lock thread1 EX 10 NX

分布式架構(gòu)中實(shí)現(xiàn)

加Redis坐標(biāo)

<dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

配置Redis端口信息

Spring:
	redis:
	    port: 6379
	    host: localhost

構(gòu)造加鎖工具類(lèi)

public interface ILock {
    /**
     * 嘗試獲取鎖
     * @param timeoutSec 鎖持有的超時(shí)時(shí)間，過(guò)期后自動(dòng)釋放
     * @return true代表獲取鎖成功; false代表獲取鎖失敗
     */
    boolean tryLock(long timeoutSec);
    /**
     * 釋放鎖
     */
    void unlock();
}

public class SimpleRedisLock implements ILock  {
    private StringRedisTemplate stringRedisTemplate;
    public SimpleRedisLock(StringRedisTemplate stringRedisTemplate) {
        this.stringRedisTemplate = stringRedisTemplate;
    }
    @Override
    public boolean tryLock(long timeoutSec) {
        Boolean secuss = stringRedisTemplate.opsForValue()
                .setIfAbsent("lock", "thread", timeoutSec, TimeUnit.SECONDS);
        return secuss;
    }
    @Override
    public void unlock() {
        stringRedisTemplate.delete("lock");
    }
}

在實(shí)際秒殺業(yè)務(wù)代碼上加鎖、解鎖

@PostMapping("/kill")
    public String executeSeckillProduct(int productId,int seckillCount){
        //獲取鎖對(duì)象
        SimpleRedisLock redisLock =new SimpleRedisLock(stringRedisTemplate);
        //嘗試獲取鎖對(duì)象
        boolean isLock = redisLock.tryLock(1200);
        if(!isLock){
            return "獲取鎖失敗";
        }
        Product product = productService.findByPid(productId);
        if(product.getStock()<seckillCount){
            return "庫(kù)存不足";
        }
        product.setStock(product.getStock()-seckillCount);
        int row = productService.reduceInventory(product);
        if(row>0){
            //新增秒殺記錄
            SeckillRecord record = new SeckillRecord();
            record.setPid(product.getPid());
            record.setCount(seckillCount);
            record.setPanme(product.getPname());
            record.setTime(new Timestamp(System.currentTimeMillis()));
            recodeService.save(record);
        }
        //釋放鎖
        redisLock.unlock();
        return "秒殺成功";
    }

測(cè)試

在測(cè)試Redis分布式鎖之前，我先用了GetWay網(wǎng)關(guān)同意了API接口，由網(wǎng)關(guān)分發(fā)路由請(qǐng)求，通過(guò)OpenFegin實(shí)現(xiàn)通信并做到負(fù)載均衡效果，并對(duì)秒殺服務(wù)做了節(jié)點(diǎn)擴(kuò)展，盡可能的模擬除了分布式架構(gòu)：網(wǎng)關(guān)配置：

server:
  port: 7000
spring:
  application:
    name: gateway-application
  cloud:
    nacos:
      discovery:
        server-addr: 127.0.0.1:8848
    gateway:
      discovery:
        locator:
          enabled: true
      routes:
        - id: reckill_route
          uri: lb://service-reckill
          order: 1
          predicates:
            - Path=/reckill-serv/**
          filters:
            - StripPrefix=1

先測(cè)試不加分布式鎖的效果：數(shù)據(jù)庫(kù)庫(kù)存：10