一、秒杀商品的页面展示：

1.1 秒杀列表页面数据的展示：

1.1.1 新建一个zyg-seckill-web工程：

pom.xml文件：

  1.  <dependencies>
  2.         <dependency>
  3.             <groupId>org.springframework.boot</groupId>
  4.             <artifactId>spring-boot-starter-web</artifactId>
  5.         </dependency>
  7.         <!--1.添加thymeleaf依赖-->
  8.         <dependency>
  9.             <groupId>org.springframework.boot</groupId>
  10.             <artifactId>spring-boot-starter-thymeleaf</artifactId>
  11.         </dependency>
  12.         <!--2.添加devtools-->
  13.         <dependency>
  14.             <groupId>org.springframework.boot</groupId>
  15.             <artifactId>spring-boot-devtools</artifactId>
  16.             <optional>true</optional>
  17.         </dependency>
  18.         <dependency>
  19.             <groupId>com.zelin</groupId>
  20.             <artifactId>zyg-dao</artifactId>
  21.             <version>2.0</version>
  22.         </dependency>
  24.         <!--1. 引入cas单点登录的依赖-->
  25.         <dependency>
  26.             <groupId>org.springframework.boot</groupId>
  27.             <artifactId>spring-boot-starter-security</artifactId>
  28.         </dependency>
  29.         <dependency>
  30.             <groupId>org.springframework.security</groupId>
  31.             <artifactId>spring-security-cas</artifactId>
  32.         </dependency>
  34.         <dependency>
  35.             <groupId>com.zelin</groupId>
  36.             <artifactId>zyg-seckill-interface</artifactId>
  37.             <version>2.0</version>
  38.         </dependency>
  39.         <!--引入支付服务-->
  40.         <dependency>
  41.             <groupId>com.zelin</groupId>
  42.             <artifactId>zyg-pay-interface</artifactId>
  43.             <version>2.0</version>
  44.         </dependency>
  45.     </dependencies>
  46. </project>

application.properties文件：

  1. server.port=9009
  2. logging.level.com.zelin=debug
  3. spring.thymeleaf.cache=false
  4. spring.dubbo.registry.address=zookeeper://192.168.56.10:2181
  5. spring.dubbo.base-package=com.zelin.seckill.web
  6. spring.dubbo.application.name=zyg-seckill-web
  8. cas.server.prefix=http://cas.zeyigou.com:8080/cas
  9. cas.server.login=${cas.server.prefix}/login
  10. cas.server.logout=${cas.server.prefix}/logout
  12. cas.client.prefix=http://seckill.zeyigou.com
  13. cas.client.login=${cas.client.prefix}/login/cas
  14. cas.client.logoutRelative=/logout/cas
  15. cas.client.logout=${cas.client.prefix}${cas.client.logoutRelative}

config目录下关于cas的配置与zyg-cart-web工程。

1.1.2 在nginx服务器下配置关于seckill-web的服务器映射：

/mydata/nginx/conf/conf.d/zeyigou.conf

  1. server {
  2.     listen       80;
  3.     server_name  seckill.zeyigou.com;
  5.     location / {
  6.     proxy_pass http://seckill;
  7.     proxy_set_header Host $host:$server_port;
  8.     }
  10.     include /etc/nginx/static.conf;
  11. }

/mydata/nginx/conf/nginx.conf文件：

  1. upstream seckill{
  2.     server 192.168.56.1:9009;
  3. }

1.1.3 在zyg-seckill-service下定义关于查询秒杀商品信息的方法：

  2.     /**
  3.      * 功能: 根据商品的时间标识得到商品列表
  4.      * 参数:
  5.      * 返回值: java.util.List<com.zelin.entity.SeckillGoodsEntity>
  6.      * 时间: 2021/8/19 12:40
  7.      */
  8.     @Override
  9.     public List<SeckillGoodsEntity> findSeckillGoods() {
  10.         BoundHashOperations<String, String, String> hashOperations = redisTemplate.boundHashOps("SeckillGoods_2021081914" );
  11.         List<String> values = hashOperations.values();
  12.         System.out.println("values = " + values);
  13.         List<SeckillGoodsEntity> collect = values.stream().map(m -> {
  14.             SeckillGoodsEntity seckillGoodsEntity = JSON.parseObject(m, SeckillGoodsEntity.class);
  15.             return seckillGoodsEntity;
  16.         }).collect(Collectors.toList());
  17.         System.out.println("collect = " + collect);
  18.         return collect;
  19.     }

1.1.4 在zyg-seckill-service下定义关于查询菜单的方法：

  1.     /**
  2.      * 功能: 展示菜单
  3.      * 参数:
  4.      * 返回值: java.util.List<java.sql.Date>
  5.      * 时间: 2021/8/19 13:13
  6.      */
  7.     @Override
  8.     public List<Date> listMenus() {
  9.         return MyDate.getDateMenus();
  10.     }

