Java基于redis和mysql實現(xiàn)簡單的秒殺(附demo)
所謂秒殺,就是網(wǎng)絡賣家發(fā)布一些超低價格的商品,所有買家在同一時間網(wǎng)上搶購的一種銷售方式。秒殺商品通常有兩種限制:時間限制,庫存限制,其中庫存超賣問題是本教程的重點!
秒殺業(yè)務的運行流程主要可以分為以下幾點:
商家提交秒殺商品申請,錄入秒殺商品數(shù)據(jù),主要有:商品標題,商品原價,秒殺價格,商品圖片,介紹等信息 運營商審核秒殺申請 秒殺頻道首頁列出秒殺商品,點擊秒殺商品圖片可以跳轉到秒殺商品詳細頁面 商品詳細頁面顯示秒殺商品信息,點擊立即搶購實現(xiàn)秒殺下單,下單時扣減庫存,當庫存為0或者不存在活動時間范圍內(nèi)時無法秒殺 秒殺下單成功,直接跳轉到支付頁面(掃碼),支付成功,跳轉到成功頁面,填寫收貨、電話、收件人等信息,完成訂單。 當用戶秒殺下單5分鐘內(nèi)未支付,取消預訂單,調(diào)用支付的關閉訂單接口,恢復庫存。 二.數(shù)據(jù)庫設計商品表:
訂單表:
秒殺技術實現(xiàn)核心思想是運用緩存減少數(shù)據(jù)庫瞬間的訪問壓力。讀取商品詳細信息時要運用緩存,當用戶點擊搶購時也要運用緩存,減少緩存中的庫存數(shù)量,當庫存數(shù)為0時或活動時間結束才同步到數(shù)據(jù)庫中。產(chǎn)生的秒殺預訂單也不會立刻寫到數(shù)據(jù)庫中,而是先寫到緩存,當用戶付款成功后再寫入數(shù)據(jù)庫,或者異步寫入MQ,讓數(shù)據(jù)庫根據(jù)自身的能力去消費。
四.實現(xià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ù)庫操作建議走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ā)生異常~');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存儲的數(shù)據(jù)和數(shù)據(jù)庫的訂單記錄可發(fā)現(xiàn),秒殺場景基本實現(xiàn)!
四.總結本文主要解決超賣,和長時間未支付庫存重置的問題; 實際場景,還要考慮前后端的多種優(yōu)化(靜態(tài)頁、cdn、防止重復下單、限流等等……)
五.完整代碼示例前往下載
到此這篇關于Java基于redis和mysql實現(xiàn)簡單的秒殺(附demo)的文章就介紹到這了,更多相關Java基于redis和mysql秒殺內(nèi)容請搜索好吧啦網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持好吧啦網(wǎng)!
相關文章:
1. python中scrapy處理項目數(shù)據(jù)的實例分析2. Python中讀取文件名中的數(shù)字的實例詳解3. 在idea中為注釋標記作者日期操作4. 通過Ajax方式綁定select選項數(shù)據(jù)的實例5. JSP頁面的靜態(tài)包含和動態(tài)包含使用方法6. ASP.Net Core對USB攝像頭進行截圖7. ASP.NET MVC使用Boostrap實現(xiàn)產(chǎn)品展示、查詢、排序、分頁8. .net如何優(yōu)雅的使用EFCore實例詳解9. 使用AJAX(包含正則表達式)驗證用戶登錄的步驟10. ajax動態(tài)加載json數(shù)據(jù)并詳細解析
