(更新时间)2021年6月4日 商城高并发秒杀系统(.NET Core版) 29-单品限流和防刷

#region 1、单品限流
{
    // 1、单品限流(限制单品在有限时间内请求次数)
    string LimitKey = "SeckillRequestLimit" + orderPo.ProductCount;
    string LimitCount = RedisHelper.Get(LimitKey);
    int SeckillRequestLimitCount = string.IsNullOrEmpty(LimitCount) ? 0 : Convert.ToInt32(LimitCount);
    int RequestLimits = 100; // 限制请求数量
    int expireSeconds = 10; // 2秒
    if (SeckillRequestLimitCount + 1 > RequestLimits)
    {
        // 1.1、抛出异常，达到最高限制数
        throw new BizException($"{expireSeconds}秒内只能请求{RequestLimits}次");
    }
    else
    {
        // 1.2、增加1 并设置2秒过期
        RedisHelper.IncrBy(LimitKey, 1);
        RedisHelper.Expire(LimitKey, expireSeconds);
    }
}
#endregion

#region 2、限制购买数量
{
    // 2、限制购买数量(防止刷单)
    string UserBuyLimitKey = "UserId" + sysUser.UserId + "ProductId" + orderPo.ProductId;
    string count = RedisHelper.HGet(UserBuyLimitKey, "UserBuyLimit");
    int intCount = string.IsNullOrEmpty(count) ? 0 : Convert.ToInt32(count);

    // 2.1 获取秒杀活动数量
    string SeckillLimit = RedisHelper.HGet(Convert.ToString(orderPo.ProductId), "SeckillLimit");
    int SeckillLimitCount = string.IsNullOrEmpty(SeckillLimit) ? 0 : Convert.ToInt32(SeckillLimit);
    if (intCount + 1 > SeckillLimitCount)
    {
        throw new BizException($"商品{orderPo.ProductName}:只能购买{SeckillLimit}次");
    }
    else
    {
        // 2.2 增加用户购买数量
        RedisHelper.HIncrBy(UserBuyLimitKey, "UserBuyLimit", orderPo.ProductCount);
    }
}
#endregion

  

 

  
1
  
2
  
3
  
4
  
5
  
6
  
7
  
8
  
9
  
10
  
11
  
12
  
13
  
14
  
15
  
16
  
17
  
18
  
19
  
20
  
21
  
22
  
23
  
24
  
25
  
26
  
27
  
28
  
29
  
30
  
31
  
32
  
33
  
34
  
35
  
36
  
37
  
38
  
39
  
40
  
41
  
42
  
43
 

这样做还会存在超卖问题，lock和redis分布式锁会造成性能问题，下节讲lua解决超卖问题

文章来源: codeboy.blog.csdn.net，作者：愚公搬代码，版权归原作者所有，如需转载，请联系作者。

原文链接：codeboy.blog.csdn.net/article/details/117574767