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

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

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

前言 

大家好,我是田螺。

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