1.1.5 在zyg-seckill-web中的控制器下定义查看商品的方法：

  1. /**
  2.      * 功能: 根据当前时间列表秒杀商品
  3.      * 参数:
  4.      * 返回值: java.lang.String
  5.      * 时间: 2021/8/19 12:08
  6.      */
  7.     @RequestMapping({"/","seckill-index"})
  8.     public String secKillList(Model model){
  9.         //1. 得到所有商品(指定日期空间下的某些商品)
  10.         List<SeckillGoodsEntity> seckillGoodsEntities = secKillService.findSeckillGoods();
  11.         //2. 得到以当前时间小时数为起点的往向5个时间范围
  12.         List<Date> menus = secKillService.listMenus();
  13.         //3. 将上面的两组数据放到model中
  14.         model.addAttribute("seckillGoods",seckillGoodsEntities);
  15.         model.addAttribute("menus",menus);
  16.         return "seckill-index";
  17.     }

1.1.6 在zyg-seckill-web中的控制器下定义查看菜单的方法：

  1.     /**
  2.      * 功能: 展示菜单
  3.      * 参数:
  4.      * 返回值:
  5.      * 时间: 2021/8/19 13:11
  6.      */
  7.     @RequestMapping("menus")
  8.     public String listMenus(Model model){
  9.         List<Date> menus = secKillService.listMenus();
  10.         model.addAttribute("menus",menus);
  11.         return "seckill-index";
  12.     }

1.1.7 在templates/seckill-index.html页面展示商品：

  1. <div class="py-container index">
  2.         <!--banner-->
  3.         <div class="banner">
  4.             <img src="/static/seckill/img/_/banner.png" class="img-responsive" alt="">
  5.         </div>
  6.         <!--秒杀时间-->
  7.         <div class="sectime">
  8.             <div th:class="${stat.index==0}? 'item-time active':'item-time' "
  9.                  th:attr="time=${#dates.hour(menu)}" th:each="menu,stat : ${menus}">
  10.                 <div class="time-clock" th:text="${#dates.hour(menu)}"></div>
  11.                 <div class="time-state-on">
  12.                     <span class="on-text">快抢中</span>
  13.                     <span class="on-over">距离结束：01:02:34</span>
  14.                 </div>
  16.             </div>
  18.         </div>
  19.         <!--商品列表-->
  20.         <div class="goods-list" id="app">
  21.             <ul class="seckill" id="seckill">
  22.                 <li class="seckill-item" th:each="item : ${seckillGoods}" >
  23.                     <div class="pic">
  24.                         <img th:src="${item.smallPic}" alt=''>
  25.                     </div>
  26.                     <div class="intro">
  27.                         <span>[[${item.introduction}]]</span>
  28.                     </div>
  29.                     <div class='price'>
  30.                         <b class='sec-price'>￥[[${item.costPrice}]]</b>
  31.                         <b class='ever-price'>￥[[${item.price}]]</b>
  32.                     </div>
  33.                     <div class='num'>
  34.                         <div>已售[[${item.num-item.stockCount}]]</div>
  35.                         <div class='progress'>
  36.                             <div class='sui-progress progress-danger'>
  37.                                 <span th:style="'width:'+ ${(item.num-item.stockCount)* 100/item.num}  + '%'"
  38.                                        class='bar'></span>
  39.                             </div>
  40.                         </div>
  41.                         <div>剩余
  42.                             <b class='owned'>[[${item.stockCount}]]</b>件</div>
  43.                     </div>
  44.                     <a class='sui-btn btn-block btn-buy' th:href="'/findSeckillGoods?seckillId=' + ${item.id}" target='_blank'>立即抢购</a>
  46.                 </li>
  47.             </ul>
  48.         </div>
  49.         <div class="cd-top">
  50.             <div class="top">
  51.                 <img src="/static/seckill/img/_/gotop.png" />
  52.                 <b>TOP</b>
  53.             </div>
  54.             <div class="code" id="code">
  55.                 <span>
  56.                     <img src="/static/seckill/img/_/code.png" />
  57.                 </span>
  58.             </div>
  59.             <div class="erweima">
  60.                 <img src="/static/seckill/img/_/erweima.jpg" alt="">
  61.                 <s></s>
  62.             </div>
  63.         </div>
  64.     </div>

1.1.8 页面效果如下：

image.png

1.2 秒杀详情页面数据的展示：

1.2.1 在秒杀列表中中的”立即抢购”按钮下添加跳转：

  1. <a class='sui-btn btn-block btn-buy' th:href="'/findSeckillGoods?seckillId=' + ${item.id}" 
  2.                        target='_blank'>立即抢购</a>

