基于SpringBoot+Redis+Lua 实现高并发秒杀系统_Java

基于 springboot+redis+lua 构建高并发秒杀系统的设计思路，本文将聚焦核心代码实现，从环境配置、库存预热、lua 脚本、秒杀接口到异步下单、限流防护，完整呈现可直接落地的代码方案，帮你快速搭建稳定高效的秒杀系统。

一、环境准备与依赖配置

1. 项目依赖（pom.xml）

首先在 springboot 项目中引入核心依赖，包括 redis、消息队列（以 rabbitmq 为例）、springboot 核心组件等：

<!-- springboot核心依赖 -->
<dependency>
    <groupid>org.springframework.boot</groupid>
    <artifactid>spring-boot-starter-web</artifactid>
</dependency>
<dependency>
    <groupid>org.springframework.boot</groupid>
    <artifactid>spring-boot-starter-data-redis</artifactid>
</dependency>
<!-- 消息队列（rabbitmq） -->
<dependency>
    <groupid>org.springframework.boot</groupid>
    <artifactid>spring-boot-starter-amqp</artifactid>
</dependency>
<!-- lua脚本支持 -->
<dependency>
    <groupid>org.springframework.data</groupid>
    <artifactid>spring-data-redis</artifactid>
    <version>2.7.0</version>
</dependency>
<!-- 工具类 -->
<dependency>
    <groupid>cn.hutool</groupid>
    <artifactid>hutool-all</artifactid>
    <version>5.8.11</version>
</dependency>
<!--  lombok -->
<dependency>
    <groupid>org.projectlombok</groupid>
    <artifactid>lombok</artifactid>
    <optional>true</optional>
</dependency>

2. 核心配置（application.yml）

配置 redis、rabbitmq 连接信息，以及秒杀系统核心参数：

spring:
  # redis配置
  redis:
    host: 127.0.0.1
    port: 6379
    password: 123456
    database: 0
    lettuce:
      pool:
        max-active: 16  # 最大连接数
        max-idle: 8     # 最大空闲连接
        min-idle: 4     # 最小空闲连接
  # rabbitmq配置
  rabbitmq:
    host: 127.0.0.1
    port: 5672
    username: guest
    password: guest
    virtual-host: /
    listener:
      simple:
        acknowledge-mode: manual  # 手动ack确认
        concurrency: 5            # 消费者并发数

# 秒杀系统配置
seckill:
  redis:
    stock-key-prefix: "seckill:goods:"       # 商品库存key前缀
    user-key-prefix: "seckill:goods:users:"  # 已秒杀用户key前缀
  rabbitmq:
    queue-name: "seckill_order_queue"        # 订单消息队列名
    exchange-name: "seckill_order_exchange"  # 订单交换机名
    routing-key: "seckill.order"             # 路由键
  rate-limit:
    qps: 1000  # 全局限流qps

二、核心工具类与常量定义

1. 秒杀常量类（seckillconstant）

统一管理 redis 键前缀、消息队列参数等常量，避免硬编码：

import lombok.allargsconstructor;
import lombok.getter;

/**
 * 秒杀系统常量类
 */
@getter
@allargsconstructor
public class seckillconstant {
    // redis键前缀
    public static final string stock_key_prefix = "seckill:goods:";
    public static final string user_key_prefix = "seckill:goods:users:";
    public static final string request_id_key_prefix = "seckill:request:";
    
    // 秒杀结果状态码
    public static final int seckill_success = 1;  // 秒杀成功
    public static final int seckill_fail_stock = 0; // 库存不足
    public static final int seckill_fail_repeat = 2; // 重复秒杀
    
    // 消息队列参数
    public static final string order_queue_name = "seckill_order_queue";
    public static final string order_exchange_name = "seckill_order_exchange";
    public static final string order_routing_key = "seckill.order";
}

2. redis 工具类（redistemplateconfig）

