springboot+支付宝完成秒杀项目的初体验

Posted tanyiming

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了springboot+支付宝完成秒杀项目的初体验相关的知识,希望对你有一定的参考价值。

springboot+支付宝完成秒杀项目的初体验

思考的问题:

首先是秒杀的商品查询,考虑到是热点数据,所以写一个接口读取当日批次的秒杀商品到redis中(那么接下来对商品的操作都放入redis中)。
当用户抢购商品时,考虑到的是是否在秒杀时间段内以及商品是抢完的问题。首先需要判断该商品是否在秒杀时间内,然后要查询该商品数量是否足够。当然这些还不够,还要有为了防止高并发的解决方案:
  • 对用户限流:对恶意请求通过ip设置访问次数,超过次数则抛出异常。
  • 利用消息队列的异步请求来削峰
  • 利用redis做缓存:提升读的效率,当然在秒杀的时候更改数量也可以在redis中完成,可以保证数据库的安全性。
  • 当然还有nginx方向代理,双击热备份,资源静态化,服务做集群,还有redis的主从集群

###最主要的还是数据库的读写问题,强一致问题

当用户抢购时,进入并调用后端服务,这时候首先在redis中设置商品的键值对,然后读出redis中该商品的秒杀时间和数量,当满足条件时,更新redis中该商品的数量并在redis中生成订单。(这里用到了redis的锁,当这个商品的键没有时,则提交事物,当有时则不提交事物)

这时候通过线程来判断该商品是否在一分钟之内付款,付款失败则将商品?1,好让商品继续可以被秒杀。

同时,为了防止该商品在事物过程中发生错误,导致该商品一直锁住,所以使用了try catch finally代码块,在finally中释放该锁,即是删除该键值对。

核心代码如下:

利用任务系统查询当日秒杀商品业务:

public AppResult FindSkProduce() 
    //找到今日打折的商品放入redis中
    //条件 状态为1 数量大于0 在指定时间内
    //用hash(Map)存储 大键为cs1901_sk 小键为商品id  值为商品对象
    String s= DateUtils.getCurrentDate();
    String s1 = s + " 00:00:00";
    String s2 = s+ " 23:59:59";
    Date date1 = DateUtils.stringToDate(s1,DateUtils.DATE_TIME_FORMAT);
    Date date2 = DateUtils.stringToDate(s2,DateUtils.DATE_TIME_FORMAT);
    TbSeckillGoodsExample example=new TbSeckillGoodsExample();
    example.createCriteria().andEndTimeBetween(date1,date2).andStatusEqualTo("1").andNumGreaterThan(0);
    List<TbSeckillGoods> glist=tbSeckillGoodsMapper.selectByExample(example);
    HashOperations hashOperations =redisTemplate.opsForHash();
    for (TbSeckillGoods tbSeckillGoods : glist) 
        System.out.println(tbSeckillGoods.getId());
        hashOperations.put("cs1901_sk",tbSeckillGoods.getId()+"",tbSeckillGoods);
    
    //设置过期时间 过期时间为EndTime减去现在的时间(data2-nowData)
    Long expireTime=(date2.getTime()-new Date().getTime())/1000;
    System.out.println(expireTime);
    //设置过期时间用expire 注意是redisTemplate中的方法 参数(Key,Long 时间,时间单位(TimeUnit))
    redisTemplate.expire("cs1901_sk",expireTime,TimeUnit.SECONDS);

    return new AppResult(true,200,null,null);
秒杀业务:
public AppResult CreateSkOrder(Long pid) 
    //创建订单
    //用redis的锁 锁住 该商品(在redis中查出该商品)
    //原理:redis 先设置唯一键 , 用redis 的事物和提交 ,再提交之前判断唯一键是否存在
    //watch(key)  若有该唯一键 则不提交事物,无则提交事物
    RedisLock redisLock=new RedisLock(redisTemplate,"lock"+pid);
    try 
        //事物
        //生成订单之前的判断:1 判断秒杀是否过期  2 判断商品数量是否足够
        //生成订单:1 生成唯一ID  将redis中的该商品数量减一  更新进redis
        //          2 生成订单 redis设置键位 大键为cs1901_sk_order 小键为订单id 值为订单
        //若抛出异常在finally中解锁 防止商品被锁死
        //新建线程 若一分钟未付款删除订单
        //用 thread

        //1 判断秒杀是否过期
        HashOperations hashOperations=redisTemplate.opsForHash();
        TbSeckillGoods tbSeckillGoods= (TbSeckillGoods) hashOperations.get("cs1901_sk",pid+"");
        if (redisTemplate.hasKey("cs1901_sk")==false)
            throw new AppExeption(200,"秒杀时间已过");
        
        //2 判断商品数量是否大于0
        if (tbSeckillGoods.getNum()<=0)
            throw  new AppExeption(201,"商品已抢购完");
        
        //1 更新数量
        tbSeckillGoods.setNum(tbSeckillGoods.getNum()-1);
        hashOperations.put("cs1901_sk",pid+"",tbSeckillGoods);
        //2 生成订单
        TbSeckillOrder tbSeckillOrder=new TbSeckillOrder();
        IDUtils idUtils=new IDUtils();
        Long oid=idUtils.nextId();
        tbSeckillOrder.setId(oid);
        tbSeckillOrder.setStatus("1");
        hashOperations.put("cs1901_sk_order",oid+"",tbSeckillOrder);

        //新建线程
        new Thread(new Runnable() 
            @Override
            public void run() 
                try 
                    Thread.sleep(1000);
                 catch (InterruptedException e) 
                    e.printStackTrace();
                
                TbSeckillOrder tbSeckillOrder1= (TbSeckillOrder) hashOperations.get("cs1901_sk_order",oid+"");
                if (tbSeckillOrder1.getStatus().equals("1"))
                 //将商品数量加一
                    TbSeckillGoods tbSeckillGoods1= (TbSeckillGoods) hashOperations.get("cs1901_sk",pid+"");
                    tbSeckillGoods1.setNum(tbSeckillGoods.getNum()+1);
                    hashOperations.put("cs1901_sk",pid+"",tbSeckillGoods1);
                
            
        ).start();
        return new AppResult(true,200,"已经抢到,请在一分钟内完成付款",oid+"");
    catch (Exception ex)
        return new AppResult(false,201,"没有抢到",null);
    finally 
        redisLock.unlock();
    
