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