Java秒杀系统：商品秒杀代码实战

其中，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); 
 } 
 } 
}复制代码 

（编辑：西安站长网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!