java毕业设计 基于SpringBoot+Mybatis的秒杀系统的设计与实现+详细文档+全部资料（优秀项目）.zip

package com.lh.seckill.controller; import com.lh.seckill.access.AccessLimit; import com.lh.seckill.domain.SeckillOrder; import com.lh.seckill.domain.SeckillUser; import com.lh.seckill.rabbitmq.MQSender; import com.lh.seckill.rabbitmq.SeckillMessage; import com.lh.seckill.redis.RedisService; import com.lh.seckill.redis.key.GoodsKey; import com.lh.seckill.redis.key.OrderKey; import com.lh.seckill.result.CodeMsg; import com.lh.seckill.result.Result; import com.lh.seckill.service.GoodsService; import com.lh.seckill.service.OrderService; import com.lh.seckill.service.SeckillKey; import com.lh.seckill.service.SeckillService; import com.lh.seckill.vo.GoodsVo; import org.springframework.beans.factory.InitializingBean; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.autoconfigure.EnableAutoConfiguration; import org.springframework.stereotype.Controller; import org.springframework.ui.Model; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.ResponseBody; import java.awt.image.BufferedImage; import java.io.OutputStream; import java.util.HashMap; import java.util.List; import javax.imageio.ImageIO; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; /** * Created by lh on 2018/4/20. */ @Controller @EnableAutoConfiguration @RequestMapping("/seckill") public class SeckillController implements InitializingBean { @Autowired GoodsService goodsService; @Autowired SeckillService seckillService; @Autowired OrderService orderService; @Autowired RedisService redisService; @Autowired MQSender sender; private HashMap<Long, Boolean> localOverMap = new HashMap<Long, Boolean>(); @AccessLimit(seconds=5, maxCount=5, needLogin=true) @RequestMapping(value="/path", method=RequestMethod.GET) @ResponseBody public Result<String> getMiaoshaPath(HttpServletRequest request, SeckillUser user, @RequestParam("goodsId")long goodsId, @RequestParam(value="verifyCode", defaultValue="0")int verifyCode) { if(user == null) { return Result.error(CodeMsg.SESSION_ERROR); } boolean check = seckillService.checkVerifyCode(user, goodsId, verifyCode); if(!check) { return Result.error(CodeMsg.REQUEST_ILLEGAL); } String path =seckillService.createSeckillPath(user, goodsId); return Result.success(path); } @RequestMapping(value="/{path}/do_seckill", method= RequestMethod.POST) @ResponseBody public Result<Integer> seckill(Model model, SeckillUser user,@RequestParam("goodsId")long goodsId, @PathVariable("path") String path) { model.addAttribute("user", user); if(user == null) { return Result.error(CodeMsg.SESSION_ERROR); } //验证path boolean check = seckillService.checkPath(user, goodsId, path); if(!check){ return Result.error(CodeMsg.REQUEST_ILLEGAL); } //内存标记，减少redis访问 boolean over = localOverMap.get(goodsId); if(over) { return Result.error(CodeMsg.SECKILL_OVER); } //预减库存 long stock = redisService.decr(GoodsKey.getSeckillGoodsStock, ""+goodsId);//10 if(stock < 0) { localOverMap.put(goodsId, true); return Result.error(CodeMsg.SECKILL_OVER); } //判断是否已经秒杀到了 SeckillOrder order = orderService.getSeckillOrderByUserIdGoodsId(user.getId(), goodsId); if(order != null) { return Result.error(CodeMsg.REPEATE_SECKILL); } //入队 SeckillMessage mm = new SeckillMessage(); mm.setUser(user); mm.setGoodsId(goodsId); sender.sendSeckillMessage(mm); return Result.success(0);//排队中 /* //判断库存 GoodsVo goods = goodsService.getGoodsVoByGoodsId(goodsId); int stock = goods.getStockCount(); if(stock <= 0) { return Result.error(CodeMsg.SECKILL_OVER); } //判断是否已经秒杀到了 SeckillOrder order = orderService.getSeckillOrderByUserIdGoodsId(user.getId(), goodsId); if(order != null) { model.addAttribute("errmsg", CodeMsg.REPEATE_SECKILL.getMsg()); return Result.error(CodeMsg.REPEATE_SECKILL); } //减库存 下订单 写入秒杀订单 OrderInfo orderInfo = seckillService.seckill(user, goods); return Result.success(orderInfo); */ } /** * orderId：成功 * -1：秒杀失败 * 0： 排队中 * */ @RequestMapping(value="/result", method=RequestMethod.GET) @ResponseBody public Result<Long> miaoshaResult(Model model,SeckillUser user, @RequestParam("goodsId")long goodsId) { model.addAttribute("user", user); if(user == null) { return Result.error(CodeMsg.SESSION_ERROR); } long result = seckillService.getSeckillResult(user.getId(), goodsId); return Result.success(result); } @Override public void afterPropertiesSet() throws Exception { List<GoodsVo> goodsList = goodsService.listGoodsVo(); if(goodsList == null) { return; } for(GoodsVo goods : goodsList) { redisService.set(GoodsKey.getSeckillGoodsStock, ""+goods.getId(), goods.getStockCount()); localOverMap.put(goods.getId(), false); } } @RequestMapping(value="/reset", method=RequestMethod.GET) @ResponseBody public Result<Boolean> reset(Model model) { List<GoodsVo> goodsList = goodsService.listGoodsVo(); for(GoodsVo goods : goodsList) { goods.setStockCount(10); redisService.set(GoodsKey.getSeckillGoodsStock, ""+goods.getId(), 10); localOverMap.put(goods.getId(), false); } redisService.delete(OrderKey.getSeckillOrderByUidGid); redisService.delete(SeckillKey.isGoodsOver); seckillService.reset(goodsList); return Result.success(true); } @RequestMapping(value="/verifyCode", method=RequestMethod.GET) @ResponseBody public Result<String> getMiaoshaVerifyCod(HttpServletResponse response, SeckillUser user, @RequestParam("goodsId")long goodsId) { if(user == null) { return Result.error(CodeMsg.SESSION_ERROR); } try { BufferedImage image = seckillService.createVerifyCode(user, goodsId); OutputStream out = response.getOutputStream(); ImageIO.write(image, "JPEG", out); out.flush(); out.close(); return null; }catch(Exception e) { e.printStackTrace(); return Result.error(CodeMsg.SECKILL_FAIL); } } }