• 10万QPS高并发请求,如何防止重复下单

10万QPS高并发请求,如何防止重复下单

2025-04-27 10:39:45 栏目:宝塔面板 22 阅读

前言 

大家好,我是田螺。

星球粉丝分享了一道面试题:10万QPS高并发请求,如何防止重复下单。本文田螺哥从面试的角度,跟大家一起探讨一下,从前端到后端,全链路,一层层递进探讨!

1. 前端拦截 

首先因为是10万QPS的高并发请求,我们要保护好系统,那就是尽可能减少用户无效请求。

1.1 按钮置灰

很多用户抢票、抢购、抢红包等时候,为了提高抢中的概率,都是疯狂点击按钮。会触发多次请求,导致重复下单。

因此,在用户点击过抢购按钮后,我们可以给按钮置灰,不让用户重复点击。

const submitButton = document.getElementById('submit-order');
submitButton.disabled = true;  // 禁用按钮
// 提交订单的异步操作
submitOrder().then(response => {
  submitButton.disabled = false;  // 请求完成后恢复按钮
}).catch(error => {
  submitButton.disabled = false;  // 请求失败也恢复按钮
});

如果你的系统希望设计得友好一点,可以前端提示个文案,比如:已经收到你的请求,请耐心等待抢购结果。

1.2 Token机制

  • 前端加载页面的时候,获取一个全局唯一标记的token,如UUID。
  • 在表单提交时,用该Token来标识该请求。每次请求都附带该Token,后端验证Token是否唯一。如果已提交过该Token的请求,则直接返回错误或无效响应,防止重复提交。

2.后端设计 

2.1 NGINX 限流

请求从前端到后端,首先是先到nginx ,我们可以在nginx做一下限流。

因为有些用户不怀好意,通过脚本绕过前端,疯狂请求。这类用户的IP和用户ID,我们都可以做一下限流的限制的。

一个Nginx限流配置:

http {
    # 核心配置:IP+用户ID双因子限流 (按业务需求二选一)
    
    ## 选项1:基础版(纯IP限制)
    limit_req_zone $binary_remote_addr zone=order_base:10m rate=3r/m;  # 每IP每分钟3次

    ## 选项2:增强版(IP+用户ID,需前端传递UserID)
    limit_req_zone $binary_remote_addr$http_user_id zone=order_enhanced:20m rate=5r/m;

    server {
        listen 80;
        server_name tianluoboy.com;

        # 订单提交接口
        location = /v1/order/create {
            # 启用限流(示例用增强版)
            limit_req zone=order_enhanced burst=3 nodelay;  
            
            # 返回429时强制JSON响应
            error_page 429 @toofast;
            location @toofast {
                default_type application/json;
                return 200 '{"code":429,"msg":"操作过于频繁,请稍后再试"}';
            }

            # 反向代理到业务服务器
            proxy_pass http://order_backend;
        }

        # 其他接口不限流
        location / {
            proxy_pass http://default_backend;
        }
    }
}

2.2 网关(Spring Cloud Gateway)

网关层可以做的事情很多,比如

Token 校验:在网关层拦截请求,验证 Token 是否在 Redis 中存在.

// 伪代码示例:网关过滤器校验 Token
if (redis.get(token) != null) {
    return error("重复请求");
} else {
    redis.setex(token, 60, "1"); // Token 有效期 60 秒
    //请求到后台
    passToBackend();
}

当然,网关也可以做限流的:

  • 令牌桶算法:通过Redis + Lua 实现集群级限流(如 redis-cell 模块)。
  • 用户维度限流:基于用户 ID或设备指纹限制并发请求数。

网关层可以做一下请求排队:

  • 对高并发请求放到消息队列,削峰填谷(如 Kafka/RabbitMQ)

图片

2.3 幂等设计

下单业务接口,我们一般要做幂等的。

一般用唯一索引做幂等设计。

唯一索引:比如使用用户ID + 商品ID + 时间戳组合生成唯一订单号。

一般的幂等处理就是这样啦,如下:

图片

2.4 分库分表

分库分表:按用户 ID 分片,分散写压力,避免单表成为瓶颈。

当业务量暴增的话,MySQL单机磁盘容量会撑爆。并且,我们知道数据库连接数是有限的。在高并发的场景下,大量请求访问数据库,MySQL单机是扛不住的!高并发场景下,会出现too many connections报错。

所以高并发的系统,需要考虑拆分为多个数据库,来抗住高并发的毒打。而假如你的单表数据量非常大,存储和查询的性能就会遇到瓶颈了,如果你做了很多优化之后还是无法提升效率的时候,就需要考虑做分表了。一般千万级别数据量,就需要分表,每个表的数据量少一点,提升SQL查询性能。

2.5 分布式锁