1.2.2 在zyg-seckill-web中添加findSeckillGoods方法：

  2.     /**
  3.      * 功能: 根据秒杀商品id查询秒杀商品
  4.      * 参数:
  5.      * 返回值:
  6.      * 时间: 2021/8/19 14:49
  7.      */
  8.     @RequestMapping("findSeckillGoods")
  9.     public String findSeckillGoods(String seckillId,Model model){
  10.         //1. 在redis中根据secKillId查询秒杀商品
  11.         SeckillGoodsEntity seckillGoodsEntity = secKillService.findSecKillGoodsById(seckillId);
  12.         //2. 放到model 中
  13.         model.addAttribute("seckillGoods",seckillGoodsEntity);
  14.         //3. 返回到seckill-item.html
  15.         return "seckill-item";
  16.     }

1.2.3 在zyg-seckill-service中通过redis中进行查询

  2.     /**
  3.      * 功能: 根据秒杀商品id查询商品
  4.      * 参数:
  5.      * 返回值: com.zelin.entity.SeckillGoodsEntity
  6.      * 时间: 2021/8/19 14:52
  7.      */
  8.     @Override
  9.     public SeckillGoodsEntity findSecKillGoodsById(String seckillId) {
  10.         String seckillGoods = (String) redisTemplate.boundHashOps("SeckillGoods_2021081914").get(seckillId);
  11.         return JSON.parseObject(seckillGoods,SeckillGoodsEntity.class);
  12.     }

1.2.4 页面展示：

  1.     <div class="fr itemInfo-wrap">
  2.                     <div class="sku-name">
  3.                         <h4>[[${seckillGoods.title}]]</h4>
  4.                     </div>
  5.                     <div class="news">
  6.                         <span><img src="/static/seckill/img/_/clock.png"/>青橙秒杀</span>
  7.                         <span class="overtime">距离结束：01:56:78</span>
  8.                         </div>
  9.                     <div class="summary">
  10.                         <div class="summary-wrap">
  12.                             <div class="fl title">
  13.                                 <i>价　　格</i>
  14.                             </div>
  15.                             <div class="fl price">
  16.                                 <i>¥</i>
  17.                                 <em>[[${seckillGoods.costPrice}]]</em>
  18.                                 <span>降价通知</span>
  19.                             </div>
  20.                             <div class="fr remark">
  21.                                 <i>累计评价</i><em>612188</em>
  22.                             </div>
  23.                         </div>
  24.                         <div class="summary-wrap">
  25.                             <div class="fl title">
  26.                                 <i>促　　销</i>
  27.                             </div>
  28.                             <div class="fl fix-width">
  29.                                 <i class="red-bg">加价购</i>
  30.                                 <em class="t-gray">满999.00另加20.00元，或满1999.00另加30.00元，或满2999.00另加40.00元，即可在购物车换购热销商品</em>
  31.                             </div>
  32.                         </div>
  33.                     </div>
  34.                     <div class="support">
  35.                         <div class="summary-wrap">
  36.                             <div class="fl title">
  37.                                 <i>支　　持</i>
  38.                             </div>
  39.                             <div class="fl fix-width">
  40.                                 <em class="t-gray">以旧换新，闲置手机回收  4G套餐超值抢  礼品购</em>
  41.                             </div>
  42.                         </div>
  43.                         <div class="summary-wrap">
  44.                             <div class="fl title">
  45.                                 <i>配 送 至</i>
  46.                             </div>
  47.                             <div class="fl fix-width">
  48.                                 <em class="t-gray">满999.00另加20.00元，或满1999.00另加30.00元，或满2999.00另加40.00元，即可在购物车换购热销商品</em>
  49.                             </div>
  50.                         </div>
  51.                     </div>
  52.                     <div class="clearfix choose">
  53.                         <div id="specification" class="summary-wrap clearfix">
  54.                             <dl>
  55.                                 <dt>
  56.                                     <div class="fl title">
  57.                                         <i>选择颜色</i>
  58.                                     </div>
  59.                                 </dt>
  60.                                 <dd><a href="javascript:;" class="selected">金色<span title="点击取消选择">&nbsp;</span>
  61. </a></dd>
  62.                                 <dd><a href="javascript:;">银色</a></dd>
  63.                                 <dd><a href="javascript:;">黑色</a></dd>
  64.                             </dl>
  65.                             <dl>
  66.                                 <dt>
  67.                                     <div class="fl title">
  68.                                         <i>内存容量</i>
  69.                                     </div>
  70.                                 </dt>
  71.                                 <dd><a href="javascript:;" class="selected">16G<span title="点击取消选择">&nbsp;</span>
  72. </a></dd>
  73.                                 <dd><a href="javascript:;">64G</a></dd>
  74.                                 <dd><a href="javascript:;" class="locked">128G</a></dd>
  75.                             </dl>
  76.                             <dl>
  77.                                 <dt>
  78.                                     <div class="fl title">
  79.                                         <i>选择版本</i>
  80.                                     </div>
  81.                                 </dt>
  82.                                 <dd><a href="javascript:;" class="selected">公开版<span title="点击取消选择">&nbsp;</span>
  83. </a></dd>
  84.                                 <dd><a href="javascript:;">移动版</a></dd>
  85.                             </dl>
  86.                             <dl>
  87.                                 <dt>
  88.                                     <div class="fl title">
  89.                                         <i>购买方式</i>
  90.                                     </div>
  91.                                 </dt>
  92.                                 <dd><a href="javascript:;" class="selected">官方标配<span title="点击取消选择">&nbsp;</span>
  93. </a></dd>
  94.                                 <dd><a href="javascript:;">移动优惠版</a></dd>
  95.                                 <dd><a href="javascript:;" class="locked">电信优惠版</a></dd>
  96.                             </dl>
  97.                             <dl>
  98.                                 <dt>
  99.                                     <div class="fl title">
  100.                                         <i>套　　装</i>
  101.                                     </div>
  102.                                 </dt>
  103.                                 <dd><a href="javascript:;" class="selected">保护套装<span title="点击取消选择">&nbsp;</span>
  104. </a></dd>
  105.                                 <dd><a href="javascript:;" class="locked">充电套装</a></dd>
  107.                             </dl>
  110.                         </div>
  113.                         <div class="summary-wrap">
  114.                             <div class="fl title">
  115.                                 <div class="control-group">
  116.                                     <div class="controls">
  117.                                         <input autocomplete="off" type="text" value="1" minnum="1" class="itxt" />
  118.                                         <a href="javascript:void(0)" class="increment plus">+</a>
  119.                                         <a href="javascript:void(0)" class="increment mins">-</a>
  120.                                     </div>
  121.                                 </div>
  122.                             </div>
  123.                             <div class="fl">
  124.                                 <ul class="btn-choose unstyled">
  125.                                     <li>
  126.                                         <a href="cart.html" target="_blank" class="addshopcar">抢单</a>
  127.                                     </li>
  128.                                 </ul>
  129.                             </div>
  130.                         </div>
  131.                     </div>
  132.                 </div>

