本篇文章為大家展示了怎么在Java中使用redis或mysql實(shí)現(xiàn)一個(gè)秒殺功能，內(nèi)容簡(jiǎn)明扼要并且容易理解，絕對(duì)能使你眼前一亮，通過(guò)這篇文章的詳細(xì)介紹希望你能有所收獲。

創(chuàng)新互聯(lián)專注于成都做網(wǎng)站、網(wǎng)站建設(shè)、網(wǎng)頁(yè)設(shè)計(jì)、網(wǎng)站制作、網(wǎng)站開(kāi)發(fā)。公司秉持“客戶至上,用心服務(wù)”的宗旨,從客戶的利益和觀點(diǎn)出發(fā),讓客戶在網(wǎng)絡(luò)營(yíng)銷中找到自己的駐足之地。尊重和關(guān)懷每一位客戶，用嚴(yán)謹(jǐn)?shù)膽B(tài)度對(duì)待客戶，用專業(yè)的服務(wù)創(chuàng)造價(jià)值，成為客戶值得信賴的朋友，為客戶解除后顧之憂。

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

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

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

• 商家提交秒殺商品申請(qǐng)，錄入秒殺商品數(shù)據(jù)，主要有：商品標(biāo)題，商品原價(jià)，秒殺價(jià)格，商品圖片，介紹等信息

• 運(yùn)營(yíng)商審核秒殺申請(qǐng)

• 秒殺頻道首頁(yè)列出秒殺商品，點(diǎn)擊秒殺商品圖片可以跳轉(zhuǎn)到秒殺商品詳細(xì)頁(yè)面

• 商品詳細(xì)頁(yè)面顯示秒殺商品信息，點(diǎn)擊立即搶購(gòu)實(shí)現(xiàn)秒殺下單，下單時(shí)扣減庫(kù)存，當(dāng)庫(kù)存為０或者不存在活動(dòng)時(shí)間范圍內(nèi)時(shí)無(wú)法秒殺

• 秒殺下單成功，直接跳轉(zhuǎn)到支付頁(yè)面(掃碼),支付成功，跳轉(zhuǎn)到成功頁(yè)面，填寫(xiě)收貨、電話、收件人等信息，完成訂單。

• 當(dāng)用戶秒殺下單５分鐘內(nèi)未支付，取消預(yù)訂單，調(diào)用支付的關(guān)閉訂單接口，恢復(fù)庫(kù)存。

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

商品表：

訂單表：

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

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

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

緩存商品信息，庫(kù)存信息

  @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), "搶購(gòu)商品初始化發(fā)生異?！?);
    // 緩存庫(kù)存
    redisTemplate.opsForValue().increment("amount:" + goodsEntity.getId(), amount);
    // 緩存商品信息
    redisTemplate.opsForValue().set("goods:" + goodsEntity.getId(), goodsEntity);
    return goodsEntity;
  }

基于redis incr 原子性防止超賣(mài)

  @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ù)庫(kù)操作建議走M(jìn)Q讓數(shù)據(jù)庫(kù)按照他的處理能力，從消息隊(duì)列中拿取消息進(jìn)行處理。
      Try.of(() -> {
        Assert.isTrue(goodsService.secKill(Long.valueOf(key)), "庫(kù)存不足！");
        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;
  }

 最終效果：

上述內(nèi)容就是怎么在Java中使用redis或mysql實(shí)現(xiàn)一個(gè)秒殺功能，你們學(xué)到知識(shí)或技能了嗎？如果還想學(xué)到更多技能或者豐富自己的知識(shí)儲(chǔ)備，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。

名稱欄目：怎么在Java中使用redis或mysql實(shí)現(xiàn)一個(gè)秒殺功能-創(chuàng)新互聯(lián)
鏈接分享：http://weahome.cn/article/iheoh.html