配置 redistemplate，支持 string、hash 等数据结构操作，以及 lua 脚本执行：

import org.springframework.context.annotation.bean;
import org.springframework.context.annotation.configuration;
import org.springframework.data.redis.connection.redisconnectionfactory;
import org.springframework.data.redis.core.redistemplate;
import org.springframework.data.redis.serializer.genericjackson2jsonredisserializer;
import org.springframework.data.redis.serializer.stringredisserializer;

@configuration
public class redistemplateconfig {

    @bean
    public redistemplate<string, object> redistemplate(redisconnectionfactory factory) {
        redistemplate<string, object> template = new redistemplate<>();
        template.setconnectionfactory(factory);
        
        // string序列化器
        stringredisserializer stringserializer = new stringredisserializer();
        // json序列化器
        genericjackson2jsonredisserializer jsonserializer = new genericjackson2jsonredisserializer();
        
        // key使用string序列化
        template.setkeyserializer(stringserializer);
        template.sethashkeyserializer(stringserializer);
        
        // value使用json序列化
        template.setvalueserializer(jsonserializer);
        template.sethashvalueserializer(jsonserializer);
        
        template.afterpropertiesset();
        return template;
    }
}

三、库存预热实现（活动前数据加载）

秒杀活动开始前，将商品库存、活动状态从数据库加载到 redis，避免活动中频繁访问数据库：

1. 商品实体类（goodsdto）

import lombok.data;
import java.math.bigdecimal;
import java.util.date;

/**
 * 秒杀商品dto
 */
@data
public class goodsdto {
    private long goodsid;        // 商品id
    private string goodsname;    // 商品名称
    private bigdecimal seckillprice; // 秒杀价格
    private integer stock;       // 秒杀库存
    private date starttime;      // 活动开始时间
    private date endtime;        // 活动结束时间
    private integer status;      // 活动状态：0-未开始，1-进行中，2-已结束
}

2. 库存预热服务（stockwarmupservice）

import org.springframework.beans.factory.annotation.autowired;
import org.springframework.data.redis.core.redistemplate;
import org.springframework.stereotype.service;
import java.util.hashmap;
import java.util.map;

/**
 * 库存预热服务
 */
@service
public class stockwarmupservice {

    @autowired
    private redistemplate<string, object> redistemplate;

    /**
     * 预热单个商品库存到redis
     */
    public void warmupgoodsstock(goodsdto goodsdto) {
        if (goodsdto == null || goodsdto.getstock() <= 0) {
            throw new illegalargumentexception("商品信息或库存无效");
        }
        
        // 1. 存储商品库存和状态（hash结构）
        string stockkey = seckillconstant.stock_key_prefix + goodsdto.getgoodsid();
        map<string, object> goodsmap = new hashmap<>();
        goodsmap.put("stock", goodsdto.getstock());
        goodsmap.put("status", goodsdto.getstatus());
        goodsmap.put("starttime", goodsdto.getstarttime().gettime());
        goodsmap.put("endtime", goodsdto.getendtime().gettime());
        redistemplate.opsforhash().putall(stockkey, goodsmap);
        
        // 2. 初始化已秒杀用户集合（set结构，用于去重）
        string userkey = seckillconstant.user_key_prefix + goodsdto.getgoodsid();
        redistemplate.opsforset().add(userkey, new object[]{}); // 初始化空集合
    }

    /**
     * 批量预热商品库存（适用于多商品秒杀活动）
     */
    public void batchwarmupgoodsstock(java.util.list<goodsdto> goodsdtolist) {
        for (goodsdto goodsdto : goodsdtolist) {
            warmupgoodsstock(goodsdto);
        }
    }
}

3. 定时预热触发（可选）

通过定时任务在活动开始前 10 分钟自动预热库存：

import org.springframework.beans.factory.annotation.autowired;
import org.springframework.scheduling.annotation.scheduled;
import org.springframework.stereotype.component;
import java.util.list;

@component
public class seckillscheduledtask {

