当前位置：首页 > news >正文

秒杀系统主库宕机不丢单方案-05-Redis预扣+消息队列

news 2026/6/10 22:19:55

秒杀系统主库宕机不丢单方案：Redis预扣+消息队列（流量削峰）

方案概述

Redis预扣+消息队列方案通过在应用层引入Redis缓存和消息队列，实现流量削峰和数据持久化分离。该方案从源头减少对数据库的压力，是秒杀系统主库宕机不丢单的源头减压方案。

核心原理

1. 整体架构

2. 工作流程

Redis预扣: 用户请求先在Redis中预扣库存
消息入队: 预扣成功后，将订单信息放入消息队列
异步处理: 消费者从队列中取出消息并处理
数据库持久化: 将订单数据持久化到数据库
补偿机制: Redis和数据库数据不一致时进行补偿

3. 关键组件

Redis: 用于库存预扣和热点数据缓存
消息队列: 用于流量削峰和异步处理
补偿服务: 用于数据一致性保障

实战配置

1. Redis预扣库存

@ServicepublicclassSeckillService{@AutowiredprivateRedisTemplate<String,String>redisTemplate;@AutowiredprivateMessageQueuemessageQueue;publicbooleanpreDeductStock(LongproductId,Integerquantity){// Redis预扣库存StringstockKey="stock:"+productId;StringcurrentStock=redisTemplate.opsForValue().get(stockKey);if(currentStock==null||Integer.parseInt(currentStock)<quantity){returnfalse;}// 执行预扣Longremaining=redisTemplate.opsForValue().decrement(stockKey,quantity);if(remaining>=0){// 入队处理SeckillOrderorder=newSeckillOrder(productId,quantity);messageQueue.send(order);returntrue;}else{// 库存不足，回滚redisTemplate.opsForValue().increment(stockKey,quantity);returnfalse;}}}

2. 消息队列配置

@ConfigurationpublicclassMessageQueueConfig{@BeanpublicQueueseckillQueue(){returnnewQueue("seckill_queue",true);}@BeanpublicMessageSendermessageSender(){returnnewMessageSender();}}@ServicepublicclassMessageSender{@AutowiredprivateAmqpTemplaterabbitTemplate;publicvoidsend(SeckillOrderorder){rabbitTemplate.convertAndSend("seckill_exchange","seckill_routing_key",order);}}

3. 消费者处理

@ComponentpublicclassSeckillConsumer{@AutowiredprivateOrderServiceorderService;@RabbitListener(queues="seckill_queue")publicvoidhandleSeckillOrder(SeckillOrderorder){try{// 数据库持久化orderService.createOrder(order);}catch(Exceptione){// 记录失败，后续补偿compensationService.recordFailedOrder(order);}}}

4. 补偿机制

@ServicepublicclassCompensationService{@AutowiredprivateRedisTemplate<String,String>redisTemplate;@AutowiredprivateOrderDaoorderDao;@Scheduled(fixedDelay=60000)publicvoidcompensateOrders(){List<SeckillOrder>failedOrders=orderDao.selectFailedOrders();for(SeckillOrderorder:failedOrders){try{// 重新处理订单orderService.createOrder(order);// 标记为已处理orderDao.updateOrderStatus(order.getId(),"COMPLETED");}catch(Exceptione){// 继续保留失败状态，等待下次重试}}}}

优缺点分析

优点

流量削峰: Redis缓存有效减少数据库压力
性能提升: 读写分离，提高系统吞吐量
容灾能力强: Redis和数据库分离，单点故障影响小
扩展性好: 支持水平扩展

缺点

数据一致性: 需要补偿机制保证最终一致性
实现复杂: 需要多个组件协同工作
运维成本: 需要维护Redis和消息队列

适用场景

超高并发秒杀系统: 并发量在50000+ QPS
读多写少场景: 如商品库存查询、订单创建
已有缓存和消息队列基础设施

实战案例

某手机厂商新品秒杀活动

场景: 新品发布会，预计并发量100000 QPS
配置:
- Redis集群预扣库存
- RabbitMQ消息队列
- 5个消费者节点
- 补偿机制重试3次
效果:
- 零数据丢失，成功保障订单不丢单
- 平均响应时间50ms
- 系统吞吐量90000 QPS
- Redis命中率99.9%

最佳实践

Redis集群: 使用Redis Cluster提高可用性和性能
消息持久化: 确保消息队列支持持久化
幂等设计: 确保消息处理的幂等性
监控告警: 建立全面的监控体系

Redis集群配置示例

# redis.confcluster-enabled yes cluster-config-file nodes.conf cluster-node-timeout 5000 appendonly yes appendfsync everysec

监控指标

-- Redis监控INFO memory INFOreplicationINFO cluster-- 消息队列监控rabbitmqctl list_queues name messages_ready messages_unacknowledged-- 数据库监控SHOWGLOBALSTATUSLIKE'Innodb_%';