既然是防止重复下单,一般都需要加Redis分布式锁的。

// 伪代码:Redisson 分布式锁
RLock lock = redisson.getLock("order:lock:" + userId);
if (lock.tryLock(0, 30, TimeUnit.SECONDS)) {
    try {
        createOrder();
    } finally {
        lock.unlock();
    }
}

2.6 乐观锁兜底

如果分布式锁失效了呢?怎么办呢?

我们可以加数据库乐观锁兜底。比如

  • 在数据订单表中添加 version 字段,每次更新都version+1,更新时校验版本号
  • 通过原子操作 UPDATE ... SET versinotallow=version+1 WHERE order_id=xx AND versinotallow=old_version实现

2.7 日志与监控

要打印好日志,和做好监控指标,如果发现日志或者监控异常,可以快速介入排查~

打印日志也有坑:

图片

有需要的伙伴可以购买我的踩坑专栏哈:血与泪的教训,盘点我工作七年所踩的坑(更新到90篇啦~)

2.8 核对数据

我们要做好核对数据,比如做个定时任务,核对订单数据和交易金额是否对得上,如果发现数据异常,就人工快速介入排查和修复。

本文地址:https://www.yitenyun.com/148.html

搜索文章

Tags

数据库 API FastAPI Calcite 电商系统 MySQL 数据同步 ACK 双主架构 循环复制 Web 应用 异步数据库 生命周期 序列 核心机制 Deepseek 宝塔面板 Linux宝塔 Docker JumpServer JumpServer安装 堡垒机安装 Linux安装JumpServer esxi esxi6 root密码不对 无法登录 web无法登录 Windows Windows server net3.5 .NET 安装出错 宝塔面板打不开 宝塔面板无法访问 SSL 堡垒机 跳板机 HTTPS Windows宝塔 Mysql重置密码 无法访问宝塔面板 HTTPS加密 查看硬件 Linux查看硬件 Linux查看CPU Linux查看内存 ES 协同 修改DNS Centos7如何修改DNS scp Linux的scp怎么用 scp上传 scp下载 scp命令 防火墙 服务器 黑客 Serverless 无服务器 语言 存储 Oracle 处理机制 Spring SQL 动态查询 Linux 安全 网络架构 工具 网络配置 加密 场景 MySQL 9.3 开源 PostgreSQL 存储引擎 RocketMQ 长轮询 配置 HexHub Canal Rsync 架构 InnoDB 缓存方案 缓存架构 缓存穿透 信息化 智能运维 响应模型 日志文件 MIXED 3 线上 库存 预扣 索引 数据 业务 AI 助手 数据库锁 监控 聚簇 非聚簇 B+Tree ID 字段 单点故障 云原生 GreatSQL Hash 字段 分库 分表 优化 万能公式 Redis Redis 8.0 openHalo OB 单机版 DBMS 管理系统 SpringAI 自定义序列化 数据集成工具 SQLite Redka ​Redis 机器学习 推荐模型 SVM Embedding PostGIS 系统 SQLark 虚拟服务器 虚拟机 内存 分页查询 Netstat Linux 服务器 端口 排行榜 排序 自动重启 运维 sqlmock sftp 服务器 参数 • 索引 • 数据库 RDB AOF 技术 Testcloud 云端自动化 查询 EasyExcel MySQL8 prometheus Alert SQLite-Web 数据库管理工具 同城 双活 缓存 聚簇索引 非聚簇索引 共享锁 OAuth2 Token Entity 开发 StarRocks 数据仓库 向量数据库 大模型 IT 不宕机 数据备份 容器化 Postgres OTel Iceberg 分布式架构 分布式锁​ 数据类型 Doris SeaTunnel 人工智能 推荐系统 IT运维 分页 数据结构 连接控制 机制 AIOPS MongoDB 容器 悲观锁 乐观锁 Caffeine CP Python Web 部署 LRU Milvus 向量库 Ftp 池化技术 连接池 redo log 重做日志 崖山 新版本 高可用 mini-redis INCR指令 MVCC 事务隔离 磁盘架构 流量 MCP 单线程 线程 速度 服务器中毒 开放协议 Web 接口 字典 电商 QPS 高并发 原子性 对象 微软 SQL Server AI功能 数据脱敏 加密算法 R2DBC 双引擎 RAG HelixDB 主库 Order 窗口 函数 ZODB SSH 网络 频繁 Codis Crash 代码 1 PG DBA 工具链 引擎 性能 List 类型 dbt 数据转换工具 优化器 Pottery 发件箱模式 意向锁 记录锁 InfluxDB 模型 传统数据库 向量化 事务同步 网络故障 UUIDv7 主键 仪表盘 Redisson 锁芯 线程安全 INSERT COMPACT Undo Log LLM JOIN 连接数 订单