Sentinel 与 Resilience4j 是当前 Spring Cloud 生态中替代 Hystrix 的主流流量防护组件。Sentinel 功能全面，支持可视化 Dashboard 及动态规则持久化，适合大中型项目；Resilience4j 轻量级，基于函数式编程，无外部依赖，适合小型或纯函数式场景。对比了两者在熔断、限流、降级、隔离等维度的差异，提供了详细的配置示例、原理剖析及迁移指南，帮助开发者根据项目需求精准选型并完成从 Hystrix 的平滑迁移。
| 维度 | Sentinel | Resilience4j | Hystrix (旧) | 胜者分析 |
|---|---|---|---|---|
| 熔断 | 支持（异常率/慢调用/异常数） | 支持（异常率/慢调用/异常数） | 支持（异常率/超时） | 平手 |
| 限流 | 高级（QPS/并发/令牌桶/漏桶/热点参数） | 基本（RateLimiter/信号量） | 无（需自定义） | Sentinel |
| 降级 | 支持（Fallback/BlockHandler） | 支持（Fallback） | 支持（Fallback） | 平手 |
| 隔离 | 线程池/信号量（可切换） | 信号量/线程池（Bulkhead） | 线程池（默认） | 平手 |
| 系统防护 | 自适应（CPU/负载/RT/QPS 多维） | 无（需自定义） | 无 | Sentinel |
| 可视化 | Dashboard（实时监控/规则编辑） | 无（需 Prometheus + Grafana） | 无 | Sentinel |
| 持久化 | 支持（Nacos/Apollo/ZK） | 无（配置硬编码） | 无 | Sentinel |
| 集群支持 | Token Server（集群限流） | 无（单机） | 无 | Sentinel |
| 集成 | Feign/Gateway/Dubbo/Stream | Feign/Gateway/Retrofit | Feign/RestTemplate | Sentinel |
| 性能开销 | 低（纳秒级统计） | 极低（纯函数） | 高（线程切换） | Resilience4j |
| 依赖 | Spring Cloud Alibaba | 独立 Jar（无外部依赖） | Netflix OSS | Resilience4j |
| 社区活跃 | ★★★★★ (阿里维护) | ★★★★ (开源社区) | ★ (停更) | Sentinel |
结论：Sentinel 功能更全（适合大中型项目），Resilience4j 更轻（适合小项目/纯函数式）。
确保 Spring Cloud Alibaba 版本匹配 Spring Boot，避免 JAR 冲突。
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>
<dependency>
<groupId>com.alibaba.csp</groupId>
<artifactId>sentinel-datasource-nacos</artifactId>
</dependency>
<dependency>
<groupId>com.alibaba.csp</groupId>
<artifactId>sentinel-annotation-aspectj</artifactId>
</dependency>
spring:
cloud:
sentinel:
eager: true # 启动时加载规则（开发调试推荐）
transport:
dashboard: localhost:8080
port: 8719 # 客户端端口，避免冲突
datasource:
flow:
nacos:
server-addr: localhost:8848
data-id: sentinel-flow.json
group-id: DEFAULT_GROUP
rule-type: flow
degrade:
nacos:
server-addr: localhost:8848
data-id: sentinel-degrade.json
group-id: DEFAULT_GROUP
rule-type: degrade
filter:
enabled: true
order: -1 # 优先级高
@Service
public class OrderService {
@SentinelResource(
value = "getOrder",
blockHandler = "handleBlock",
blockHandlerClass = BlockHandler.class,
fallback = "handleFallback",
exceptionsToIgnore = {NullPointerException.class}
)
public OrderDTO getOrder(Long id) {
// 业务逻辑
return new OrderDTO(id, "success");
}
}
@SentinelResource(paramFlow = true)，开发时配置 paramItem，支持参数限流（e.g., 用户 ID 限 5 QPS）。[
{
"resource": "getOrder",
"grade": 1,
"count": 20,
"controlBehavior": 1
},
{
"resource": "getOrder",
"grade": 0,
"count": 10
},
{
"resource": "getOrder",
"refResource": "pay",
"strategy": 1,
"count": 5
}
]
// CtSph.process()
public Entry entry(String resource) {
Context context = ContextUtil.enter(resource);
try {
for (ProcessorSlot slot : slotChain) {
slot.entry(context, ...); // 链式检查
}
return new Entry(resource);
} catch (BlockException e) {
throw e; // 限流/熔断
}
}
Sentinel 在开发中强调'可观测性 + 渐进集成'，以下是关键事项，帮助你从 0 到生产高效落地：
@SentinelResource 注解细粒度保护方法，避免全局资源（如 "ALL"）导致规则冲突。开发时，先定义资源名规范（如 "service.methodName"），便于 Dashboard 搜索。关键：在注解中指定 entryType = EntryType.IN/OUT，IN 用于入口流量，OUT 用于出口调用（如 Feign）。测试时，用 JUnit + Mock 模拟 BlockException。sentinel.datasource.auto-refresh: true，规则变更自动推送（延迟 < 1s）。开发事项：用 JSON 模板标准化规则，避免手动输入错误。示例：批量导入 100+ 规则时，用脚本生成 JSON。测试策略：用 JMeter 模拟高并发，验证 QPS 阈值；用 Chaos Monkey 注入故障，测试熔断恢复时间（half-open 探针）。feign.sentinel.enabled: true 自动注入 Sentinel。maxSystemLoad: 1.5，避免过度保护。关键：在 K8s 中集成，结合 HPA（Horizontal Pod Autoscaler）动态扩容。监控：用 Prometheus exporter 暴露 system_qps 等指标。logging.level.com.alibaba.csp.sentinel: DEBUG 追踪 Slot 链执行。statistic.maxRt: 5000ms 防长尾请求。关键：开发后期，用 Arthas 热点分析 Sentinel 方法；集成 SkyWalking 追踪 Sentinel Entry。支持 YAML/Properties/环境变量，开发时用 @ConfigurationProperties 绑定自定义配置。
<dependency>
<groupId>io.github.resilience4j</groupId>
<artifactId>resilience4j-spring-boot3</artifactId>
</dependency>
<dependency>
<groupId>io.github.resilience4j</groupId>
<artifactId>resilience4j-micrometer</artifactId>
</dependency>
<dependency>
<groupId>io.github.resilience4j</groupId>
<artifactId>resilience4j-reactor</artifactId>
</dependency>
resilience4j:
circuitbreaker:
configs:
default: # 全局默认（开发推荐）
sliding-window-type: count-based
sliding-window-size: 100
failure-rate-threshold: 50
slow-call-rate-threshold: 100
slow-call-duration-threshold: 60000
wait-duration-in-open-state: 5s
permitted-number-of-calls-in-half-open-state: 3
automatic-transition-from-open-to-half-open-enabled: true
instances:
orderCB:
base-config: default
ratelimiter:
instances:
orderRL:
limit-for-period: 20
limit-refresh-period: 1s
timeout:
instances:
orderTimeout:
timeout-duration: 3s
bulkhead:
instances:
orderBulkhead:
max-concurrent-calls: 10 # 信号量隔离
max-wait-duration: 0
thread-pool-bulkhead:
instances:
orderTP:
max-thread-pool-size: 10
core-thread-pool-size: 2
queue-capacity: 20
@Service
public class OrderService {
@CircuitBreaker(name = "orderCB", fallbackMethod = "fallback")
@RateLimiter(name = "orderRL")
@Bulkhead(name = "orderBulkhead", type = Bulkhead.Type.SEMAPHORE)
@Retry(name = "orderRetry")
public OrderDTO getOrder(Long id) {
// 业务
return new OrderDTO(id, "success");
}
public OrderDTO fallback(Long id, CallNotPermittedException ex) {
return new OrderDTO(id, "熔断：" + ex.getMessage());
}
}
@Controller
public class OrderController {
@GetMapping("/order/{id}")
public Mono<OrderDTO> getOrder(@PathVariable Long id) {
CircuitBreaker cb = CircuitBreaker.of("orderCB", CircuitBreakerConfig.custom().build());
return Mono.fromCallable(() -> service.getOrder(id))
.transformDeferred(CircuitBreakerOperator.of(cb))
.onErrorResume(e -> Mono.just(fallback(id, e)));
}
}
@Retry 最外层，@CircuitBreaker 内层，避免重试放大故障。base-config 复用默认，开发时用 profiles 分环境（dev: 宽松阈值，prod: 严格）。@Retry(maxAttempts=3, waitDuration=500ms)，开发测试 exponential backoff 防洪水攻击。@Component
public class ResilienceConfig {
@EventListener
public void onCircuitBreakerEvent(CircuitBreakerOnStateTransitionEvent event) {
log.info("熔断状态变更：{} -> {}", event.getCircuitBreakerName(), event.getStateTransition());
}
}
// CircuitBreaker.decorateSupplier
public <T> Supplier<T> decorateSupplier(CircuitBreaker cb, Supplier<T> supplier) {
return () -> {
if (cb.isCallPermitted()) {
try {
T result = supplier.get();
cb.onSuccess();
return result;
} catch (Throwable t) {
cb.onError(t);
throw t;
}
} else {
throw CallNotPermittedException.create(...);
}
};
}
Resilience4j 强调'函数式 + 轻量'，开发中注重'配置即代码'，以下关键事项助你高效开发：
@CircuitBreaker(name = "specific") 指定实例。关键：配置 sliding-window-type: COUNT_BASED/TIME_BASED，COUNT_BASED 适合突发流量。@Retry(name = "orderRetry", maxAttempts: 3, waitDuration: 500ms)。关键：设 backoff: exponential 指数退避，防重试风暴。调试事项：日志记录重试次数，开启 resilience4j.retry.logging-enabled: true。CircuitBreaker.addStateTransitionListener 监听状态变更。开发时，集成 Actuator /micrometer 暴露事件。关键：自定义 RegistryEventConsumer，规则变更时热加载配置（用 Spring Cloud Config）。Resilience4jFeign.builder()；与 Gateway 用 Resilience4jGatewayFilterFactoryFactory。开发事项：函数式装饰：CircuitBreaker.decorateSupplier(supplier)，易于 Lambda。调试：用 resilience4j.micrometer: true 暴露指标到 Prometheus。ringBufferSizeInClosedState: 100 增大缓冲防误判。关键：开发后期，用 JMH 基准测试装饰器开销；集成 Grafana Dashboard 监控 failureRate 等。@HystrixCommand → @SentinelResource / @CircuitBreakercircuitbreaker_calls_successful / ratelimiter_available_permissions
微信公众号「极客日志」，在微信中扫描左侧二维码关注。展示文案：极客日志 zeeklog
查找任何按下的键的javascript键代码、代码、位置和修饰符。 在线工具，Keycode 信息在线工具，online
JavaScript 字符串转义/反转义；Java 风格 \uXXXX（Native2Ascii）编码与解码。 在线工具，Escape 与 Native 编解码在线工具，online
使用 Prettier 在浏览器内格式化 JavaScript 或 HTML 片段。 在线工具，JavaScript / HTML 格式化在线工具，online
Terser 压缩、变量名混淆，或 javascript-obfuscator 高强度混淆（体积会增大）。 在线工具，JavaScript 压缩与混淆在线工具，online
将字符串编码和解码为其 Base64 格式表示形式即可。 在线工具，Base64 字符串编码/解码在线工具，online
将字符串、文件或图像转换为其 Base64 表示形式。 在线工具，Base64 文件转换器在线工具，online