亚洲国产欧美在线成人Aⅴ,动漫一区亚洲一区日韩一区

Java秒殺系統(tǒng)(六)：商品秒殺代碼實(shí)戰(zhàn)

作者：修羅debug
版權(quán)聲明：本文為博主原創(chuàng)文章，遵循 CC 4.0 by-sa 版權(quán)協(xié)議，轉(zhuǎn)載請(qǐng)附上原文出處鏈接和本聲明。

摘要：本篇博文是“Java秒殺系統(tǒng)實(shí)戰(zhàn)系列文章”的第六篇，本篇博文我們將進(jìn)入整個(gè)秒殺系統(tǒng)核心功能模塊的代碼開發(fā)，即“商品秒殺”功能模塊的代碼實(shí)戰(zhàn)。

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

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

從該業(yè)務(wù)流程圖中可以看出，后端接口在接收前端用戶的秒殺請(qǐng)求時(shí)，其核心處理邏輯為：
A 首先判斷當(dāng)前用戶是否已經(jīng)搶購過該商品了，如果否，則代表用戶沒有搶購過該商品，可以進(jìn)入下一步的處理邏輯
B 判斷該商品可搶的剩余數(shù)量，即庫存是否充足（即是否大于0），如果是，則進(jìn)入下一步的處理邏輯
C 扣減庫存，并更新數(shù)據(jù)庫的中對(duì)應(yīng)搶購記錄的庫存（一般是減一操作），判斷更新庫存的數(shù)據(jù)庫操作是否成功了，如果是，則創(chuàng)建用戶秒殺成功的訂單，并異步發(fā)送短信或者郵件通知信息通知用戶
D 以上的操作邏輯如果有任何一步是不滿足條件的，則直接結(jié)束整個(gè)秒殺的流程，即秒殺失敗！接下來，我們?nèi)匀换贛VC的開發(fā)模式，采用代碼實(shí)戰(zhàn)實(shí)現(xiàn)這一功能模塊！

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

其源代碼如下所示：

private static final String prefix = "kill";
 
@Autowired
private IKillService killService;
 
@Autowired
private ItemKillSuccessMapper itemKillSuccessMapper;
 
/***
 * 商品秒殺核心業(yè)務(wù)邏輯
 */
@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);
}
//獲取當(dāng)前登錄用戶的信息
    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(),"哈哈~商品已搶購?fù)戤吇蛘卟辉趽屬彆r(shí)間段哦!");
        }
    }catch (Exception e){
        response=new BaseResponse(StatusCode.Fail.getCode(),e.getMessage());
    }
    return response;
}

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

@Data
@ToString
public class KillDto implements Serializable{
    @NotNull
    private Integer killId;
 
    private Integer userId; //在整合shiro之后，userId字段可以不需要了！因?yàn)橥ㄟ^session進(jìn)行獲取了
}

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

@Autowired
private ItemKillSuccessMapper itemKillSuccessMapper;
 
@Autowired
private ItemKillMapper itemKillMapper;
 
@Autowired
private RabbitSenderService rabbitSenderService;
 
//商品秒殺核心業(yè)務(wù)邏輯的處理
@Override
public Boolean killItem(Integer killId, Integer userId) throws Exception {
    Boolean result=false;
 
    //TODO:判斷當(dāng)前用戶是否已經(jīng)搶購過當(dāng)前商品
    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:扣減是否成功?是-生成秒殺成功的訂單，同時(shí)通知用戶秒殺成功的消息
            if (res>0){
                commonRecordKillSuccessInfo(itemKill,userId);
 
                result=true;
            }
        }
    }else{
        throw new Exception("您已經(jīng)搶購過該商品了!");
    }
    return result;
}

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

<!--搶購商品，剩余數(shù)量減一-->
  <update id="updateKillItem">
    UPDATE item_kill
    SET total = total - 1
    WHERE
        id = #{killId}
  </update>

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

/**
 * 通用的方法-用戶秒殺成功后創(chuàng)建訂單-并進(jìn)行異步郵件消息的通知
 * @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());   //傳統(tǒng)時(shí)間戳+N位隨機(jī)數(shù)
    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:學(xué)以致用，舉一反三 -> 仿照單例模式的雙重檢驗(yàn)鎖寫法
    if (itemKillSuccessMapper.countByKillUserId(kill.getId(),userId) <= 0){
        int res=itemKillSuccessMapper.insertSelective(entity);
 
        if (res>0){
            //TODO:進(jìn)行異步郵件消息的通知=rabbitmq+mail
            rabbitSenderService.sendKillSuccessEmailMsg(orderNo);
 
            //TODO:入死信隊(duì)列，用于 “失效” 超過指定的TTL時(shí)間時(shí)仍然未支付的訂單
            rabbitSenderService.sendKillSuccessOrderExpireMsg(orderNo);
        }
    }
}

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

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

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

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

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

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

當(dāng)然，對(duì)于“郵件的通知”和“秒殺成功生成的訂單的訂單編號(hào)”的功能，我們將在后面的篇章進(jìn)行分享介紹，在本節(jié)我們主要是分享介紹了秒殺系統(tǒng)中用戶的“秒殺/搶購請(qǐng)求”功能！

補(bǔ)充：

1、目前，這一秒殺系統(tǒng)的整體構(gòu)建與代碼實(shí)戰(zhàn)已經(jīng)全部完成了，該秒殺系統(tǒng)對(duì)應(yīng)的視頻教程的鏈接地址為：https://www.fightjava.com/web/index/course/detail/6，可以點(diǎn)擊鏈接進(jìn)行試看以及學(xué)習(xí)，實(shí)戰(zhàn)期間有任何問題都可以留言或者與Debug聯(lián)系、交流！

2、另外，Debug也開源了該秒殺系統(tǒng)對(duì)應(yīng)的完整的源代碼以及數(shù)據(jù)庫，其地址可以來這里下載：https://gitee.com/steadyjack/SpringBoot-SecondKill 記得Fork跟Star啊?。?！

3、最后，不要忘記了關(guān)注一下Debug的技術(shù)微信公眾號(hào)：

原文鏈接：https://fightjava.com/web/index/blog/article/18

在线午夜精品自拍小视频_无码av无码专区线_亚洲无码精品人妻_人人澡欧美一区

后端高級(jí)