1.2.5 页面效果：

image.png

二、秒杀功能实现：

2.1 用户下单功能细节：

1、细节功能，添加排队信息(SeckillStatus)

  1. 在秒杀模块实现过程中，为了公平起见，先来的可以先下单 ，我们可以将用户的排队信息定义在一个实体类，并把这个实体类放到redis中的队列中（redis的list数据类型）<br />**1.1 SeckillStatus类型定义**
  1. /**
  2.  * ------------------------------
  3.  * 功能：
  4.  * 作者：WF
  5.  * 微信：hbxfwf13590332912
  6.  * 创建时间：2021/8/19-17:01
  7.  * ------------------------------
  8.  */
  9. @Data
  10. public class SeckillStatus implements Serializable {
  11.     //秒杀用户名
  12.     private String username;
  13.     //创建时间
  14.     private Date createTime;
  15.     //秒杀状态  1:排队中，2:秒杀等待支付,3:支付超时，4:秒杀失败,5:支付完成
  16.     private Integer status;
  17.     //秒杀的商品ID
  18.     private Long secKillId;
  20.     //应付金额
  21.     private Float money;
  23.     //订单号
  24.     private Long orderId;
  25.     //时间段
  26.     private String time;
  28.     public SeckillStatus(String username, Date createTime, Integer status, Long secKillId, String time) {
  29.         this.username = username;
  30.         this.createTime = createTime;
  31.         this.status = status;
  32.         this.secKillId = secKillId;
  33.         this.time = time;
  34.     }
  35. }

1.2 在下单前，应该把排队的信息(SeckillStatus对象)存放到redis中的list中：

  1. @Override
  2. public boolean save(String secKillId, String time, String username)  {
  3.     ...
  4.     // 将此对象入队列,目的是为了公平原则（先排队先下单）
  5.     redisTemplate.boundListOps("SeckillOrderQueue").leftPush(JSON.toJSONString(seckillStatus));
  6.     ...
  7. }

1.3 在下单前，从redis中取得从左边放入的队列数据（先排队的就先弹出）

  1.  public void createOrder()  {
  3.       ...
  4.      String orderQueue = redisTemplate.boundListOps("SeckillOrderQueue").rightPop();
  5.      //转换为 SeckillStatus类型,取得排队时放入的信息
  6.      SeckillStatus seckillStatus = JSON.parseObject(orderQueue, SeckillStatus.class);
  7.      String time = seckillStatus.getTime();
  8.      String secKillId = seckillStatus.getSecKillId()+"";
  9.      String username = seckillStatus.getUsername();
  10.       ...    
  11.  }

原理图：

1、秒杀-排队顺序问题.jpg

2、细节功能：添加排队标识

