秒杀系统高并发难题：Redis 分片集群与 Sentinel 熔断架构实战

wen5g3qx

321人浏览 · 2026-05-13 18:03:44

wen5g3qx · 2026-05-13 18:03:44 发布

秒杀系统面对的典型问题是瞬间涌入的大量请求，对后端服务造成巨大压力。尤其是在 Redis 这种常用的缓存系统中，如果数据量过大或者并发量过高，单个 Redis 实例很容易成为瓶颈，导致缓存雪崩、击穿等问题，最终引发整个秒杀系统崩溃。传统的单机 Redis 架构在应对高并发的秒杀场景时显得力不从心。我们需要更具扩展性和稳定性的方案。这就是秒杀系统崩溃？Redis分片 Sentinel熔断架构设计需要解决的核心问题。

单机 Redis 的局限性

单机 Redis 的性能瓶颈主要体现在以下几个方面：

容量限制：单个 Redis 实例的内存容量有限，无法存储海量数据。
并发限制：单个 Redis 实例的处理能力有限，无法承受高并发请求。
可用性风险：单点故障会导致整个缓存服务不可用。

突破瓶颈：Redis 分片集群

为了解决单机 Redis 的局限性，我们可以采用 Redis 分片集群方案。分片集群将数据分散存储在多个 Redis 节点上，每个节点只负责存储一部分数据，从而提高整体的存储容量和并发处理能力。

常见的 Redis 分片策略包括：

哈希取模：将 key 的哈希值对节点数量取模，根据结果选择对应的节点。
一致性哈希：将节点和 key 都映射到一个环上，key 顺时针找到的第一个节点即为目标节点。
范围分区：将 key 的范围划分成多个区间，每个区间对应一个节点。

Redis Cluster 提供了原生的分片集群支持，它采用哈希槽（hash slot）的方式进行数据分片。Redis Cluster 将整个 key 空间划分为 16384 个槽，每个节点负责存储一部分槽的数据。

保证高可用：Sentinel 熔断机制

仅仅使用 Redis 分片集群还不够，我们需要考虑节点故障的情况。Sentinel 是 Redis 官方提供的高可用解决方案，它可以监控 Redis 节点的运行状态，并在节点故障时自动进行故障转移。

Sentinel 的主要功能包括：

监控：定期检查 Redis 节点的运行状态。
通知：当 Redis 节点出现故障时，通知客户端。
自动故障转移：当主节点故障时，自动将一个从节点提升为主节点。

除了 Sentinel 的自动故障转移功能，我们还可以引入熔断机制，防止因 Redis 集群不稳定导致服务雪崩。熔断器可以在 Redis 服务出现异常时，快速阻断请求，避免对 Redis 集群造成更大的压力。

Redis 分片 Sentinel 熔断架构落地实践

搭建 Redis 分片集群

以下是一个简单的 Redis Cluster 搭建示例（使用 Docker）：

# 创建 Docker 网络docker network create redis-cluster# 启动 Redis 节点docker run -d --net redis-cluster --name redis1 -p 7001:7001 redis redis-server --cluster-enabled yes --cluster-config-file node1.conf --cluster-node-timeout 5000 --appendonly yesdocker run -d --net redis-cluster --name redis2 -p 7002:7002 redis redis-server --cluster-enabled yes --cluster-config-file node2.conf --cluster-node-timeout 5000 --appendonly yesdocker run -d --net redis-cluster --name redis3 -p 7003:7003 redis redis-server --cluster-enabled yes --cluster-config-file node3.conf --cluster-node-timeout 5000 --appendonly yesdocker run -d --net redis-cluster --name redis4 -p 7004:7004 redis redis-server --cluster-enabled yes --cluster-config-file node4.conf --cluster-node-timeout 5000 --appendonly yesdocker run -d --net redis-cluster --name redis5 -p 7005:7005 redis redis-server --cluster-enabled yes --cluster-config-file node5.conf --cluster-node-timeout 5000 --appendonly yesdocker run -d --net redis-cluster --name redis6 -p 7006:7006 redis redis-server --cluster-enabled yes --cluster-config-file node6.conf --cluster-node-timeout 5000 --appendonly yes# 创建集群docker exec -it redis1 redis-cli --cluster create 172.17.0.2:7001 172.17.0.2:7002 172.17.0.2:7003 172.17.0.2:7004 172.17.0.2:7005 172.17.0.2:7006 --cluster-replicas 1

配置 Sentinel 监控 Redis 集群

# 创建 Sentinel 配置文件 sentinel.confport 26379dir /tmpsentinel monitor mymaster 172.17.0.2 7001 2sentinel down-after-milliseconds mymaster 30000sentinel parallel-syncs mymaster 1sentinel failover-timeout mymaster 180000# 启动 Sentinel 实例docker run -d --net redis-cluster --name sentinel redis redis-sentinel /usr/local/etc/redis/sentinel.conf

集成熔断机制

可以使用 Hystrix 或 Resilience4j 等熔断器框架，对 Redis 客户端进行包装，当 Redis 服务出现异常时，自动触发熔断。

以下是一个使用 Resilience4j 的示例：

import io.github.resilience4j.circuitbreaker.CircuitBreaker;import io.github.resilience4j.circuitbreaker.CircuitBreakerConfig;import io.github.resilience4j.redis.RedisClient;// 创建 CircuitBreakerConfigCircuitBreakerConfig circuitBreakerConfig = CircuitBreakerConfig.custom()    .failureRateThreshold(50)    .slowCallRateThreshold(100)    .slowCallDurationThreshold(Duration.ofSeconds(2))    .waitDurationInOpenState(Duration.ofSeconds(10))    .permittedNumberOfCallsInHalfOpenState(10)    .slidingWindowSize(100)    .build();// 创建 CircuitBreakerCircuitBreaker circuitBreaker = CircuitBreaker.of("redis", circuitBreakerConfig);// 创建 RedisClientRedisClient redisClient = new RedisClient("172.17.0.2", 7001);// 使用 CircuitBreaker 包装 Redis 操作Supplier<String> redisOperation = () -> redisClient.get("key");CheckedFunction0<String> checkedRedisOperation = CircuitBreaker.decorateCheckedSupplier(circuitBreaker, redisOperation::get);try {    String result = checkedRedisOperation.apply();    System.out.println("Result: "   result);} catch (Throwable throwable) {    System.err.println("Error: "   throwable.getMessage());}