您好,登錄后才能下訂單哦!
本篇文章為大家展示了怎么在Java中使用redis或mysql實現(xiàn)一個秒殺功能,內(nèi)容簡明扼要并且容易理解,絕對能使你眼前一亮,通過這篇文章的詳細(xì)介紹希望你能有所收獲。
所謂秒殺,就是網(wǎng)絡(luò)賣家發(fā)布一些超低價格的商品,所有買家在同一時間網(wǎng)上搶購的一種銷售方式。秒殺商品通常有兩種限制:時間限制,庫存限制,其中庫存超賣問題是本教程的重點!
秒殺業(yè)務(wù)的運行流程主要可以分為以下幾點:
商家提交秒殺商品申請,錄入秒殺商品數(shù)據(jù),主要有:商品標(biāo)題,商品原價,秒殺價格,商品圖片,介紹等信息
運營商審核秒殺申請
秒殺頻道首頁列出秒殺商品,點擊秒殺商品圖片可以跳轉(zhuǎn)到秒殺商品詳細(xì)頁面
商品詳細(xì)頁面顯示秒殺商品信息,點擊立即搶購實現(xiàn)秒殺下單,下單時扣減庫存,當(dāng)庫存為0或者不存在活動時間范圍內(nèi)時無法秒殺
秒殺下單成功,直接跳轉(zhuǎn)到支付頁面(掃碼),支付成功,跳轉(zhuǎn)到成功頁面,填寫收貨、電話、收件人等信息,完成訂單。
當(dāng)用戶秒殺下單5分鐘內(nèi)未支付,取消預(yù)訂單,調(diào)用支付的關(guān)閉訂單接口,恢復(fù)庫存。
商品表:
訂單表:
秒殺技術(shù)實現(xiàn)核心思想是運用緩存減少數(shù)據(jù)庫瞬間的訪問壓力。讀取商品詳細(xì)信息時要運用緩存,當(dāng)用戶點擊搶購時也要運用緩存,減少緩存中的庫存數(shù)量,當(dāng)庫存數(shù)為0時或活動時間結(jié)束才同步到數(shù)據(jù)庫中。產(chǎn)生的秒殺預(yù)訂單也不會立刻寫到數(shù)據(jù)庫中,而是先寫到緩存,當(dāng)用戶付款成功后再寫入數(shù)據(jù)庫,或者異步寫入MQ,讓數(shù)據(jù)庫根據(jù)自身的能力去消費。
緩存商品信息,庫存信息
@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ā)生異?!?quot;); // 緩存庫存 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ù)庫操作建議走MQ讓數(shù)據(jù)庫按照他的處理能力,從消息隊列中拿取消息進行處理。 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ā)生異?!?quot;); 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實現(xiàn)一個秒殺功能,你們學(xué)到知識或技能了嗎?如果還想學(xué)到更多技能或者豐富自己的知識儲備,歡迎關(guān)注億速云行業(yè)資訊頻道。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進行舉報,并提供相關(guān)證據(jù),一經(jīng)查實,將立刻刪除涉嫌侵權(quán)內(nèi)容。