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

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

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

前言 

大家好,我是田螺。

星球粉丝分享了一道面试题: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 Web 应用 异步数据库 数据同步 ACK 双主架构 循环复制 JumpServer SSL 堡垒机 跳板机 HTTPS TIME_WAIT 运维 负载均衡 HexHub Docker JumpServer安装 堡垒机安装 Linux安装JumpServer Deepseek 宝塔面板 Linux宝塔 生命周期 esxi esxi6 root密码不对 无法登录 web无法登录 服务器 管理口 序列 核心机制 HTTPS加密 Windows Windows server net3.5 .NET 安装出错 服务器性能 查看硬件 Linux查看硬件 Linux查看CPU Linux查看内存 宝塔面板打不开 宝塔面板无法访问 开源 PostgreSQL 存储引擎 Windows宝塔 Mysql重置密码 Oracle 处理机制 无法访问宝塔面板 连接控制 机制 InnoDB 数据库锁 监控 Serverless 无服务器 语言 Spring Redis 异步化 ES 协同 技术 Undo Log group by 索引 SQL 优化 万能公式 分页查询 缓存方案 缓存架构 缓存穿透 高可用 动态查询 GreatSQL 连接数 机器学习 工具 响应模型 查询 日志文件 MIXED 3 scp Linux的scp怎么用 scp上传 scp下载 scp命令 R edis 线程 SVM Embedding 加密 场景 R2DBC 锁机制 数据 主库 Netstat Linux 服务器 端口 openHalo Linux 安全 Postgres OTel Iceberg RocketMQ 长轮询 配置 云原生 自定义序列化 存储 AI 助手 ​Redis 推荐模型 SQLite-Web SQLite 数据库管理工具 Recursive SQLark 共享锁 Hash 字段 向量数据库 大模型 PG DBA Ftp 电商 系统 OB 单机版 国产数据库 架构 启动故障 MySQL 9.3 修改DNS Centos7如何修改DNS 人工智能 推荐系统 数据分类 • 索引 • 数据库 业务 磁盘架构 流量 Rsync sftp 服务器 参数 防火墙 黑客 线上 库存 预扣 redo log 重做日志 分库 分表 同城 双活 信息化 智能运维 Python 向量库 Milvus mini-redis INCR指令 MVCC 不宕机 聚簇 非聚簇 传统数据库 向量化 Canal 高效统计 今天这篇文章就跟大家 PostGIS 行业 趋势 INSERT COMPACT Doris SeaTunnel 缓存 Redisson 锁芯 网络架构 网络配置 prometheus Alert 数据备份 虚拟服务器 虚拟机 内存 filelock 事务 Java 开发 语句 Web 窗口 函数 ZODB RDB AOF 引擎 性能 数据脱敏 加密算法 MongoDB 数据结构 读写 容器 IT运维 核心架构 订阅机制 Go 数据库迁移 失效 OAuth2 Token 自动重启 数据类型 频繁 Codis B+Tree ID 字段 模型 崖山 新版本 Redis 8.0 发件箱模式 容器化 分布式 集中式 SSH 网络故障 微软 SQL Server AI功能 MCP 开放协议 DBMS 管理系统 聚簇索引 非聚簇索引 QPS 高并发 播客 SpringAI 数据集成工具 Web 接口 部署 Entity 数据页 JOIN 排行榜 排序 速度 服务器中毒 Caffeine CP 网络 原子性 Testcloud 云端自动化 池化技术 连接池 Pottery StarRocks 数据仓库 工具链 Redka 主从复制 代理 事务隔离 分布式架构 分布式锁​ 分页方案 排版 1 大表 业务场景 dbt 数据转换工具 悲观锁 乐观锁 LRU 分页 单点故障 AIOPS 日志 优化器 EasyExcel MySQL8 意向锁 记录锁 仪表盘 sqlmock Order 事务同步 数据字典 兼容性 InfluxDB 对象 单线程 UUIDv7 主键 ReadView RAG HelixDB Ansible UUID ID Crash 代码 订单 IT 双引擎 LLM 字典 Weaviate 产业链 编程 Valkey Valkey8.0 恢复数据 千万级 线程安全 MGR 分布式集群 分布式锁 Zookeeper Pump List 类型 关系数据库 拦截器 动态代理 Next-Key 表空间 解锁 调优 慢SQL优化 快照读 当前读 视图 国产 用户 RR 互联网 GitHub Git 神经系统 矢量存储 数据库类型 AI代理 算法 查询规划 count(*) count(主键) 行数 技巧 CAS 并发控制 恢复机制 多线程 闪回