支付宝创建订单:
@GetMapping("/pay/createsk/orderid")
public void createsk(@PathVariable("orderid") Long orderid , HttpServletResponse response) throws Exception 
    //System.out.println(orderid+":"+total);
    //获得初始化的AlipayClient(生成支付宝客户端)
    AppResult result = payService.createSkPay(orderid,1L);
    if(result.isSuccess()==true)
        //把支付宝返回给我们的字符串   打印到客户端的浏览器
        response.getWriter().println(result.getData());
    else
        response.getWriter().println(result.getMessage());
    
支付成功同步回调:
@PostMapping("/asynonotice")
@ResponseBody
public String asynonotice(HttpServletRequest request) throws Exception 
    // 1: 获得支付宝返回的消息
    System.out.println("异步回调");
    String result = null;
    Map<String,String> params = new HashMap<String,String>();
    Map<String,String[]> requestParams = request.getParameterMap();
    for (Iterator<String> iter = requestParams.keySet().iterator(); iter.hasNext();) 
        String name = (String) iter.next();
        String[] values = (String[]) requestParams.get(name);
        String valueStr = "";
        for (int i = 0; i < values.length; i++) 
            valueStr = (i == values.length - 1) ? valueStr + values[i]
                    : valueStr + values[i] + ",";
        
        params.put(name, valueStr);
    
    System.out.println(params);
    //2:  延签( )
    boolean signVerified = AlipaySignature.rsaCheckV1(params, AlipayConfig.alipay_public_key,
            AlipayConfig.charset, AlipayConfig.sign_type); //调用SDK验证签名
    if(signVerified==false)
        //return new AppResult(false,null,null,"fail");
        return "fail";
    
    //3 判断 支付成功还是退款成功
    try 
        String trade_status = new String(request.getParameter("trade_status"));
        if(trade_status.equals("TRADE_FINISHED"))
            // 退款的话
            //payService.returnnotice(params);
            //...............
        else if (trade_status.equals("TRADE_SUCCESS"))
            AppResult appResult = payService.PaySyncNotice(params);
            if(appResult.isSuccess())
                result = "success";
            else
                result = "fail";
            
        
     catch (Exception e) 
        result = "fail";
        e.printStackTrace();
    
    System.out.println(result.toString());
    return "success";
支付成功异步回调:
@PostMapping("/sk/syncnotice")
@ResponseBody
public String sksyncnotice(HttpServletRequest request) throws Exception 

    String result = null;
    // 1: 获得支付宝返回的消息
    Map<String,String> params = new HashMap<String,String>();
    Map<String,String[]> requestParams = request.getParameterMap();
    for (Iterator<String> iter = requestParams.keySet().iterator(); iter.hasNext();) 
        String name = (String) iter.next();
        String[] values = (String[]) requestParams.get(name);
        String valueStr = "";
        for (int i = 0; i < values.length; i++) 
            valueStr = (i == values.length - 1) ? valueStr + values[i]
                    : valueStr + values[i] + ",";
        
        params.put(name, valueStr);
    
    //2:  验签( )
    boolean signVerified = AlipaySignature.rsaCheckV1(params, AlipayConfig.alipay_public_key,
            AlipayConfig.charset, AlipayConfig.sign_type); //调用SDK验证签名
    if(signVerified==false)
        //return new AppResult(false,null,null,"fail");
        return "fail";
    
    //3 判断 支付成功还是退款成功
    try 
        String trade_status = new String(request.getParameter("trade_status"));
        if(trade_status.equals("TRADE_FINISHED"))
            // 退款的话
            //payService.returnnotice(params);
            //...............
        else if (trade_status.equals("TRADE_SUCCESS"))
            AppResult appResult = payService.skpayNotice(params);
            if(appResult.isSuccess())
                result = "success";
            else
                result = "fail";
            
        
     catch (Exception e) 
        result = "fail";
        e.printStackTrace();
    
    System.out.println(result.toString());
    return "success";

以上是关于springboot+支付宝完成秒杀项目的初体验的主要内容,如果未能解决你的问题,请参考以下文章

SpringBoot构建电商秒杀项目

SpringBoot构建电商基础秒杀项目总结

SpringBoot+RabbitMQ+Redis实现商品秒杀

两套可以秒杀全场的SpringCloud项目,一套聚合支付一套电商,附完整资料文档

IDEA+SpringBoot MyBatis Dynamic SQL的初体验(二)

2019最新 Java商城秒杀系统的设计与实战视频教程(SpringBoot版)_2-1微服务项目的搭建-SpringBoot搭建多模块项目一