Java秒殺系統實戰系列~商品秒殺代碼實戰

摘要：

本篇博文是「Java秒殺系統實戰系列文章」的第六篇，本篇博文咱們將進入整個秒殺系統核心功能模塊的代碼開發，即「商品秒殺」功能模塊的代碼實戰。

內容：

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

其中，後端接口的這一系列判斷與秒殺處理邏輯仍是挺複雜的，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中也將會生成一筆「秒殺成功的訂單記錄」，以下圖所示：

固然，對於「郵件的通知」和「秒殺成功生成的訂單的訂單編號」的功能，咱們將在後面的篇章進行分享介紹，在本節咱們主要是分享介紹了秒殺系統中用戶的「秒殺/搶購請求」功能！

補充：

一、目前，這一秒殺系統的總體構建與代碼實戰已經所有完成了，完整的源代碼數據庫地址能夠來這裏下載：gitee.com/steadyjack/… 記得Fork跟Star啊！！！