    @autowired
    private stockwarmupservice stockwarmupservice;
    @autowired
    private goodsmapper goodsmapper; // 自定义mapper，查询待秒杀商品

    /**
     * 每天00:00预热当天秒杀商品库存（可根据实际活动时间调整）
     */
    @scheduled(cron = "0 0 0 * * ?")
    public void scheduledwarmupstock() {
        list<goodsdto> seckillgoods = goodsmapper.selecttodayseckillgoods();
        stockwarmupservice.batchwarmupgoodsstock(seckillgoods);
    }
}

四、核心：lua 脚本实现原子扣减库存

通过 lua 脚本将 “库存检查、重复秒杀拦截、库存扣减” 封装为原子操作，从根本上解决并发冲突：

1. lua 脚本文件（seckill_stock.lua）

在resources/lua目录下创建 lua 脚本：

-- 传入参数：keys[1] = 商品id，argv[1] = 用户id
local goodsid = keys[1]
local userid = argv[1]

-- 定义redis键
local stockkey = "seckill:goods:" .. goodsid
local userkey = "seckill:goods:users:" .. goodsid

-- 1. 检查商品活动状态和库存
local goodsstatus = redis.call("hget", stockkey, "status")
if goodsstatus ~= "1" then
    return 3  -- 活动未开始或已结束
end

local stock = redis.call("hget", stockkey, "stock")
if not stock or tonumber(stock) <= 0 then
    return 0  -- 库存不足
end

-- 2. 检查用户是否已秒杀（避免重复下单）
if redis.call("sismember", userkey, userid) == 1 then
    return 2  -- 重复秒杀
end

-- 3. 原子扣减库存并记录用户
redis.call("hincrby", stockkey, "stock", -1)
redis.call("sadd", userkey, userid)

return 1  -- 秒杀成功

2. lua 脚本加载与执行服务（luascriptservice）

import org.springframework.core.io.classpathresource;
import org.springframework.data.redis.core.redistemplate;
import org.springframework.data.redis.core.script.defaultredisscript;
import org.springframework.scripting.support.staticscriptsource;
import org.springframework.stereotype.service;
import javax.annotation.postconstruct;
import java.util.collections;
import java.util.list;

/**
 * lua脚本执行服务
 */
@service
public class luascriptservice {

    @autowired
    private redistemplate<string, object> redistemplate;

    private defaultredisscript<integer> seckillstockscript;

    /**
     * 初始化加载lua脚本
     */
    @postconstruct
    public void initluascript() {
        seckillstockscript = new defaultredisscript<>();
        // 加载脚本文件
        seckillstockscript.setscriptsource(new staticscriptsource(
                new classpathresource("lua/seckill_stock.lua").getcontentasstring()
        ));
        // 设置返回值类型
        seckillstockscript.setresulttype(integer.class);
    }

    /**
     * 执行秒杀库存扣减脚本
     */
    public integer executeseckillscript(long goodsid, long userid) {
        list<string> keys = collections.singletonlist(goodsid.tostring());
        // 执行脚本：keys=商品id，args=用户id
        return redistemplate.execute(
                seckillstockscript,
                keys,
                userid.tostring()
        );
    }
}

五、秒杀接口实现（含限流、防重复提交）

1. 限流注解与 aop 实现（ratelimitaspect）

基于 redis 实现分布式限流，拦截超 qps 请求：

import cn.hutool.core.util.strutil;
import org.aspectj.lang.proceedingjoinpoint;
import org.aspectj.lang.annotation.around;
import org.aspectj.lang.annotation.aspect;
import org.aspectj.lang.annotation.pointcut;
import org.springframework.beans.factory.annotation.value;
import org.springframework.data.redis.core.redistemplate;
import org.springframework.data.redis.core.script.defaultredisscript;
import org.springframework.stereotype.component;
import javax.annotation.postconstruct;
import java.util.collections;

/**
 * 限流aop切面
 */