将用户排队信息写入到redis中，方便后面更新用户的排队状态。
2.1 存用户排队标识的key (用于存储 谁 买了什么商品 以及抢单的状态)

  1.    @Override
  2.     public boolean save(String secKillId, String time, String username)  {
  3.         ...
  4.         // 为了后面查询订单状态，我们将上面的seckillStatus又保存一份到redis中（因上面的会被立即弹出）
  5.         redisTemplate.boundHashOps("UserQueueStatus").put(username,JSON.toJSONString(seckillStatus));
  6.         //异步下单
  7.         multiThreadingCreateOrder.createOrder();
  9.         return true;
  10.     }

2.2 在下单完成后，修改排队信息：

  1.    public void createOrder()  {
  2.        ...
  3.        //重新改回状态值
  4.        seckillStatus.setStatus(2);   //下单后，等待支付
  5.        seckillStatus.setOrderId(seckillOrderEntity.getId());
  6.        seckillStatus.setMoney(seckillOrderEntity.getMoney().floatValue());
  7.        redisTemplate.boundHashOps("UserQueueStatus").put(username,JSON.toJSONString(seckillStatus));
  8.        ...
  9.    }

3、细节功能：避免重复排队

思路：可以以UserQueueCount为key，以当前登录名为小key，让其从1开始自增，如果自增后的值大于1，说明不能排队。

  1.  @Override
  2.     public boolean save(String secKillId, String time, String username)  {
  3.         // 定义用户状态信息保存到redis中的队列中
  4.         SeckillStatus seckillStatus = new SeckillStatus(username,new Date(),1, Long.parseLong(secKillId),time);
  6.         //避免重复排队
  7.         Long queueCount = redisTemplate.boundHashOps("UserQueueCount").increment(username, 1);
  8.         if(queueCount > 1){
  9.             throw new RuntimeException(StatusCode.REPERROR + "");
  10.         }
  12.         // 将此对象入队列,目的是为了公平原则（先排队先下单）
  13.         redisTemplate.boundListOps("SeckillOrderQueue").leftPush(JSON.toJSONString(seckillStatus));
  14.         // 为了后面查询订单状态，我们将上面的seckillStatus又保存一份到redis中（因上面的会被立即弹出）
  15.         redisTemplate.boundHashOps("UserQueueStatus").put(username,JSON.toJSONString(seckillStatus));
  16.         //异步下单
  17.         multiThreadingCreateOrder.createOrder();
  19.         return true;
  20.     }

4、细节功能：避免商品超卖

2、秒杀-内存超卖.jpg
思路：
① 我们可以在定时任务放商品信息时，以SeckillGoodsCountList商品id为key，以一个这样的数组为值（数组的个数为商品的个数，数组的元素内容为商品id【可以放任意值】）放到redis的队列中。
② 方案一【推荐】
在我们队Redis进行操作的时候，很多时候，都是先将数据查询出来，在内存中修改，然后存入到Redis，在并发场景，会出现数据错乱问题，为了控制数量准确，我们单独将商品数量整一个自增键，自增键是线程安全的，所以不担心并发场景的问题。
③ 方案二：
可以根据SeckillGoodsCountList商品id这个队列中的商品的个数就知道了商品的数量。

  1.  /**
  2.      * 功能: 将数据库中的数据加载到redis中
  3.      * 参数:
  4.      * 返回值: void
  5.      * 时间: 2021/8/18 16:24
  6.      */
  7.     @Scheduled(cron = "0/30 * * * * ?")
  8.     public void loadDataToRedis(){
  10.         //1. 得到日期菜单
  11.         List<Date> dateMenus = MyDate.getDateMenus();
  12.         //2. 遍历日期菜单
  13.         for (Date dateMenu : dateMenus) {
  14.             //2.1 定义查询条件
  15.             QueryWrapper<SeckillGoodsEntity> queryWrapper = new QueryWrapper<SeckillGoodsEntity>()
  16.                                             .eq("status", 1)
  17.                                             .ge("start_time",dateMenu)
  18.                                             // .lt("start_time",MyDate.addDateHour(dateMenu,2))
  19.                                             .lt("end_time",MyDate.addDateHour(dateMenu,2))
  20.                                             .gt("stock_count",0);
  21.             //2.2 查询redis中指定大key中是否包含有小key集合
  22.             Set keys = redisTemplate.boundHashOps("SeckillGoods_" + MyDate.getDateStr(dateMenu)).keys();
  23.             //2.3 判断是否keys存在
  24.             if(keys != null && keys.size() > 0){
  25.                 queryWrapper.notIn("id",keys);
  26.             }
  27.             //2.4 查询商品列表
  28.             List<SeckillGoodsEntity> goodsEntities = seckillGoodsDao.selectList(queryWrapper);
  29.             //2.5 将商品放到redis中
  30.             for (SeckillGoodsEntity goodsEntity : goodsEntities) {
  31.                 BoundHashOperations<String, String, String> hashOperations = redisTemplate.boundHashOps("SeckillGoods_" + MyDate.getDateStr(dateMenu));
  32.                 hashOperations.put(goodsEntity.getId() + "", JSON.toJSONString(goodsEntity));
  33.                 //设置过期时间
  35.                 //[添加的内容一]:以SeckillGoodsCountList_商品id为key，将一个指定的数组(数组的长度为商品数量，元素是商品id)放到redis中
  36.                 String[] ids = pushGoods(goodsEntity.getStockCount(), goodsEntity.getId());
  37.                 redisTemplate.boundListOps("SeckillGoodsCountList_"+goodsEntity.getId()).leftPushAll(ids);
  39.                 //[添加的内容二]:以SeckillGoodsCount为大key，以商品id为小key，作一个对应商品的自增键，以后下单扣完库存的实际数量，就是这里的自增键
  40.                 redisTemplate.boundHashOps("SeckillGoodsCount").put(goodsEntity.getId()+"",goodsEntity.getStockCount());
  41.             }
  42.         }
  43.     }
  45.     /**
  46.      * 功能: 以商品数量为数组长度，以商品id为数组元素
  47.      * 参数:
  48.      * 返回值:
  49.      * 时间: 2021/8/20 15:36
  50.      */
  51.     private String[] pushGoods(int len,long id){
  52.         String[] ids = new String[len];
  53.         for (int i = 0; i < len; i++) {
  54.             ids[i] = id + "";
  55.         }
  56.         return ids;
  57.     }

