百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 技术教程 > 正文

阿里P8亲授:分布式锁+Redis秒杀系统设计,吞吐量提升10倍!

mhr18 2025-05-03 15:25 33 浏览 0 评论


一、超卖问题的本质:高并发下的原子性缺失

在秒杀场景中,超卖(库存扣减至负数)和超买(用户重复购买)的核心问题源于非原子性操作。例如,当多个线程同时查询库存并执行扣减时,传统数据库的“查询-判断-扣减”三步操作可能被并发请求打乱,导致库存逻辑错误(如剩余库存为1时被多个线程同时判定为可购买)。

案例模拟:某电商平台推出100件商品秒杀,瞬间涌入1万请求。假设库存存储于MySQL,若未加锁,多个线程可能同时查询到剩余库存为1,均执行扣减,最终库存变为-99,导致超卖。


二、Redis分布式锁:秒杀系统的核心防线

1. 分布式锁的核心要求

  • 互斥性:同一时刻仅一个线程持有锁。
  • 防死锁:锁需设置超时时间,避免线程崩溃导致锁永久占用。
  • 原子性:锁的获取和释放必须是原子操作(如Lua脚本实现)。

2. Redis实现分布式锁的三种方案

方案一:SETNX + EXPIRE(基础版)

// 加锁
Boolean lock = redisTemplate.opsForValue().setIfAbsent("lock:product_001", "uuid", 10, TimeUnit.SECONDS);
if (lock) {
    try {
        // 业务逻辑(扣减库存)
    } finally {
        // 释放锁时需校验UUID,防止误删其他线程的锁
        if ("uuid".equals(redisTemplate.opsForValue().get("lock:product_001"))) {
            redisTemplate.delete("lock:product_001");
        }
    }
}

缺陷:SETNX和EXPIRE非原子操作,可能因线程崩溃导致死锁。

方案二:Lua脚本(原子操作版)

-- 扣减库存的Lua脚本
local stock = tonumber(redis.call('GET', KEYS[1]))
if stock > 0 then
    redis.call('DECR', KEYS[1])
    return 1  -- 扣减成功
else
    return 0  -- 库存不足
end

通过Redis单线程特性,保证操作的原子性,避免超卖。

方案三:RedLock(高可用版)

在Redis主从架构下,为避免主节点宕机导致锁失效,使用RedLock算法(需部署多个独立Redis实例):

// Redisson实现RedLock
RLock lock1 = redisson.getLock("lock:product_001");
RLock lock2 = redisson.getLock("lock:product_001");
RLock lock3 = redisson.getLock("lock:product_001");
RedissonRedLock redLock = new RedissonRedLock(lock1, lock2, lock3);
redLock.lock();
try {
    // 扣减库存
} finally {
    redLock.unlock();
}

RedLock通过半数以上节点加锁成功来保证高可用性。


三、实战:Redis秒杀系统设计(吞吐量提升10倍的关键)

1. 架构设计

  • 流量分层:前端用Nginx+Lua限流,拦截90%无效请求。
  • 库存预热:活动开始前将库存加载至Redis(如stock:product_001=100)。
  • 异步下单:扣减库存后发送MQ消息,由消费者异步处理订单和数据库更新,缓解数据库压力。

2. 核心代码实现(Spring Boot + RedisTemplate)

@RestController
public class SeckillController {

    @Autowired
    private StringRedisTemplate redisTemplate;

    @PostMapping("/seckill")
    public String seckill(@RequestParam String productId) {
        String stockKey = "stock:" + productId;
        String lockKey = "lock:" + productId;
        String uuid = UUID.randomUUID().toString();

        // 获取分布式锁(设置10秒超时)
        Boolean locked = redisTemplate.opsForValue().setIfAbsent(lockKey, uuid, 10, TimeUnit.SECONDS);
        if (locked != null && locked) {
            try {
                // Lua脚本原子扣减库存
                String script = "local stock = tonumber(redis.call('GET', KEYS[1])) " +
                                "if stock > 0 then redis.call('DECR', KEYS[1]) return 1 else return 0 end";
                Long result = redisTemplate.execute(
                    new DefaultRedisScript<>(script, Long.class),
                    Collections.singletonList(stockKey)
                );
                if (result == 1) {
                    // 发送MQ消息,异步创建订单
                    return "秒杀成功!";
                } else {
                    return "库存不足!";
                }
            } finally {
                // 释放锁时校验UUID
                if (uuid.equals(redisTemplate.opsForValue().get(lockKey))) {
                    redisTemplate.delete(lockKey);
                }
            }
        }
        return "系统繁忙,请重试!";
    }
}

四、性能优化:从千级到万级并发的跨越

1. 分段锁:提升并发粒度

将库存拆分为多个Key(如stock:product_001_1到stock:product_001_10),每个Key对应10件库存。线程随机选择分段扣减,并发能力提升10倍。

2. 主从架构下的锁失效问题

Redis主从同步存在延迟,若主节点宕机,可能导致锁丢失。解决方案:

  • 使用RedLock(需部署多实例)。
  • ZooKeeper替代(CP模型,但性能较低)。

3. 熔断降级

通过Sentinel或Hystrix监控系统负载,当库存耗尽或Redis异常时,直接返回“已售罄”,避免无效请求冲击。


