日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

RELATEED CONSULTING
相關(guān)咨詢
選擇下列產(chǎn)品馬上在線溝通
服務(wù)時(shí)間：8:30-17:00
你可能遇到了下面的問題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
Java秒殺系統(tǒng)：商品秒殺代碼實(shí)戰(zhàn)

內(nèi)容：

創(chuàng)新互聯(lián)長期為千余家客戶提供的網(wǎng)站建設(shè)服務(wù)，團(tuán)隊(duì)從業(yè)經(jīng)驗(yàn)10年，關(guān)注不同地域、不同群體，并針對不同對象提供差異化的產(chǎn)品和服務(wù)；打造開放共贏平臺(tái)，與合作伙伴共同營造健康的互聯(lián)網(wǎng)生態(tài)環(huán)境。為丹徒企業(yè)提供專業(yè)的成都網(wǎng)站設(shè)計(jì)、成都網(wǎng)站建設(shè)，丹徒網(wǎng)站改版等技術(shù)服務(wù)。擁有十載豐富建站經(jīng)驗(yàn)和眾多成功案例,為您定制開發(fā)。

“商品秒殺”功能模塊是建立在“商品詳情”功能模塊的基礎(chǔ)之上，對于這一功能模塊而言，其主要的核心流程在于：前端發(fā)起搶購請求，該請求將攜帶著一些請求數(shù)據(jù)：待秒殺Id跟當(dāng)前用戶Id等數(shù)據(jù)；后端接口在接收到請求之后，將執(zhí)行一系列的判斷與秒殺處理邏輯，最終將處理結(jié)果返回給到前端。

其中，后端接口的這一系列判斷與秒殺處理邏輯還是挺復(fù)雜的，Debug將其繪制成了如下的流程圖：

從該業(yè)務(wù)流程圖中可以看出，后端接口在接收前端用戶的秒殺請求時(shí)，其核心處理邏輯為：

（1）首先判斷當(dāng)前用戶是否已經(jīng)搶購過該商品了，如果否，則代表用戶沒有搶購過該商品，可以進(jìn)入下一步的處理邏輯

（2）判斷該商品可搶的剩余數(shù)量，即庫存是否充足（即是否大于0），如果是，則進(jìn)入下一步的處理邏輯

（3）扣減庫存，并更新數(shù)據(jù)庫的中對應(yīng)搶購記錄的庫存（一般是減一操作），判斷更新庫存的數(shù)據(jù)庫操作是否成功了，如果是，則創(chuàng)建用戶秒殺成功的訂單，并異步發(fā)送短信或者郵件通知信息通知用戶

（4）以上的操作邏輯如果有任何一步是不滿足條件的，則直接結(jié)束整個(gè)秒殺的流程，即秒殺失敗！

接下來，我們?nèi)匀换贛VC的開發(fā)模式，采用代碼實(shí)戰(zhàn)實(shí)現(xiàn)這一功能模塊！

（1）首先是在KillController 控制器開發(fā)接收“前端用戶秒殺請求”的功能方法，其中，該方法需要接收前端請求過來的“待秒殺Id”，而當(dāng)前用戶的Id可以通過上一篇博文介紹的Shiro 的會(huì)話模塊Session進(jìn)行獲取！

