其中,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运行起来,观察控制台的输出信息,如果没有报错信息,则代表整体的实战代码没有语法级别的错误!点击“详情”按钮,登录成功后,进入“待秒杀商品的的详情”,可以查看当前待秒杀商品的详情信息;点击“抢购”按钮,即可进入“秒杀”环节,后端经过一系列的逻辑处理之后,将处理的结果返回给到前端,如下图所示:
(编辑:晋中站长网)
【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!
|