快捷導(dǎo)航

Java基于redis和mysql實現(xiàn)簡單的秒殺(附demo)

更新時間：2021年02月07日 10:34:24 作者：JAVA拾貝

這篇文章主要介紹了Java基于redis和mysql實現(xiàn)簡單的秒殺(附demo)，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

一.秒殺業(yè)務(wù)分析

所謂秒殺，就是網(wǎng)絡(luò)賣家發(fā)布一些超低價格的商品，所有買家在同一時間網(wǎng)上搶購的一種銷售方式。秒殺商品通常有兩種限制：時間限制，庫存限制，其中庫存超賣問題是本教程的重點！

秒殺業(yè)務(wù)的運(yùn)行流程主要可以分為以下幾點：

商家提交秒殺商品申請，錄入秒殺商品數(shù)據(jù)，主要有：商品標(biāo)題，商品原價，秒殺價格，商品圖片，介紹等信息
運(yùn)營商審核秒殺申請
秒殺頻道首頁列出秒殺商品，點擊秒殺商品圖片可以跳轉(zhuǎn)到秒殺商品詳細(xì)頁面
商品詳細(xì)頁面顯示秒殺商品信息，點擊立即搶購實現(xiàn)秒殺下單，下單時扣減庫存，當(dāng)庫存為０或者不存在活動時間范圍內(nèi)時無法秒殺
秒殺下單成功，直接跳轉(zhuǎn)到支付頁面(掃碼),支付成功，跳轉(zhuǎn)到成功頁面，填寫收貨、電話、收件人等信息，完成訂單。
當(dāng)用戶秒殺下單５分鐘內(nèi)未支付，取消預(yù)訂單，調(diào)用支付的關(guān)閉訂單接口，恢復(fù)庫存。

二.數(shù)據(jù)庫設(shè)計

商品表：

訂單表：

三.秒殺實現(xiàn)思路

秒殺技術(shù)實現(xiàn)核心思想是運(yùn)用緩存減少數(shù)據(jù)庫瞬間的訪問壓力。讀取商品詳細(xì)信息時要運(yùn)用緩存，當(dāng)用戶點擊搶購時也要運(yùn)用緩存，減少緩存中的庫存數(shù)量，當(dāng)庫存數(shù)為０時或活動時間結(jié)束才同步到數(shù)據(jù)庫中。產(chǎn)生的秒殺預(yù)訂單也不會立刻寫到數(shù)據(jù)庫中，而是先寫到緩存，當(dāng)用戶付款成功后再寫入數(shù)據(jù)庫，或者異步寫入MQ,讓數(shù)據(jù)庫根據(jù)自身的能力去消費。

四.實現(xiàn)關(guān)鍵步驟說明

緩存商品信息，庫存信息

  @Override
  @Transactional(rollbackFor = Exception.class)
  public GoodsEntity initGoods(String name, Integer amount, BigDecimal price) {
    GoodsEntity goodsEntity = new GoodsEntity().setName(name).setAmount(amount).setPrice(price).setStartDate(new Date()).setEndDate(new Date());
    Assert.isTrue(goodsService.save(goodsEntity), "搶購商品初始化發(fā)生異常～");
    // 緩存庫存
    redisTemplate.opsForValue().increment("amount:" + goodsEntity.getId(), amount);
    // 緩存商品信息
    redisTemplate.opsForValue().set("goods:" + goodsEntity.getId(), goodsEntity);
    return goodsEntity;
  }

基于redis incr 原子性防止超賣

  @Override
  @Transactional(rollbackFor = Exception.class)
  public Boolean secKill(String key) {
    Long result = redisTemplate.opsForValue().decrement("amount:" + key, 1);
    if (result.compareTo(0L) >= 0) {
      // 下面的數(shù)據(jù)庫操作建議走M(jìn)Q讓數(shù)據(jù)庫按照他的處理能力，從消息隊列中拿取消息進(jìn)行處理。
      Try.of(() -> {
        Assert.isTrue(goodsService.secKill(Long.valueOf(key)), "庫存不足！");
        OrderEntity orderEntity = new OrderEntity().setGoodsId(Long.valueOf(key)).setOrderNo(UUID.randomUUID().toString().replace("-", ""));
        Assert.isTrue(orderService.save(orderEntity), "訂單創(chuàng)建發(fā)生異常～");
        redisTemplate.opsForValue().set("secKill:" + orderEntity.getId(), orderEntity.getOrderNo(), 10, TimeUnit.SECONDS);
        return true;
      }).onFailure((e) -> {
        log.error("持久化異常：" + e.getMessage());
        redisTemplate.opsForValue().increment("amount:" + key, 1);
      });
      return false;
    }
    redisTemplate.opsForValue().increment("amount:" + key, 1);
    return false;
  }

最終效果：