@aspect
@component
public class ratelimitaspect {

    @autowired
    private redistemplate<string, object> redistemplate;

    @value("${seckill.rate-limit.qps}")
    private int qps;

    private defaultredisscript<long> ratelimitscript;

    @postconstruct
    public void initratelimitscript() {
        // 令牌桶限流lua脚本
        string script = "local key = keys[1]\n" +
                        "local now = tonumber(argv[1])\n" +
                        "local qps = tonumber(argv[2])\n" +
                        "local window = 1\n" +  // 窗口时间1秒
                        "local maxtoken = qps\n" +
                        "local lasttime = redis.call('hget', key, 'lasttime')\n" +
                        "local tokencount = redis.call('hget', key, 'tokencount')\n" +
                        "if not lasttime or not tokencount then\n" +
                        "    redis.call('hset', key, 'lasttime', now)\n" +
                        "    redis.call('hset', key, 'tokencount', maxtoken - 1)\n" +
                        "    redis.call('expire', key, window)\n" +
                        "    return 1\n" +
                        "end\n" +
                        "local interval = now - tonumber(lasttime)\n" +
                        "local addtoken = math.floor(interval / 1000 * qps)\n" +
                        "tokencount = math.min(addtoken + tonumber(tokencount), maxtoken)\n" +
                        "if tokencount <= 0 then\n" +
                        "    return 0\n" +
                        "end\n" +
                        "redis.call('hset', key, 'lasttime', now)\n" +
                        "redis.call('hset', key, 'tokencount', tokencount - 1)\n" +
                        "return 1";
        
        ratelimitscript = new defaultredisscript<>(script, long.class);
    }

    // 定义限流注解切入点
    @pointcut("@annotation(com.seckill.annotation.ratelimit)")
    public void ratelimitpointcut() {}

    @around("ratelimitpointcut()")
    public object around(proceedingjoinpoint joinpoint) throws throwable {
        string key = "seckill:rate:limit:global"; // 全局限流key（可扩展为ip/用户维度）
        long now = system.currenttimemillis();
        long result = redistemplate.execute(
                ratelimitscript,
                collections.singletonlist(key),
                now.tostring(),
                string.valueof(qps)
        );
        
        if (result == 1) {
            return joinpoint.proceed(); // 获得令牌，执行方法
        } else {
            throw new runtimeexception("请求过于频繁，请稍后再试");
        }
    }
}

2. 防重复提交注解（repeatsubmit）

import java.lang.annotation.*;

@target(elementtype.method)
@retention(retentionpolicy.runtime)
@documented
public @interface repeatsubmit {
    // 防重复提交过期时间（默认5秒）
    int expireseconds() default 5;
}

3. 秒杀接口（seckillcontroller）

import cn.hutool.core.util.idutil;
import com.seckill.annotation.ratelimit;
import com.seckill.annotation.repeatsubmit;
import com.seckill.dto.seckillrequestdto;
import com.seckill.dto.seckillresponsedto;
import com.seckill.service.luascriptservice;
import com.seckill.service.ordermessageservice;
import com.seckill.service.stockwarmupservice;
import com.seckill.util.seckillconstant;
import org.springframework.beans.factory.annotation.autowired;
import org.springframework.data.redis.core.redistemplate;
import org.springframework.web.bind.annotation.postmapping;
import org.springframework.web.bind.annotation.requestbody;
import org.springframework.web.bind.annotation.requestmapping;
import org.springframework.web.bind.annotation.restcontroller;
import javax.validation.valid;
import java.util.objects;

/**
 * 秒杀接口
 */
@restcontroller
@requestmapping("/seckill")
public class seckillcontroller {

    @autowired
    private luascriptservice luascriptservice;
    @autowired
    private ordermessageservice ordermessageservice;
    @autowired
    private redistemplate<string, object> redistemplate;

