基于SpringBoot + MySQL + Redis + RabbitMQ + Guava开发的高并发商品限时秒杀系统

package com.jesper.seckill.controller; import com.alibaba.druid.util.StringUtils; import com.jesper.seckill.bean.User; import com.jesper.seckill.redis.GoodsKey; import com.jesper.seckill.redis.RedisService; import com.jesper.seckill.result.Result; import com.jesper.seckill.service.GoodsService; import com.jesper.seckill.service.UserService; import com.jesper.seckill.vo.GoodsDetailVo; import com.jesper.seckill.vo.GoodsVo; import org.springframework.beans.factory.annotation.Autowired; 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.ResponseBody; import org.thymeleaf.spring4.context.SpringWebContext; import org.springframework.context.ApplicationContext; import org.thymeleaf.spring4.view.ThymeleafViewResolver; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import java.util.List; /** * Created by jiangyunxiong on 2018/5/22. */ @Controller @RequestMapping("/goods") public class GoodsController { @Autowired UserService userService; @Autowired RedisService redisService; @Autowired GoodsService goodsService; @Autowired ApplicationContext applicationContext; @Autowired ThymeleafViewResolver thymeleafViewResolver; /** * 商品列表页面 * QPS:433 * 1000 * 10 */ @RequestMapping(value = "/to_list", produces = "text/html") @ResponseBody public String list(HttpServletRequest request, HttpServletResponse response, Model model, User user) { //取缓存 String html = redisService.get(GoodsKey.getGoodsList, "", String.class); if (!StringUtils.isEmpty(html)) { return html; } List<GoodsVo> goodsList = goodsService.listGoodsVo(); model.addAttribute("user", user); model.addAttribute("goodsList", goodsList); //手动渲染 SpringWebContext ctx = new SpringWebContext(request, response, request.getServletContext(), request.getLocale(), model.asMap(), applicationContext); html = thymeleafViewResolver.getTemplateEngine().process("goods_list", ctx); if (!StringUtils.isEmpty(html)) { redisService.set(GoodsKey.getGoodsList, "", html); } //结果输出 return html; } /** * 商品详情页面 */ @RequestMapping(value = "/to_detail2/{goodsId}", produces = "text/html") @ResponseBody public String detail2(HttpServletRequest request, HttpServletResponse response, Model model, User user, @PathVariable("goodsId") long goodsId) { model.addAttribute("user", user); //取缓存 String html = redisService.get(GoodsKey.getGoodsDetail, "" + goodsId, String.class); if (!StringUtils.isEmpty(html)) { return html; } //根据id查询商品详情 GoodsVo goods = goodsService.getGoodsVoByGoodsId(goodsId); model.addAttribute("goods", goods); long startTime = goods.getStartDate().getTime(); long endTime = goods.getEndDate().getTime(); long now = System.currentTimeMillis(); int seckillStatus = 0; int remainSeconds = 0; if (now < startTime) {//秒杀还没开始，倒计时 seckillStatus = 0; remainSeconds = (int) ((startTime - now) / 1000); } else if (now > endTime) {//秒杀已经结束 seckillStatus = 2; remainSeconds = -1; } else {//秒杀进行中 seckillStatus = 1; remainSeconds = 0; } model.addAttribute("seckillStatus", seckillStatus); model.addAttribute("remainSeconds", remainSeconds); //手动渲染 SpringWebContext ctx = new SpringWebContext(request, response, request.getServletContext(), request.getLocale(), model.asMap(), applicationContext); html = thymeleafViewResolver.getTemplateEngine().process("goods_detail", ctx); if (!StringUtils.isEmpty(html)) { redisService.set(GoodsKey.getGoodsDetail, "" + goodsId, html); } return html; } /** * 商品详情页面 */ @RequestMapping(value = "/detail/{goodsId}") @ResponseBody public Result<GoodsDetailVo> detail(HttpServletRequest request, HttpServletResponse response, Model model, User user, @PathVariable("goodsId") long goodsId) { //根据id查询商品详情 GoodsVo goods = goodsService.getGoodsVoByGoodsId(goodsId); model.addAttribute("goods", goods); long startTime = goods.getStartDate().getTime(); long endTime = goods.getEndDate().getTime(); long now = System.currentTimeMillis(); int seckillStatus = 0; int remainSeconds = 0; if (now < startTime) {//秒杀还没开始，倒计时 seckillStatus = 0; remainSeconds = (int) ((startTime - now) / 1000); } else if (now > endTime) {//秒杀已经结束 seckillStatus = 2; remainSeconds = -1; } else {//秒杀进行中 seckillStatus = 1; remainSeconds = 0; } GoodsDetailVo vo = new GoodsDetailVo(); vo.setGoods(goods); vo.setUser(user); vo.setRemainSeconds(remainSeconds); vo.setSeckillStatus(seckillStatus); return Result.success(vo); } }