其源代碼如下所示：

 
 
 
 
    
  
  
  
  
  1. private static final String prefix = "kill"; 
    2. 
  
  
  
  
  2.   
    3. 
  
  
  
  
  3. @Autowired 
    4. 
  
  
  
  
  4. private IKillService killService; 
    5. 
  
  
  
  
  5.   
    6. 
  
  
  
  
  6. @Autowired 
    7. 
  
  
  
  
  7. private ItemKillSuccessMapper itemKillSuccessMapper; 
    8. 
  
  
  
  
  8.   
    9. 
  
  
  
  
  9. /*** 
    10. 
  
  
  
  
  10.  * 商品秒殺核心業(yè)務(wù)邏輯 
    11. 
  
  
  
  
  11.  */ 
    12. 
  
  
  
  
  12. @RequestMapping(value = prefix+"/execute",method = RequestMethod.POST,consumes = MediaType.APPLICATION_JSON_UTF8_VALUE) 
    13. 
  
  
  
  
  13. @ResponseBody 
    14. 
  
  
  
  
  14. public BaseResponse execute(@RequestBody @Validated KillDto dto, BindingResult result, HttpSession session){ 
    15. 
  
  
  
  
  15.  if (result.hasErrors() || dto.getKillId()<=0){ 
    16. 
  
  
  
  
  16.  return new BaseResponse(StatusCode.InvalidParams); 
    17. 
  
  
  
  
  17. } 
    18. 
  
  
  
  
  18. //獲取當(dāng)前登錄用戶的信息 
    19. 
  
  
  
  
  19.  Object uId=session.getAttribute("uid"); 
    20. 
  
  
  
  
  20.  if (uId==null){ 
    21. 
  
  
  
  
  21.  return new BaseResponse(StatusCode.UserNotLogin); 
    22. 
  
  
  
  
  22.  } 
    23. 
  
  
  
  
  23.  Integer userId= (Integer)uId ; 
    24. 
  
  
  
  
  24.  BaseResponse response=new BaseResponse(StatusCode.Success); 
    25. 
  
  
  
  
  25.  try { 
    26. 
  
  
  
  
  26.  Boolean res=killService.killItem(dto.getKillId(),userId); 
    27. 
  
  
  
  
  27.  if (!res){ 
    28. 
  
  
  
  
  28.  return new BaseResponse(StatusCode.Fail.getCode(),"哈哈~商品已搶購?fù)戤吇蛘卟辉趽屬彆r(shí)間段哦!"); 
    29. 
  
  
  
  
  29.  } 
    30. 
  
  
  
  
  30.  }catch (Exception e){ 
    31. 
  
  
  
  
  31.  response=new BaseResponse(StatusCode.Fail.getCode(),e.getMessage()); 
    32. 
  
  
  
  
  32.  } 
    33. 
  
  
  
  
  33.  return response; 
    34. 
  
  
  
  
  34. }復(fù)制代碼 
    35.

其中，KillDto對象主要封裝了“待秒殺Id”等字段信息，其主要用于接收前端過來的用戶秒殺請求信息，源代碼如下所示：

 
 
 
 
    
  
  
  
  
  1. @Data 
    2. 
  
  
  
  
  2. @ToString 
    3. 
  
  
  
  
  3. public class KillDto implements Serializable{ 
    4. 
  
  
  
  
  4.  @NotNull 
    5. 
  
  
  
  
  5.  private Integer killId; 
    6. 
  
  
  
  
  6.   
    7. 
  
  
  
  
  7.  private Integer userId; //在整合shiro之后，userId字段可以不需要了！因?yàn)橥ㄟ^session進(jìn)行獲取了 
    8. 
  
  
  
  
  8. }復(fù)制代碼 
    9.