    /**
     * 秒杀核心接口（含限流、防重复提交）
     */
    @postmapping("/doseckill")
    @ratelimit  // 限流注解
    @repeatsubmit(expireseconds = 5)  // 防重复提交（5秒内同一请求id不可重复提交）
    public seckillresponsedto doseckill(@valid @requestbody seckillrequestdto requestdto) {
        long goodsid = requestdto.getgoodsid();
        long userid = requestdto.getuserid();
        string requestid = requestdto.getrequestid(); // 前端生成的唯一请求id

        // 1. 防重复提交校验（基于redis缓存请求id）
        string requestkey = seckillconstant.request_id_key_prefix + requestid;
        boolean hasrequest = redistemplate.haskey(requestkey);
        if (boolean.true.equals(hasrequest)) {
            return seckillresponsedto.fail("请勿重复提交请求");
        }
        redistemplate.opsforvalue().set(requestkey, "1", 5); // 缓存5秒

        try {
            // 2. 执行lua脚本扣减库存
            integer seckillresult = luascriptservice.executeseckillscript(goodsid, userid);

            // 3. 处理秒杀结果
            if (seckillconstant.seckill_success == seckillresult) {
                // 秒杀成功，发送订单消息到消息队列
                ordermessageservice.sendordermessage(goodsid, userid);
                return seckillresponsedto.success("秒杀成功，正在创建订单...");
            } else if (seckillconstant.seckill_fail_stock == seckillresult) {
                return seckillresponsedto.fail("库存不足，秒杀失败");
            } else if (seckillconstant.seckill_fail_repeat == seckillresult) {
                return seckillresponsedto.fail("您已参与过该商品秒杀，请勿重复抢购");
            } else {
                return seckillresponsedto.fail("活动未开始或已结束");
            }
        } finally {
            // 4. 移除防重复提交缓存（可选，根据业务需求调整）
            redistemplate.delete(requestkey);
        }
    }
}

4. 秒杀请求 / 响应 dto

import lombok.data;
import javax.validation.constraints.notnull;

/**
 * 秒杀请求dto
 */
@data
public class seckillrequestdto {
    @notnull(message = "商品id不能为空")
    private long goodsid;

    @notnull(message = "用户id不能为空")
    private long userid;

    @notnull(message = "请求id不能为空")
    private string requestid; // 前端生成的唯一请求id，用于防重复提交
}

/**
 * 秒杀响应dto
 */
import lombok.allargsconstructor;
import lombok.data;
import lombok.noargsconstructor;

@data
@noargsconstructor
@allargsconstructor
public class seckillresponsedto {
    private int code; // 响应码：0-失败，1-成功
    private string message; // 响应消息

    public static seckillresponsedto success(string message) {
        return new seckillresponsedto(1, message);
    }

    public static seckillresponsedto fail(string message) {
        return new seckillresponsedto(0, message);
    }
}

六、消息队列异步下单实现

1. 订单消息实体（ordermessage）

import lombok.allargsconstructor;
import lombok.data;
import lombok.noargsconstructor;
import java.math.bigdecimal;

/**
 * 订单消息实体
 */
@data
@noargsconstructor
@allargsconstructor
public class ordermessage {
    private long orderid;        // 订单id（可在消息发送时生成）
    private long goodsid;        // 商品id
    private long userid;         // 用户id
    private bigdecimal seckillprice; // 秒杀价格
    private long createtime;     // 创建时间戳
}

2. 消息队列配置（rabbitmqconfig）

import org.springframework.amqp.core.binding;
import org.springframework.amqp.core.bindingbuilder;
import org.springframework.amqp.core.directexchange;
import org.springframework.amqp.core.queue;
import org.springframework.context.annotation.bean;
import org.springframework.context.annotation.configuration;

/**
 * rabbitmq配置
 */
@configuration
public class rabbitmqconfig {

    /**
     * 声明订单队列
     */
    @bean
    public queue orderqueue() {
        // 队列持久化
        return new queue(seckillconstant.order_queue_name, true);
    }

