一.秒殺業務分析
所謂秒殺，就是網絡賣家發布一些超低價格的商品，所有買家在同一時間網上搶購的一種銷售方式。秒殺商品通常有兩種限制：時間限制，庫存限制，其中庫存超賣問題是本教程的重點！
秒殺業務的運行流程主要可以分為以下幾點：
- 商家提交秒殺商品申請，錄入秒殺商品數據，主要有：商品標題，商品原價，秒殺價格，商品圖片，介紹等信息
- 運營商審核秒殺申請
- 秒殺頻道首頁列出秒殺商品，點擊秒殺商品圖片可以跳轉到秒殺商品詳細頁面
- 商品詳細頁面顯示秒殺商品信息，點擊立即搶購實現秒殺下單，下單時扣減庫存，當庫存為０或者不存在活動時間范圍內時無法秒殺
- 秒殺下單成功，直接跳轉到支付頁面(掃碼),支付成功，跳轉到成功頁面，填寫收貨、電話、收件人等信息，完成訂單。
- 當用戶秒殺下單５分鐘內未支付，取消預訂單，調用支付的關閉訂單接口，恢復庫存。
二.數據庫設計
商品表：
訂單表：
三.秒殺實現思路
秒殺技術實現核心思想是運用緩存減少數據庫瞬間的訪問壓力。讀取商品詳細信息時要運用緩存，當用戶點擊搶購時也要運用緩存，減少緩存中的庫存數量，當庫存數為０時或活動時間結束才同步到數據庫中。產生的秒殺預訂單也不會立刻寫到數據庫中，而是先寫到緩存，當用戶付款成功后再寫入數據庫，或者異步寫入MQ,讓數據庫根據自身的能力去消費。
四.實現關鍵步驟說明
緩存商品信息，庫存信息
- @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), "搶購商品初始化發生異常～");
- // 緩存庫存
- 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) {
- // 下面的數據庫操作建議走MQ讓數據庫按照他的處理能力，從消息隊列中拿取消息進行處理。
- 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), "訂單創建發生異常～");
- 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;
- }
最終效果：
觀察redis存儲的數據和數據庫的訂單記錄可發現，秒殺場景基本實現！
四.總結
本文主要解決超賣，和長時間未支付庫存重置的問題; 實際場景，還要考慮前后端的多種優化(靜態頁、cdn、防止重復下單、限流等等……)
五.完整代碼示例
到此這篇關于Java基于redis和mysql實現簡單的秒殺(附demo)的文章就介紹到這了,更多相關Java基于redis和mysql秒殺內容請搜索服務器之家以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持服務器之家！
原文鏈接：https://blog.csdn.net/kuangni5808/article/details/109578241