（2）緊接著是開發(fā) killService.killItem(dto.getKillId(),userId) 的功能，該功能對應(yīng)的代碼的編寫邏輯可以參見本文剛開始介紹時(shí)的流程圖！其完整源代碼如下所示：

 
 
 
 
    
  
  
  
  
  1. @Autowired 
    2. 
  
  
  
  
  2. private ItemKillSuccessMapper itemKillSuccessMapper; 
    3. 
  
  
  
  
  3.   
    4. 
  
  
  
  
  4. @Autowired 
    5. 
  
  
  
  
  5. private ItemKillMapper itemKillMapper; 
    6. 
  
  
  
  
  6.   
    7. 
  
  
  
  
  7. @Autowired 
    8. 
  
  
  
  
  8. private RabbitSenderService rabbitSenderService; 
    9. 
  
  
  
  
  9.   
    10. 
  
  
  
  
  10. //商品秒殺核心業(yè)務(wù)邏輯的處理 
    11. 
  
  
  
  
  11. @Override 
    12. 
  
  
  
  
  12. public Boolean killItem(Integer killId, Integer userId) throws Exception { 
    13. 
  
  
  
  
  13.  Boolean result=false; 
    14. 
  
  
  
  
  14.   
    15. 
  
  
  
  
  15.  //TODO:判斷當(dāng)前用戶是否已經(jīng)搶購過當(dāng)前商品 
    16. 
  
  
  
  
  16.  if (itemKillSuccessMapper.countByKillUserId(killId,userId) <= 0){ 
    17. 
  
  
  
  
  17.  //TODO:查詢待秒殺商品詳情 
    18. 
  
  
  
  
  18.  ItemKill itemKill=itemKillMapper.selectById(killId); 
    19. 
  
  
  
  
  19.   
    20. 
  
  
  
  
  20.  //TODO:判斷是否可以被秒殺canKill=1? 
    21. 
  
  
  
  
  21.  if (itemKill!=null && 1==itemKill.getCanKill() ){ 
    22. 
  
  
  
  
  22.  //TODO:扣減庫存-減一 
    23. 
  
  
  
  
  23.  int res=itemKillMapper.updateKillItem(killId); 
    24. 
  
  
  
  
  24.   
    25. 
  
  
  
  
  25.  //TODO:扣減是否成功?是-生成秒殺成功的訂單，同時(shí)通知用戶秒殺成功的消息 
    26. 
  
  
  
  
  26.  if (res>0){ 
    27. 
  
  
  
  
  27.  commonRecordKillSuccessInfo(itemKill,userId); 
    28. 
  
  
  
  
  28.   
    29. 
  
  
  
  
  29.  result=true; 
    30. 
  
  
  
  
  30.  } 
    31. 
  
  
  
  
  31.  } 
    32. 
  
  
  
  
  32.  }else{ 
    33. 
  
  
  
  
  33.  throw new Exception("您已經(jīng)搶購過該商品了!"); 
    34. 
  
  
  
  
  34.  } 
    35. 
  
  
  
  
  35.  return result; 
    36. 
  
  
  
  
  36. }復(fù)制代碼 
    37.

其中，itemKillMapper.selectById(killId); 表示用于獲取待秒殺商品的詳情信息，這在前面的篇章中已經(jīng)介紹過了；而 itemKillMapper.updateKillItem(killId); 主要用于扣減庫存（在這里是減1操作），其對應(yīng)的動(dòng)態(tài)Sql如下所示：

 
 
 
 
    
  
  
  
  
  1.  
    2. 
  
  
  
  
  2.   
    3. 
  
  
  
  
  3.  UPDATE item_kill 
    4. 
  
  
  
  
  4.  SET total = total - 1 
    5. 
  
  
  
  
  5.  WHERE 
    6. 
  
  
  
  
  6.  id = #{killId} 
    7. 
  
  
  
  
  7.  復(fù)制代碼 
    8.