    /**
     * 声明订单交换机
     */
    @bean
    public directexchange orderexchange() {
        return new directexchange(seckillconstant.order_exchange_name, true, false);
    }

    /**
     * 绑定队列和交换机
     */
    @bean
    public binding orderbinding() {
        return bindingbuilder.bind(orderqueue())
                .to(orderexchange())
                .with(seckillconstant.order_routing_key);
    }
}

3. 订单消息发送服务（ordermessageservice）

import cn.hutool.core.util.idutil;
import com.seckill.dto.ordermessage;
import com.seckill.util.seckillconstant;
import org.springframework.amqp.rabbit.core.rabbittemplate;
import org.springframework.beans.factory.annotation.autowired;
import org.springframework.stereotype.service;
import java.math.bigdecimal;

/**
 * 订单消息发送服务
 */
@service
public class ordermessageservice {

    @autowired
    private rabbittemplate rabbittemplate;

    /**
     * 发送秒杀订单消息
     */
    public void sendordermessage(long goodsid, long userid) {
        // 生成订单id（雪花算法或uuid）
        long orderid = idutil.getsnowflake().nextid();
        
        // 构建订单消息
        ordermessage ordermessage = new ordermessage();
        ordermessage.setorderid(orderid);
        ordermessage.setgoodsid(goodsid);
        ordermessage.setuserid(userid);
        ordermessage.setseckillprice(new bigdecimal("99.00")); // 示例秒杀价格
        ordermessage.setcreatetime(system.currenttimemillis());

        // 发送消息到rabbitmq
        rabbittemplate.convertandsend(
                seckillconstant.order_exchange_name,
                seckillconstant.order_routing_key,
                ordermessage
        );
    }
}

4. 订单消息消费服务（orderconsumerservice）

import com.rabbitmq.client.channel;
import com.seckill.dto.ordermessage;
import com.seckill.mapper.ordermapper;
import com.seckill.pojo.order;
import com.seckill.util.seckillconstant;
import org.springframework.amqp.core.message;
import org.springframework.amqp.rabbit.annotation.rabbitlistener;
import org.springframework.beans.factory.annotation.autowired;
import org.springframework.data.redis.core.redistemplate;
import org.springframework.stereotype.service;
import java.io.ioexception;

/**
 * 订单消息消费服务（异步创建订单）
 */
@service
public class orderconsumerservice {

    @autowired
    private ordermapper ordermapper;
    @autowired
    private redistemplate<string, object> redistemplate;

    @rabbitlistener(queues = seckillconstant.order_queue_name)
    public void consumeordermessage(ordermessage ordermessage, channel channel, message message) throws ioexception {
        try {
            // 1. 校验消息合法性
            if (ordermessage == null || ordermessage.getgoodsid() == null || ordermessage.getuserid() == null) {
                channel.basicnack(message.getmessageproperties().getdeliverytag(), false, false);
                return;
            }

            // 2. 异步创建订单
            order order = new order();
            order.setorderid(ordermessage.getorderid());
            order.setgoodsid(ordermessage.getgoodsid());
            order.setuserid(ordermessage.getuserid());
            order.setseckillprice(ordermessage.getseckillprice());
            order.setcreatetime(ordermessage.getcreatetime());
            order.setstatus(0); // 0-待支付
            ordermapper.insert(order);

            // 3. 手动ack确认消息
            channel.basicack(message.getmessageproperties().getdeliverytag(), false);
        } catch (exception e) {
            // 4. 处理异常：消息重投或记录日志（根据业务需求调整）
            channel.basicnack(message.getmessageproperties().getdeliverytag(), false, true);
            // 回滚redis库存（补偿机制）
            rollbackstock(ordermessage.getgoodsid());
        }
    }

    /**
     * 订单创建失败，回滚redis库存
     */
    private void rollbackstock(long goodsid) {
        string stockkey = seckillconstant.stock_key_prefix + goodsid;
        redistemplate.opsforhash().increment(stockkey, "stock", 1);
    }
}

