特定舱壁配置

DeepSeek V3 中英对照 Specific Bulkhead Configuration

与证明默认的'Bulkhead'或'ThreadPoolBulkhead'配置类似，你可以创建一个 Customizer bean，该 bean 会接收一个 Resilience4jBulkheadProvider。

@Bean
public Customizer<Resilience4jBulkheadProvider> slowBulkheadProviderCustomizer() {
    return provider -> provider.configure(builder -> builder
        .bulkheadConfig(BulkheadConfig.custom().maxConcurrentCalls(1).build())
        .threadPoolBulkheadConfig(ThreadPoolBulkheadConfig.ofDefaults()), "slowBulkhead");
}

除了配置已创建的舱壁（Bulkhead），您还可以在舱壁和线程池舱壁创建之后、返回给调用者之前对其进行自定义。为此，您可以使用 addBulkheadCustomizer 和 addThreadPoolBulkheadCustomizer 方法。

隔板模式示例

@Bean
public Customizer<Resilience4jBulkheadProvider> customizer() {
    return provider -> provider.addBulkheadCustomizer(bulkhead -> bulkhead.getEventPublisher()
        .onCallRejected(slowRejectedConsumer)
        .onCallFinished(slowFinishedConsumer), "slowBulkhead");
}

线程池隔离示例

@Bean
public Customizer<Resilience4jBulkheadProvider> slowThreadPoolBulkheadCustomizer() {
    return provider -> provider.addThreadPoolBulkheadCustomizer(threadPoolBulkhead -> threadPoolBulkhead.getEventPublisher()
        .onCallRejected(slowThreadPoolRejectedConsumer)
        .onCallFinished(slowThreadPoolFinishedConsumer), "slowThreadPoolBulkhead");
}