摘要：

本篇博文是“Java秒殺系統實戰系列文章”的第六篇，本篇博文我們將進入整個秒殺系統核心功能模組的程式碼開發，即“商品秒殺”功能模組的程式碼實戰。

內容：

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

其中，後端介面的這一系列判斷與秒殺處理邏輯還是挺複雜的，Debug將其繪製成了如下的流程圖：

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

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

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

（3）扣減庫存，並更新資料庫的中對應搶購記錄的庫存（一般是減一操作），判斷更新庫存的資料庫操作是否成功了，如果是，則建立使用者秒殺成功的訂單，並非同步傳送簡訊或者郵件通知資訊通知使用者

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

接下來，我們仍然基於MVC的開發模式，採用程式碼實戰實現這一功能模組！

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中也將會生成一筆“秒殺成功的訂單記錄”，如下圖所示：

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

補充：

1、由於相應的部落格的更新可能並不會很快，故而如果有想要快速入門以及實戰整套系統的，可以閱讀： Java商城秒殺系統的設計與實戰視訊教程（SpringBoot版）

2、目前，這一秒殺系統的整體構建與程式碼實戰已經全部完成了，完整的原始碼資料庫地址可以來這裡下載：https://gitee.com/steadyjack/SpringBoot-SecondKill 

&n