七、防重复提交 aop 实现（repeatsubmitaspect）

import org.aspectj.lang.proceedingjoinpoint;
import org.aspectj.lang.annotation.around;
import org.aspectj.lang.annotation.aspect;
import org.aspectj.lang.annotation.pointcut;
import org.springframework.beans.factory.annotation.autowired;
import org.springframework.data.redis.core.redistemplate;
import org.springframework.stereotype.component;
import com.seckill.annotation.repeatsubmit;
import com.seckill.dto.seckillrequestdto;
import java.util.objects;
import java.util.concurrent.timeunit;

/**
 * 防重复提交aop切面
 */
@aspect
@component
public class repeatsubmitaspect {

    @autowired
    private redistemplate<string, object> redistemplate;

    @pointcut("@annotation(repeatsubmit)")
    public void repeatsubmitpointcut(repeatsubmit repeatsubmit) {}

    @around("repeatsubmitpointcut(repeatsubmit)")
    public object around(proceedingjoinpoint joinpoint, repeatsubmit repeatsubmit) throws throwable {
        // 获取请求参数中的seckillrequestdto
        object[] args = joinpoint.getargs();
        seckillrequestdto requestdto = null;
        for (object arg : args) {
            if (arg instanceof seckillrequestdto) {
                requestdto = (seckillrequestdto) arg;
                break;
            }
        }

        if (requestdto == null || objects.isnull(requestdto.getrequestid())) {
            throw new illegalargumentexception("请求id不能为空");
        }

        // 构建请求key
        string requestkey = "seckill:request:" + requestdto.getrequestid();
        boolean haskey = redistemplate.haskey(requestkey);
        if (boolean.true.equals(haskey)) {
            throw new runtimeexception("请勿重复提交请求");
        }

        // 缓存请求id
        redistemplate.opsforvalue().set(requestkey, "1", repeatsubmit.expireseconds(), timeunit.seconds);
        try {
            return joinpoint.proceed();
        } finally {
            // 可根据业务需求决定是否移除缓存
            // redistemplate.delete(requestkey);
        }
    }
}

八、核心代码总结与部署建议

1. 代码核心亮点

原子性保障：通过 lua 脚本封装库存校验、扣减和用户去重，避免超卖与重复秒杀；
流量分层拦截：结合 redis 令牌桶限流、防重复提交 aop，从源头减少无效请求；
异步解耦：rabbitmq 异步处理订单创建，提升接口响应速度，降低数据库压力；
数据一致性：消息消费失败时回滚 redis 库存，确保缓存与数据库数据同步；
可扩展性：支持库存分片、预售模式等复杂场景扩展，适配不同业务需求。

2. 部署与测试建议

redis 部署：采用主从复制 + 哨兵模式，确保高可用；超大规模秒杀建议使用 redis cluster 分片存储库存；
消息队列：开启 rabbitmq 持久化与镜像队列，避免消息丢失；根据流量调整消费者并发数；
压力测试：使用 jmeter 模拟 10 万 + 并发请求，重点测试库存准确性、接口响应时间和系统稳定性；
监控告警：通过 prometheus+grafana 监控 redis 库存、消息队列堆积量、接口 qps 等核心指标，设置阈值告警。

本文完整呈现了 springboot+redis+lua 秒杀系统的核心代码，覆盖从库存预热到异步下单的全流程，代码可直接复制到项目中使用，只需根据实际业务调整参数与扩展功能。

到此这篇关于基于springboot+redis+lua 实现高并发秒杀系统的文章就介绍到这了,更多相关springboot redis lua高并发秒杀内容请搜索代码网以前的文章或继续浏览下面的相关文章希望大家以后多多支持代码网！

基于SpringBoot+Redis+Lua 实现高并发秒杀系统

2026年01月25日 • Java •我要评论