问题一：在哪里控制？在下单 前我们可以从SeckillGoodsCountList_商品id这个队列的右边弹出一项，看是否有内容，有内容就证明还有商品，否则，没有商品，清理排队信息。。。

  1.  public void createOrder()  {
  2.         try {
  3.             // String time = "2021081916";
  4.             // String username = "test";
  5.             // String secKillId = "1";
  6.             //从redis中得到SeckillOrderQueue这个队列的值
  7.             Thread.sleep(20000);
  9.             String orderQueue = redisTemplate.boundListOps("SeckillOrderQueue").rightPop();
  11.             //转换为 SeckillStatus类型
  12.             SeckillStatus seckillStatus = JSON.parseObject(orderQueue, SeckillStatus.class);
  14.             //从SeckillGoodsCountList_商品id的redis队列中取出队列，看是否有内容，如果有证明此商品还没有卖完
  15.             String rightPop = redisTemplate.boundListOps("SeckillGoodsCountList_" + seckillStatus.getSecKillId()).rightPop();
  16.             if(rightPop == null){       //如果为null就证明没有商品了，清除排队数据
  17.                 clearQueue(seckillStatus.getUsername());
  18.                 return;
  19.             }
  20.         。。。
  21. }
  22.   /**
  23.      * 功能: 清除排队相关的数据
  24.      * 参数:
  25.      * 返回值: void
  26.      * 时间: 2021/8/20 15:43
  27.      */
  28.     private void clearQueue(String username) {
  29.         //1. 清除是否重复排队标识
  30.         redisTemplate.boundHashOps("UserQueueCount").delete(username);
  31.         //2. 清除排队的标识信息
  32.         redisTemplate.boundHashOps("UserQueueStatus").delete(username);
  33.     }

问题二：如何控制商品库存量的精准？在下单前判断商品数量是否为0，此时，要得到精准数量判断。
3、秒杀-控制库存量精准.jpg

  1.  public void createOrder()  {
  2.     //2.2 通过自增键得到商品的真实库存量，因为高并发场景，可能存在着数据的错乱(得到精准的库存量)
  3.     Long goodsCount = redisTemplate.boundHashOps("SeckillGoodsCount").increment(seckillGoodsEntity.getId() + "", -1);
  4.     seckillGoodsEntity.setStockCount(new Integer(goodsCount + ""));
  5.  }

总结秒杀环节的问题：

1、排队的顺序问题：用redis的list队列解决。 2、排队的标识：最后通过它修改状态，直接在redis中保存一份排队信息。 3、库存超卖问题： 以SeckillGoodsCountList_商品id为key，以数组（长度为商品数量，内容为商品id）为值在定时任务放商品时就放到redis中，以后每次下单前就右边弹出数据，如果有证明可以下单 ，否则，不能下单 ，清空排队信息。 4、重复排队： 在下单 前添加以UserQueueCount为大key，以登录用户为小key，放一个自增值1，自增后如果大于就证明重复排队，可以抛出异常！ 5、在高并发场景下，数据的不精准性控制： 利用在定时任务开始时添加自增键，自增键的值就是商品的数量，在下单前，查看商品数量前，减少自增键，得到当前的商品真实数量。

2.2 秒杀支付：

2.2.1 在zyg-pay-service的application.yml文件中定义关于秒杀支付的同步及异步回调地址：

  1.   alipay:
  2.       notify_url1: http://42d323h910.qicp.vip/seckillOrder/payed/notify
  3.       return_url1: http://seckill.zeyigou.com/orderlist

2.2.2 在zyg-pay-service的AlipayTempalte.java中定义上面两个属性：

  1.     private String notify_url1;
  2.     private String return_url1;

2.2.3 在zyg-pay-service的pay()方法中新增一个代表支付类型的参数：

  1. @ConfigurationProperties(prefix = "alipay")
  2. @Component
  3. @Data
  4. public class AlipayTemplate {
  6.     //在支付宝创建的应用的id
  7.     private   String app_id ;//= "2016110200786382";
  9.     // 商户私钥，您的PKCS8格式RSA2私钥
  10.     private  String merchant_private_key ;
  11.     // 支付宝公钥,查看地址：https://openhome.alipay.com/platform/keyManage.htm 对应APPID下的支付宝公钥。
  12.     private  String alipay_public_key ;
  13.     // 服务器[异步通知]页面路径  需http://格式的完整路径，不能加?id=123这类自定义参数，必须外网可以正常访问
  14.     // 支付宝会悄悄的给我们发送一个请求，告诉我们支付成功的信息
  15.     private  String notify_url ;//= "http://localhost:8000/payed/notify";
  17.     // 页面跳转同步通知页面路径 需http://格式的完整路径，不能加?id=123这类自定义参数，必须外网可以正常访问
  18.     //同步通知，支付成功，一般跳转到成功页
  19.     private  String return_url ;
  21.     private String notify_url1;
  22.     private String return_url1;
  23.     // 签名方式
  24.     private  String sign_type ;
  26.     // 字符编码格式
  27.     private  String charset ;
  29.     private String timeout ;
  31.     // 支付宝网关； https://openapi.alipaydev.com/gateway.do
  32.     private  String gatewayUrl ;
  34.     public  String pay(PayVo vo,int type) throws AlipayApiException {
  36.         //1、根据支付宝的配置生成一个支付客户端
  37.         AlipayClient alipayClient = new DefaultAlipayClient(gatewayUrl,
  38.                 app_id, merchant_private_key, "json",
  39.                 charset, alipay_public_key, sign_type);
  41.         //2、创建一个支付请求 //设置请求参数
  42.         AlipayTradePagePayRequest alipayRequest = new AlipayTradePagePayRequest();
  43.         if(type == 1){
  44.             alipayRequest.setReturnUrl(return_url);
  45.             alipayRequest.setNotifyUrl(notify_url);
  46.         }
  48.         if(type == 2){
  49.             alipayRequest.setReturnUrl(return_url1);
  50.             alipayRequest.setNotifyUrl(notify_url1);
  51.         }
  53.         //商户订单号，商户网站订单系统中唯一订单号，必填
  54.         String out_trade_no = vo.getOut_trade_no();
  55.         //付款金额，必填
  56.         String total_amount = vo.getTotal_amount();
  57.         //订单名称，必填
  58.         String subject = vo.getSubject();
  59.         //商品描述，可空
  60.         String body = vo.getBody();
  62.         alipayRequest.setBizContent("{\"out_trade_no\":\""+ out_trade_no +"\","
  63.                 + "\"total_amount\":\""+ total_amount +"\","
  64.                 + "\"subject\":\""+ subject +"\","
  65.                 + "\"body\":\""+ body +"\","
  66.                 + "\"timeout_express\":\""+timeout+"\","
  67.                 + "\"product_code\":\"FAST_INSTANT_TRADE_PAY\"}");
  69.         String result = alipayClient.pageExecute(alipayRequest).getBody();
  71.         //会收到支付宝的响应，响应的是一个页面，只要浏览器显示这个页面，就会自动来到支付宝的收银台页面
  72.         System.out.println("支付宝的响应："+result);
  73.         return result;
  74.     }
  75. }

2.2.4 在zyg-seckill-web中定义pay方法调用上面的支付函数：[形成支付的页面]

  1.     /**
  2.      * 功能: 秒杀支付
  3.      * 参数:
  4.      * 返回值:
  5.      * 时间: 2021/8/20 16:47
  6.      */
  7.     @RequestMapping("pay")
  8.     @ResponseBody
  9.     public String pay(){
  10.         //0. 得到登录名
  11.         String name = SecurityContextHolder.getContext().getAuthentication().getName();
  12.         //1. 从redis中查询出订单并返回payVo对象
  13.         PayVo payVo = seckillOrderService.getPayVo(name);
  14.         String result = payService.pay(payVo, 2);
  15.         return result;
  16.     }

2.2.5 在zyg-seckill-web中定义关于支付的同步回调函数：

  1. /**
  2.      * 功能: 支付成功后的同步回调
  3.      * 参数:
  4.      * 返回值:
  5.      * 时间: 2021/8/20 17:41
  6.      */
  7.     @RequestMapping("orderlist")
  8.     public String orderlist(Model model){
  10.         //0. 得到登录id
  11.         String name = SecurityContextHolder.getContext().getAuthentication().getName();
  12.         //1. 根据登录用户id查询出此用户的订单列表及此订单的秒杀商品列表
  13.         List<SeckillOrderEntity> orderEntities = seckillOrderService.findOrders(name);
  14.         System.out.println("orderEntities = " + orderEntities);
  15.         model.addAttribute("orderList",orderEntities);
  17.         return "seckill-order";
  18.     }

2.2.6 在zyg-page-web中定义异步回调函数：

  1.  /**
  2.      * 功能: 支付宝发送异步通知【订单支付模块】
  3.      * 参数:
  4.      * 返回值: java.lang.String
  5.      * 时间: 2021/8/17 16:46
  6.      */
  7.     @PostMapping("/seckillOrder/payed/notify")
  8.     public String payedNotify(PayAsyncVo vo, HttpServletRequest request){
  9.         System.out.println("vo = " + vo);
  10.         //1. 得到登录用户
  11.         //String userId = SecurityContextHolder.getContext().getAuthentication().getName();
  12.         //2. 得支支付宝后台传入的数据
  13.         Map<String,String> params = new HashMap<>();
  14.         Map<String,String[]> requestParams = request.getParameterMap();
  15.         for (Iterator<String> iter = requestParams.keySet().iterator(); iter.hasNext();) {
  16.             String name = (String) iter.next();
  17.             String[] values = (String[]) requestParams.get(name);
  18.             String valueStr = "";
  19.             for (int i = 0; i < values.length; i++) {
  20.                 valueStr = (i == values.length - 1) ? valueStr + values[i]
  21.                         : valueStr + values[i] + ",";
  22.             }
  23.             //乱码解决，这段代码在出现乱码时使用
  24.             //valueStr = new String(valueStr.getBytes("ISO-8859-1"), "utf-8");
  25.             params.put(name, valueStr);
  26.         }
  28.         String result = payService.orderPayNotify(vo,params);
  29.         System.out.println("result = " + result);
  30.         return result;
  32.     }

2.2.6 在zyg-pay-service中定义orderPayNotify()异步回调方法：

  1.  @Transactional
  2.     @Override
  3.     public String orderPayNotify(PayAsyncVo vo, Map<String, String> params) {
  4.         try {
  5.             //1. 进行验签
  6.             boolean signVerified = AlipaySignature.rsaCheckV1(params, alipayTemplate.getAlipay_public_key(),
  7.                     alipayTemplate.getCharset(), alipayTemplate.getSign_type()); //调用SDK验证签名
  9.             //2. 判断是否验签成功
  10.             if(signVerified){
  11.                 //第一部分：修改秒杀订单日志
  12.                 //1.1 得到秒杀订单号
  13.                 String out_trade_no = vo.getOut_trade_no();
  14.                 //1.2 根据订单号得到登录名
  15.                 String username = redisTemplate.opsForValue().get(out_trade_no);
  16.                 //1.3 根据登录名得到redis中的秒杀订单
  17.                 String secKillStr = (String) redisTemplate.boundHashOps("SeckillOrder").get(username);
  18.                 SeckillOrderEntity orderEntity = JSON.parseObject(secKillStr,SeckillOrderEntity.class);
  20.                 if (vo.getTrade_status().equals("TRADE_SUCCESS") || vo.getTrade_status().equals("TRADE_FINISHED")){
  21.                     //第二部分：修改订单
  22.                     //2.1 修改redis中的订单信息
  23.                     orderEntity.setTransactionId(vo.getTrade_no()); //设置流水号
  24.                     orderEntity.setPayTime(new Date());
  25.                     orderEntity.setStatus("1");                     //代表支付成功
  26.                     //2.2 保存到db中
  27.                     seckillOrderDao.insert(orderEntity);            //添加到数据库中
  28.                     //2.3 在db中将购买的商品的库存减掉
  29.                     String time = MyDate.getDateStr(MyDate.getDateMenus().get(0));
  30.                     String s = (String) redisTemplate.boundHashOps("SeckillGoods_" + time).get(orderEntity.getSeckillId() + "");
  31.                     SeckillGoodsEntity seckillGoodsEntity = JSON.parseObject(s,SeckillGoodsEntity.class);
  32.                     goodsDao.updateById(seckillGoodsEntity);
  34.                     //2.4 从redis中删除订单
  35.                     redisTemplate.boundHashOps("SeckillOrder").delete(username);
  36.                     //2.5 也要删除该用户的排队相关的信息
  37.                     //2.5.1 清除是否重复排队标识
  38.                     redisTemplate.boundHashOps("UserQueueCount").delete(username);
  39.                     //2.5.2 清除排队的标识信息
  40.                     redisTemplate.boundHashOps("UserQueueStatus").delete(username);
  41.                 }
  43.                 System.out.println("支付成功");
  44.                 return "success";
  45.             }
  46.         } catch (AlipayApiException e) {
  47.             e.printStackTrace();
  48.         }
  49.         System.out.println("支付失败！");
  50.         return "fail";
  51.     }

2.2.7 最后的效果页面：

image.png
image.png
image.png