內容：

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

[[271508]]

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

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

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

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

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

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

接下來，我們仍然基于MVC的開發模式，采用代碼實戰實現這一功能模塊！

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

其源代碼如下所示：

private static final String prefix = "kill"; 
  
@Autowired 
private IKillService killService; 
  
@Autowired 
private ItemKillSuccessMapper itemKillSuccessMapper; 
  
/*** 
 * 商品秒殺核心業務邏輯 
 */ 
@RequestMapping(value = prefix+"/execute",method = RequestMethod.POST,consumes = MediaType.APPLICATION_JSON_UTF8_VALUE) 
@ResponseBody 
public BaseResponse execute(@RequestBody @Validated KillDto dto, BindingResult result, HttpSession session){ 
 if (result.hasErrors() || dto.getKillId()<=0){ 
 return new BaseResponse(StatusCode.InvalidParams); 
} 
//獲取當前登錄用戶的信息 
 Object uId=session.getAttribute("uid"); 
 if (uId==null){ 
 return new BaseResponse(StatusCode.UserNotLogin); 
 } 
 Integer userId= (Integer)uId ; 
 BaseResponse response=new BaseResponse(StatusCode.Success); 
 try { 
 Boolean res=killService.killItem(dto.getKillId(),userId); 
 if (!res){ 
 return new BaseResponse(StatusCode.Fail.getCode(),"哈哈~商品已搶購完畢或者不在搶購時間段哦!"); 
 } 
 }catch (Exception e){ 
 response=new BaseResponse(StatusCode.Fail.getCode(),e.getMessage()); 
 } 
 return response; 
}復制代碼 

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

@Data 
@ToString 
public class KillDto implements Serializable{ 
 @NotNull 
 private Integer killId; 
  
 private Integer userId; //在整合shiro之后，userId字段可以不需要了！因為通過session進行獲取了 
}復制代碼 

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

@Autowired 
private ItemKillSuccessMapper itemKillSuccessMapper; 
  
@Autowired 
private ItemKillMapper itemKillMapper; 
  
@Autowired 
private RabbitSenderService rabbitSenderService; 
  
//商品秒殺核心業務邏輯的處理 
@Override 
public Boolean killItem(Integer killId, Integer userId) throws Exception { 
 Boolean result=false; 
  
 //TODO:判斷當前用戶是否已經搶購過當前商品 
 if (itemKillSuccessMapper.countByKillUserId(killId,userId) <= 0){ 
 //TODO:查詢待秒殺商品詳情 
 ItemKill itemKill=itemKillMapper.selectById(killId); 
  
 //TODO:判斷是否可以被秒殺canKill=1? 
 if (itemKill!=null && 1==itemKill.getCanKill() ){ 
 //TODO:扣減庫存-減一 
 int res=itemKillMapper.updateKillItem(killId); 
  
 //TODO:扣減是否成功?是-生成秒殺成功的訂單，同時通知用戶秒殺成功的消息 
 if (res>0){ 
 commonRecordKillSuccessInfo(itemKill,userId); 
  
 result=true; 
 } 
 } 
 }else{ 
 throw new Exception("您已經搶購過該商品了!"); 
 } 
 return result; 
}復制代碼 

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

<!--搶購商品，剩余數量減一--> 
 <update id="updateKillItem"> 
 UPDATE item_kill 
 SET total = total - 1 
 WHERE 
 id = #{killId} 
 </update>復制代碼 

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

/** 
 * 通用的方法-用戶秒殺成功后創建訂單-并進行異步郵件消息的通知 
 * @param kill 
 * @param userId 
 * @throws Exception 
 */ 
private void commonRecordKillSuccessInfo(ItemKill kill, Integer userId) throws Exception{ 
 //TODO:記錄搶購成功后生成的秒殺訂單記錄 
  
 ItemKillSuccess entity=new ItemKillSuccess(); 
 String orderNo=String.valueOf(snowFlake.nextId()); 
  
 //entity.setCode(RandomUtil.generateOrderCode()); //傳統時間戳+N位隨機數 
 entity.setCode(orderNo); //雪花算法 
 entity.setItemId(kill.getItemId()); 
 entity.setKillId(kill.getId()); 
 entity.setUserId(userId.toString()); 
 entity.setStatus(SysConstant.OrderStatus.SuccessNotPayed.getCode().byteValue()); 
 entity.setCreateTime(DateTime.now().toDate()); 
 //TODO:學以致用，舉一反三 -> 仿照單例模式的雙重檢驗鎖寫法 
 if (itemKillSuccessMapper.countByKillUserId(kill.getId(),userId) <= 0){ 
 int res=itemKillSuccessMapper.insertSelective(entity); 
  
 if (res>0){ 
 //TODO:進行異步郵件消息的通知=rabbitmq+mail 
 rabbitSenderService.sendKillSuccessEmailMsg(orderNo); 
  
 //TODO:入死信隊列，用于 “失效” 超過指定的TTL時間時仍然未支付的訂單 
 rabbitSenderService.sendKillSuccessOrderExpireMsg(orderNo); 
 } 
 } 
}復制代碼 

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

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

其中，提交的數據是采用application/json的格式提交的，即json的格式！并采用POST的請求方法進行交互！

（5）將整個系統、項目采用外置的tomcat運行起來，觀察控制臺的輸出信息，如果沒有報錯信息，則代表整體的實戰代碼沒有語法級別的錯誤！點擊“詳情”按鈕，登錄成功后，進入“待秒殺商品的的詳情”，可以查看當前待秒殺商品的詳情信息；點擊“搶購”按鈕，即可進入“秒殺”環節，后端經過一系列的邏輯處理之后，將處理的結果返回給到前端，如下圖所示：

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

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

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