五、总结:秒杀系统的核心公式

高性能秒杀 = 流量分层 + 原子操作 + 异步处理 + 熔断降级
通过Redis分布式锁和Lua脚本,结合分段锁与RedLock,可实现万级TPS的秒杀系统。实际落地中需根据业务规模选择方案:小规模场景用Lua脚本+单Redis,大规模高可用场景用RedLock+分段锁。


实战建议:在阿里云等生产环境中,建议使用Tair(阿里云版Redis)或Redisson封装分布式锁,避免重复造轮子。若追求极致性能,可结合本地缓存(如Guava)减少Redis访问频率。

相关推荐

SpringBoot 各种分页查询方式详解(全网最全)

一、分页查询基础概念与原理1.1什么是分页查询分页查询是指将大量数据分割成多个小块(页)进行展示的技术,它是现代Web应用中必不可少的功能。想象一下你去图书馆找书,如果所有书都堆在一张桌子上,你很难...

《战场兄弟》全事件攻略 一般事件合同事件红装及隐藏职业攻略

《战场兄弟》全事件攻略,一般事件合同事件红装及隐藏职业攻略。《战场兄弟》事件奖励,事件条件。《战场兄弟》是OverhypeStudios制作发行的一款由xcom和桌游为灵感来源,以中世纪、低魔奇幻为...

LoadRunner(loadrunner录制不到脚本)

一、核心组件与工作流程LoadRunner性能测试工具-并发测试-正版软件下载-使用教程-价格-官方代理商的架构围绕三大核心组件构建,形成完整测试闭环:VirtualUserGenerator(...

Redis数据类型介绍(redis 数据类型)

介绍Redis支持五种数据类型:String(字符串),Hash(哈希),List(列表),Set(集合)及Zset(sortedset:有序集合)。1、字符串类型概述1.1、数据类型Redis支持...

RMAN备份监控及优化总结(rman备份原理)

今天主要介绍一下如何对RMAN备份监控及优化,这里就不讲rman备份的一些原理了,仅供参考。一、监控RMAN备份1、确定备份源与备份设备的最大速度从磁盘读的速度和磁带写的带度、备份的速度不可能超出这两...

备份软件调用rman接口备份报错RMAN-06820 ORA-17629 ORA-17627

一、报错描述:备份归档报错无法连接主库进行归档,监听问题12541RMAN-06820:WARNING:failedtoarchivecurrentlogatprimarydatab...

增量备份修复物理备库gap(增量备份恢复数据库步骤)

适用场景:主备不同步,主库归档日志已删除且无备份.解决方案:主库增量备份修复dg备库中的gap.具体步骤:1、停止同步>alterdatabaserecovermanagedstand...

一分钟看懂,如何白嫖sql工具(白嫖数据库)

如何白嫖sql工具?1分钟看懂。今天分享一个免费的sql工具,毕竟现在比较火的NavicatDbeaverDatagrip都需要付费才能使用完整功能。幸亏今天有了这款SQLynx,它不仅支持国内外...

「开源资讯」数据管理与可视化分析平台,DataGear 1.6.1 发布

前言数据齿轮(DataGear)是一款数据库管理系统,使用Java语言开发,采用浏览器/服务器架构,以数据管理为核心功能,支持多种数据库。它的数据模型并不是原始的数据库表,而是融合了数据库表及表间关系...

您还在手工打造增删改查代码么,该神器带你脱离苦海

作为Java开发程序,日常开发中,都会使用Spring框架,完成日常的功能开发;在相关业务系统中,难免存在各种增删改查的接口需求开发。通常来说,实现增删改查有如下几个方式:纯手工打造,编写各种Cont...

Linux基础知识(linux基础知识点及答案)

系统目录结构/bin:命令和应用程序。/boot:这里存放的是启动Linux时使用的一些核心文件,包括一些连接文件以及镜像文件。/dev:dev是Device(设备)的缩写,该目录...

PL/SQL 杂谈(二)(pl/sql developer使用)

承接(一)部分。我们从结构和功能这两个方面展示PL/SQL的关键要素。可以看看PL/SQL的优雅的代码。写出一个好的代码,就和文科生写出一篇优秀的作文一样,那么赏心悦目。1、与SQL的集成PL/S...

电商ERP系统哪个好用?(电商erp哪个好一点)

电商ERP系统哪个好用?做电商的,谁还没被ERP折腾过?有老板说:“我们早就上了ERP,订单、库存、财务全搞定,系统用得飞起。”也有运营吐槽:“系统是上了,可库存老不准,订单漏单错单天天有,财务对账还...

汽车检测线系统实例,看集中控制与PLC分布控制

PLC可编程控制器,上个世纪70年代初,为取代早期继电器控制线路,开始采取存储指令方式,完成顺序控制而设计的。开始仅有逻辑运算、计时、计数等简单功能。随着微处理的发展,PLC可编程能力日益提高,已经能...

苹果五件套成公司年会奖品主角,几大小技巧教你玩转苹果新品

钱江晚报·小时新闻记者张云山随着春节的临近,各家大公司的年会又将陆续上演。上周,各大游戏公司的年会大奖,苹果五件套又成了标配。在上海的游戏公司中,莉莉丝奖品列表拉得相当长,从特等奖到九等奖还包含了特...

取消回复欢迎 发表评论: