(更新时间)2021年6月4日商城高并发秒杀系统(.NET Core版) 30-lua文件封装加载和执行

一：lua文件的作用

1、批量执行redis命令
2、保证redis命令能够原子执行

二：lua文件定义和使用

1、lua文件

--[[1、函数定义
]]--
--1、单品限流
local function seckillLimit()
local seckillLimitKey = ARGV[2];
-- 1、获取单品已经请求数量
local limitCount = tonumber(redis.call('get',seckillLimitKey) or "0");
local requestCountLimits = tonumber(ARGV[4]); --限制的请求数量
local seckillLimitKeyExpire = tonumber(ARGV[5]); --2秒过期
if limitCount + 1 > requestCountLimits then --超出限流大小
return 0,seckillLimitKeyExpire.."内只能请求"..requestCountLimits.."次";  --失败
else --请求数+1，并设置过期时间
redis.call('INCRBY',seckillLimitKey,"1")
redis.call('expire',seckillLimitKey,seckillLimitKeyExpire)
return 1; --成功
end
end--2、记录订单号：目的：创建订单方法幂等性,调用方网络超时可以重复调用,存在订单号直接返回抢购成功,不至于超卖
local function recordOrderSn()
local requestIdKey = ARGV[6]; -- 订单号key
local orderSn = ARGV[7]; -- 订单号
local hasOrderSn = tostring(redis.call('get',requestIdKey) or "");
if string.len(hasOrderSn) == 0 then
-- 存储订单号
redis.call('set',requestIdKey,orderSn);
return 1; -- 设置成功
else
return 0,"不能重复下单"; --失败
end
end--3、用户购买限制
local function userBuyLimit()
local userBuyLimitKey = ARGV[1]; -- 购买限制key
local productKey =KEYS[1]; --商品key
local productCount = tonumber(ARGV[3]);-- 商品数量
-- 1、用户已经购买数量
local userHasBuyCount = tonumber(redis.call('hget',userBuyLimitKey,"UserBuyLimit") or "0");
-- 2、获取限制的数量
local seckillLimit = tonumber(redis.call('hget',productKey,"SeckillLimit") or "0");
if userHasBuyCount + 1 > seckillLimit then --超出购买数量
return 0,"该商品只能购买"..seckillLimit.."件"; --失败
else --请求数+1，并设置过期时间
redis.call('HINCRBY',userBuyLimitKey,'UserBuyLimit',productCount)
return 1; --成功
end
end--4、扣减库存
local function subtractSeckillStock()
local productKey =KEYS[1]; --商品key
local productCount = tonumber(ARGV[3]);--商品数量
-- 1.1、扣减库存
local lastNum = redis.call('HINCRBY',productKey,"SeckillStock",-productCount);
-- 1.2、判断库存是否完成
if lastNum < 0 then
return 0,"秒杀已结束"; --失败
else
return 1; --成功
end
end--[[2、函数调用
]]--
--1、单品限流
local status,msg = seckillLimit();
if status == 0 then
return msg
end
--2、记录订单号;
local status,msg = recordOrderSn();
if status == 0 then
return msg
end--3、用户购买限制
status,msg = userBuyLimit();
if status == 0 then
return msg
end
--4、扣减秒杀库存
status,msg = subtractSeckillStock();
if status == 0 then
return msg
end
-- 返回成功标识
return 1;

--[[1、函数定义
]]--
--1、删除记录订单号：目的：创建订单方法幂等性,调用方网络超时可以重复调用,存在订单号直接返回抢购成功,不至于超卖
local function delRecordOrderSn()
local requestIdKey = ARGV[3]; -- 订单号key
local orderSn = ARGV[4]; -- 订单号
--删除订单号
redis.call('del',requestIdKey)
end--2、删除用户购买限制
local function delUserBuyLimit()
local userBuyLimitKey = ARGV[1]; -- 购买限制key
local productKey =KEYS[1]; --商品key
local productCount = tonumber(ARGV[2]);-- 商品数量
redis.call('HINCRBY',userBuyLimitKey,'UserBuyLimit',-productCount)
end--3、恢复库存
local function recoverSeckillStock()
local productKey =KEYS[1]; --商品key
local productCount = tonumber(ARGV[2]);--商品数量
-- 3.1、恢复库存
redis.call('HINCRBY',productKey,"SeckillStock",productCount);
end--[[2、函数调用
]]--
--1、删除记录订单号;
delRecordOrderSn();--2、撤销用户购买限制
delUserBuyLimit();--3、恢复秒杀库存
recoverSeckillStock();

2、IHostedService

/// <summary>
/// 服务启动加载秒杀Lua文件
/// </summary>
public class SeckillLuaHostedService : IHostedService
{private readonly IMemoryCache memoryCache;public SeckillLuaHostedService(IMemoryCache memoryCache){this.memoryCache = memoryCache;}/// <summary>/// 加载秒杀库存缓存/// </summary>/// <param name="cancellationToken"></param>/// <returns></returns>public Task StartAsync(CancellationToken cancellationToken){try{Console.WriteLine("加载执行lua文件到redis中");// 1、加载lua到redisFileStream fileStream = new FileStream(@"Luas/SeckillLua.lua", FileMode.Open);using (StreamReader reader = new StreamReader(fileStream)){string line = reader.ReadToEnd();string luaSha = RedisHelper.ScriptLoad(@line);// 2、保存luaSha到缓存中memoryCache.Set<string>("luaSha", luaSha);}Console.WriteLine("加载回滚lua文件到redis中");// 1、加载lua到redisFileStream fileStreamCallback = new FileStream(@"Luas/SeckillLuaCallback.lua", FileMode.Open);using (StreamReader reader = new StreamReader(fileStreamCallback)){string line = reader.ReadToEnd();string luaSha = RedisHelper.ScriptLoad(@line);// 2、保存luaShaCallback到缓存中memoryCache.Set<string>("luaShaCallback", luaSha);}}catch (Exception e){Console.WriteLine($"lua文件异常:{e.Message}");}return Task.CompletedTask;}public Task StopAsync(CancellationToken cancellationToken){return Task.CompletedTask;}
}

三：使用

// 9、加载seckillLua文件
services.AddHostedService<SeckillLuaHostedService>();

在这里插入代码片

/// <summary>
/// 4.3、创建订单(redis + 消息队列 + lua)
/// </summary>
/// <param name="orderDto"></param>
[HttpPost]
public PaymentDto CreateOrder(SysUser sysUser, [FromForm]OrderPo orderPo)
{*//* RedisHelper.Eval("SeckillLua.lua","222","3222","2222");RedisHelper.EvalSHA("dddddd"); key = "22222222222"; // 内存缓存MemroyCacheRedisHelper.ScriptLoad*//*// 1、redis秒杀开始string ProductKey = Convert.ToString(orderPo.ProductId);// 商品keystring SeckillLimitKey = "seckill_stock_:SeckillLimit" + orderPo.ProductCount; // 单品限流keystring UserBuyLimitKey = "seckill_stock_:UserId" + sysUser.UserId + "ProductId" + orderPo.ProductId;// 用户购买限制keyint productCount = orderPo.ProductCount; // 购买商品数量 2int requestCountLimits = 100; // 单品限流数量int seckillLimitKeyExpire = 1;// 单品限流时间var SeckillResult = RedisHelper.EvalSHA(memoryCache.Get<string>("luaSha"), ProductKey, UserBuyLimitKey, SeckillLimitKey, productCount, requestCountLimits, seckillLimitKeyExpire);if (!SeckillResult.ToString().Equals("1")){throw new BizException(SeckillResult.ToString());}// 1、创建订单号string orderSn = OrderUtil.GetOrderCode();// 2、扣减库存(redis缓存+redis扣减)seckillStockCache.SubtractSeckillStock(orderPo.ProductId, orderPo.ProductCount);// 3、发送订单消息到rabbitmqSendOrderCreateMessage(sysUser.UserId, orderSn, orderPo);// 6、创建支付信息PaymentDto paymentDto = new PaymentDto();paymentDto.OrderSn = orderSn;paymentDto.OrderTotalPrice = orderPo.OrderTotalPrice;paymentDto.UserId = sysUser.UserId;paymentDto.ProductId = orderPo.ProductId;paymentDto.ProductName = orderPo.ProductName;return paymentDto;
}

