springboot+redis+rebbitmq实现商品秒杀.zip

package cn.com.app.controller; import java.awt.image.BufferedImage; import java.io.OutputStream; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.UUID; import javax.imageio.ImageIO; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import org.springframework.beans.factory.InitializingBean; 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.RequestMethod; import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.ResponseBody; import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisPool; import redis.clients.jedis.Response; import redis.clients.jedis.Transaction; import cn.com.app.bean.MiaoshaUser; import cn.com.app.rabbitmq.MQSender; import cn.com.app.redis.AccessKey; import cn.com.app.redis.GoodsKey; import cn.com.app.redis.OrderKey; import cn.com.app.redis.RedisLock; import cn.com.app.redis.RedisLua; import cn.com.app.redis.RedisService; import cn.com.app.result.CodeMsg; import cn.com.app.result.Result; import cn.com.app.service.MiaoshaService; import cn.com.app.service.MiaoshaUserService; @Controller @RequestMapping("/miaosha") public class MiaoshaController implements InitializingBean { @Autowired private MiaoshaService miaoshaService; @Autowired private RedisService redisService; @Autowired private MiaoshaUserService userService; @Autowired private MQSender mQSender; @Autowired private JedisPool jedisPool; //内存标记，减少redis访问 private HashMap<String, Boolean> localOverMap = new HashMap<String, Boolean>(); /** * 系统初始化的时把商品库存加入到缓存中 * 在容器启动时候，检测到了MiaoshaController类实现了接口InitializingBean之后执行该方法 */ @Override public void afterPropertiesSet() throws Exception { //查询库存数量 List<Map<String, Object>> stockList = miaoshaService.queryAllGoodStock(); System.out.println("系统初始化："+stockList); if(stockList == null){ return; } for(Map<String, Object> m : stockList) { //如果不是null的时候,将库存加载到redis里面去 prefix---GoodsKey:spsl, key---商品id,value---商品数量 redisService.set(GoodsKey.getMiaoshaGoodsStock, ""+m.get("goods_id"), m.get("stock_count")); //添加内存标记 localOverMap.put(m.get("goods_id").toString(), false); } } /** * QPS:327 * 请求秒杀,redis+Lua方式 */ @RequestMapping(value="/{path}/do_miaoshalua") @ResponseBody public Result<Integer> do_miaoshalua(HttpServletRequest request,HttpServletResponse response){ String userid = "1";//用户id String goodsId = "1";//库存id Jedis jedis = jedisPool.getResource(); //脚本里的KEYS参数 List<String> keys = new ArrayList<>(); keys.add(GoodsKey.getMiaoshaGoodsStock.getPrefix()+goodsId);//redis中的商品key keys.add(OrderKey.getMiaoshaOrderByUidGid.getPrefix()+userid+"_"+goodsId);//redis中的订单key //脚本里的ARGV参数 List<String> args = new ArrayList<>(); args.add("1");//扣减库存数量 args.add(userid+"_"+goodsId);//用户下单信息 long result = (long) jedis.eval(RedisLua.STOCK_LUA, keys, args); if(result == -1){ System.out.println("库存不足"); return Result.error(CodeMsg.MIAO_SHA_OVER); }else if(result == -2){ System.out.println("重复下单"); return Result.error(CodeMsg.REPEATE_MIAOSHA); } System.out.println("抢购成功"); //减库存,下订单 Map<String,Object> map = new HashMap<>(); map.put("user_id", userid); map.put("goods_id", goodsId); miaoshaService.miaosha(map); return Result.success(0); } /** * QPS:324 * 请求秒杀,redis watch事务方式 */ @RequestMapping(value="/{path}/do_miaoshawatch") @ResponseBody public Result<Integer> do_miaoshawatch(HttpServletRequest request,HttpServletResponse response){ String userid = "1";//用户id String goodsId = "1";//库存id Jedis jedis = jedisPool.getResource(); //监视key jedis.watch(GoodsKey.getMiaoshaGoodsStock.getPrefix()+goodsId,OrderKey.getMiaoshaOrderByUidGid.getPrefix()+userid+"_"+goodsId); //库存和订单判断 int count = redisService.get(GoodsKey.getMiaoshaGoodsStock, goodsId,Integer.class); if(count <= 0){ System.out.println("库存不足"); return Result.error(CodeMsg.MIAO_SHA_OVER); } String order = redisService.get(OrderKey.getMiaoshaOrderByUidGid, ""+userid+"_"+goodsId,String.class); if(order != null && !order.equals("")){ System.out.println("重复下单"); return Result.error(CodeMsg.REPEATE_MIAOSHA); } Transaction transaction = jedis.multi();// 开启事务 transaction.set(OrderKey.getMiaoshaOrderByUidGid.getPrefix()+userid+"_"+goodsId, userid+"_"+goodsId); Response<Long> v = transaction.decrBy(GoodsKey.getMiaoshaGoodsStock.getPrefix()+goodsId,1); List<Object> result = transaction.exec(); if(result == null || result.isEmpty()){ System.out.println("抢购失败"); }else{ System.out.println("抢购成功,[" + GoodsKey.getMiaoshaGoodsStock.getPrefix()+goodsId + "]剩余：" + v.get().intValue()); //减库存,下订单 Map<String,Object> map = new HashMap<>(); map.put("user_id", userid); map.put("goods_id", goodsId); miaoshaService.miaosha(map); } return Result.success(0); } /** * QPS:319 * 请求秒杀,redis分布式锁 */ @RequestMapping(value="/{path}/do_miaoshalock") @ResponseBody public Result<Integer> do_miaoshalock(HttpServletRequest request,HttpServletResponse response){ String userid = "1"; String goodsId = "1"; Map<String,Object> orderMap = redisService.get(OrderKey.getMiaoshaOrderByUidGid, ""+userid+"_"+goodsId,Map.class); if(orderMap != null){ System.out.println("重复下单"); return Result.error(CodeMsg.REPEATE_MIAOSHA); } int count = redisService.get(GoodsKey.getMiaoshaGoodsStock, goodsId,Integer.class); if(count <= 0){ System.out.println("库存不足"); return Result.error(CodeMsg.MIAO_SHA_OVER); } Jedis jedis = jedisPool.getResource(); String requestId = UUID.randomUUID().toString(); boolean isOk = RedisLock.tryGetDistributedLock(jedis,GoodsKey.getMiaoshaGoodsStock+goodsId,requestId,10000); if(isOk){ try{ redisService.decr(GoodsKey.getMiaoshaGoodsStock,goodsId); Map<String, Object> map = new HashMap<>(); map.put("user_id", userid); map.put("goods_id", goodsId); miaoshaService.miaosha(map); System.out.println("抢购成功"); }finally{ RedisLock.releaseDistributedLock(jedis,GoodsKey.getMiaoshaGoodsStock+goodsId,requestId);//释放锁 } }else{ System.out.println("该线程未拿到锁"); } return Result.success(0); } /** * QPS:327 * 请求秒杀,redis+Lua方式(小并发适用) */ @RequestMapping(value="/{path}/do_miaosha1") @ResponseBody public Result<Integer> do_miaosha1(HttpServletRequest request,HttpServletResponse response,@RequestParam("goodsId")String goodsId,@PathVariable("path") String path){ MiaoshaUser user = userService.getUser(re