（3）值得一提的是，在上面 KillService執(zhí)行killItem功能方法時(shí)，還開發(fā)了一個(gè)通用的方法：用戶秒殺成功后創(chuàng)建秒殺訂單、并異步發(fā)送通知消息給到用戶秒殺成功的信息！該方法為 commonRecordKillSuccessInfo(itemKill,userId); 其完整的源代碼如下所示：

 
 
 
 
    
  
  
  
  
  1. /** 
    2. 
  
  
  
  
  2.  * 通用的方法-用戶秒殺成功后創(chuàng)建訂單-并進(jìn)行異步郵件消息的通知 
    3. 
  
  
  
  
  3.  * @param kill 
    4. 
  
  
  
  
  4.  * @param userId 
    5. 
  
  
  
  
  5.  * @throws Exception 
    6. 
  
  
  
  
  6.  */ 
    7. 
  
  
  
  
  7. private void commonRecordKillSuccessInfo(ItemKill kill, Integer userId) throws Exception{ 
    8. 
  
  
  
  
  8.  //TODO:記錄搶購成功后生成的秒殺訂單記錄 
    9. 
  
  
  
  
  9.   
    10. 
  
  
  
  
  10.  ItemKillSuccess entity=new ItemKillSuccess(); 
    11. 
  
  
  
  
  11.  String orderNo=String.valueOf(snowFlake.nextId()); 
    12. 
  
  
  
  
  12.   
    13. 
  
  
  
  
  13.  //entity.setCode(RandomUtil.generateOrderCode()); //傳統(tǒng)時(shí)間戳+N位隨機(jī)數(shù) 
    14. 
  
  
  
  
  14.  entity.setCode(orderNo); //雪花算法 
    15. 
  
  
  
  
  15.  entity.setItemId(kill.getItemId()); 
    16. 
  
  
  
  
  16.  entity.setKillId(kill.getId()); 
    17. 
  
  
  
  
  17.  entity.setUserId(userId.toString()); 
    18. 
  
  
  
  
  18.  entity.setStatus(SysConstant.OrderStatus.SuccessNotPayed.getCode().byteValue()); 
    19. 
  
  
  
  
  19.  entity.setCreateTime(DateTime.now().toDate()); 
    20. 
  
  
  
  
  20.  //TODO:學(xué)以致用，舉一反三 -> 仿照單例模式的雙重檢驗(yàn)鎖寫法 
    21. 
  
  
  
  
  21.  if (itemKillSuccessMapper.countByKillUserId(kill.getId(),userId) <= 0){ 
    22. 
  
  
  
  
  22.  int res=itemKillSuccessMapper.insertSelective(entity); 
    23. 
  
  
  
  
  23.   
    24. 
  
  
  
  
  24.  if (res>0){ 
    25. 
  
  
  
  
  25.  //TODO:進(jìn)行異步郵件消息的通知=rabbitmq+mail 
    26. 
  
  
  
  
  26.  rabbitSenderService.sendKillSuccessEmailMsg(orderNo); 
    27. 
  
  
  
  
  27.   
    28. 
  
  
  
  
  28.  //TODO:入死信隊(duì)列，用于 “失效” 超過指定的TTL時(shí)間時(shí)仍然未支付的訂單 
    29. 
  
  
  
  
  29.  rabbitSenderService.sendKillSuccessOrderExpireMsg(orderNo); 
    30. 
  
  
  
  
  30.  } 
    31. 
  
  
  
  
  31.  } 
    32. 
  
  
  
  
  32. }復(fù)制代碼 
    33.

該方法涉及的功能模塊稍微比較多，即主要包含了“分布式唯一ID-雪花算法的應(yīng)用”、“整合RabbitMQ異步發(fā)送通知消息給用戶”、“基于JavaMail開發(fā)發(fā)送郵件的功能”、“死信隊(duì)列失效超時(shí)未支付的訂單”等等，這些功能模塊將在后面的小節(jié)一步一步展開進(jìn)行介紹！

（4）最后是需要在前端頁面info.jsp開發(fā)“提交用戶秒殺請求”的功能，其部分核心源代碼如下所示：

其中，提交的數(shù)據(jù)是采用application/json的格式提交的，即json的格式！并采用POST的請求方法進(jìn)行交互！

（5）將整個(gè)系統(tǒng)、項(xiàng)目采用外置的tomcat運(yùn)行起來，觀察控制臺(tái)的輸出信息，如果沒有報(bào)錯(cuò)信息，則代表整體的實(shí)戰(zhàn)代碼沒有語法級別的錯(cuò)誤！點(diǎn)擊“詳情”按鈕，登錄成功后，進(jìn)入“待秒殺商品的的詳情”，可以查看當(dāng)前待秒殺商品的詳情信息；點(diǎn)擊“搶購”按鈕，即可進(jìn)入“秒殺”環(huán)節(jié)，后端經(jīng)過一系列的邏輯處理之后，將處理的結(jié)果返回給到前端，如下圖所示：

[[271509]]

與此同時(shí)，當(dāng)前用戶的郵箱中將收到一條“秒殺成功”的郵件信息，表示當(dāng)前用戶已經(jīng)成功秒殺搶到當(dāng)前商品了，如下圖所示：

除此之外，在數(shù)據(jù)庫表item_kill_success中也將會(huì)生成一筆“秒殺成功的訂單記錄”，如下圖所示：

當(dāng)然，對于“郵件的通知”和“秒殺成功生成的訂單的訂單編號”的功能，在本節(jié)我們主要是分享介紹了秒殺系統(tǒng)中用戶的“秒殺/搶購請求”功能！


當(dāng)前文章：Java秒殺系統(tǒng)：商品秒殺代碼實(shí)戰(zhàn)
網(wǎng)站網(wǎng)址：http://m.5511xx.com/article/dpeiece.html