(更新时间)2021年6月4日商城高并发秒杀系统(.NET Core版) 30-lua文件封装加载和执行相关推荐

(更新时间)2021年5月28日商城高并发秒杀系统(.NET Core版) 01-系统设计介绍
秒杀项目目标:从0到1构建一个高并发的秒杀系统三个阶段从0到1构建一个电商系统从0到1构建秒杀系统从0到1构建高并发秒杀系统为了完成这个目标,我们需要知道几个前提什么是电商什么是秒杀 ...
(更新时间)2021年6月2日商城高并发秒杀系统(.NET Core版) 20-性能优化-系统配置
性能测试的系统配置操作系统参数 1.cpu 8核2.内存 16G3.硬盘 237G4.带宽 100M本机2088/ms 性能瓶颈原因 1.操作系统如果是操作系统没有任何软件,只有秒杀微服务 ...
(更新时间)2021年6月3日商城高并发秒杀系统(.NET Core版) 26-性能优化-nginx负载均衡优化
一.关于Nginx的负载均衡在服务器集群中,Nginx起到一个代理服务器的角色(即反向代理),为了避免单独一个服务器压力过大,将来自用户的请求转发给不同的服务器. 二.Nginx负载均衡策略负载均 ...
(更新时间)2021年6月5日商城高并发秒杀系统(.NET Core版) 36-高并发秒杀项目k8s集群部署
秒杀项目docker部署前提准备 k8s集群网络 serviceSubnet: "10.96.0.0/16" podSubnet: "10.100.0.0/20&quo ...
(更新时间)2021年5月11日 MongoDB数据库 MongoDB面试题
MongoDB高频面试题文章目录 MongoDB高频面试题 1.MongoDB是什么? 2.MongoDB有哪些特点? 3.MySQL与MongoDB之间最基本的差别是什么? 4.monogodb中 ...
(更新时间)2021年5月12日 redis数据库 Redis面试题
Redis高频面试题文章目录 Redis高频面试题 1.什么是Redis?简述它的优缺点? 2.Redis相比memcached有哪些优势? 3.Redis支持哪几种数据类型? 4.Redis主要消 ...
(更新时间)2021年5月15日 Nginx服务器 Nginx面试题
Nginx面试题 1.什么是Nginx? Nginx是一个轻量级/高性能的反向代理Web服务器,他实现非常高效的反向代理.负载平衡,他可以处理2-3万并发连接数,官方监测能支持5万并发,现在中国使用 ...
(更新时间)2021年5月18日 C#.NET笔试题高级篇
C#.NET笔试题高级进阶篇文章目录 C#.NET笔试题高级进阶篇 1.说说什么是架构模式. 2.架构的5大要素是哪5大要素? 3.说说什么事集群,什么是分布式. 4.说说对Redis的理解 5 ...
(更新时间)2021年5月15日 SqlServer数据库 SqlServer面试题
数据库SqlServer笔试题文章目录数据库SqlServer笔试题一.数据库基础知识(通用)篇 1.说说主键.外键.超键.候选键 2.为什么用自增列作为主键? 3.触发器的作用是什么? 4.什 ...

(更新时间)2021年6月4日商城高并发秒杀系统(.NET Core版) 30-lua文件封装加载和执行

一：lua文件的作用

二：lua文件定义和使用

三：使用

(更新时间)2021年6月4日商城高并发秒杀系统(.NET Core版) 30-lua文件封装加载和执行相关推荐

最新文章

热门文章

(更新时间)2021年6月4日 商城高并发秒杀系统(.NET Core版) 30-lua文件封装加载和执行

一：lua文件的作用

二：lua文件定义和使用

三：使用

(更新时间)2021年6月4日 商城高并发秒杀系统(.NET Core版) 30-lua文件封装加载和执行相关推荐

最新文章

热门文章

(更新时间)2021年6月4日商城高并发秒杀系统(.NET Core版) 30-lua文件封装加载和执行

(更新时间)2021年6月4日商城高并发秒杀系统(.NET Core版) 30-lua文件封装加载和执行相关推荐