Java中非阻塞重试机制实现咨询：解决@Retryable线程阻塞问题

Spring Retry原生的@Retryable确实是同步阻塞的，退避等待时会占用当前线程无法处理其他任务。要实现非阻塞重试，有以下几种可行方案：

1. 结合Spring Async + Spring Retry #

通过Spring的异步注解@Async将重试方法提交到独立线程池执行，发起调用的线程不会被阻塞；退避等待时线程池中的线程进入等待，但主线程可继续处理其他任务。

实现步骤： #

• 在配置类上添加@EnableAsync和@EnableRetry注解，开启异步与重试功能
• 给需要重试的方法同时标注@Async和@Retryable，配置退避策略
• 可选：自定义异步线程池，避免默认线程池的资源限制

代码示例： #

@Configuration
@EnableAsync
@EnableRetry
public class RetryAsyncConfig {
    // 自定义异步线程池（可选）
    @Bean(name = "retryAsyncExecutor")
    public Executor asyncExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(5);
        executor.setMaxPoolSize(10);
        executor.setQueueCapacity(20);
        executor.setThreadNamePrefix("RetryAsync-");
        executor.initialize();
        return executor;
    }
}

@Service
public class AsyncRetryService {
    @Async("retryAsyncExecutor")
    @Retryable(value = {RemoteServiceException.class}, backoff = @Backoff(delay = 1000, multiplier = 2))
    public CompletableFuture<String> callRemoteService() {
        // 调用远程服务逻辑
        return CompletableFuture.completedFuture("success");
    }
}

2. 使用Spring Retry反应式API #

如果项目基于Spring WebFlux等反应式框架，可直接使用Spring Retry的反应式重试能力，基于事件循环模型实现非阻塞重试，退避期间不会占用线程资源。

代码示例： #

@Service
public class ReactiveRetryService {
    public Mono<String> callReactiveRemoteService() {
        return remoteClient.invoke()
                .retryWhen(Retry.backoff(3, Duration.ofSeconds(1))
                        .filter(throwable -> throwable instanceof RemoteServiceException));
    }
}

3. 使用Resilience4j异步重试 #

Resilience4j提供了更灵活的异步重试支持，基于CompletableFuture实现非阻塞重试，可精细配置重试规则、退避策略，且与Spring生态兼容。

实现步骤： #

• 引入Resilience4j Retry依赖
• 配置RetryRegistry定义重试规则
• 使用Retry装饰异步方法

代码示例： #

@Configuration
public class Resilience4jRetryConfig {
    @Bean
    public Retry retryConfig() {
        return RetryRegistry.of(RetryConfig.custom()
                .maxAttempts(3)
                .waitDuration(Duration.ofSeconds(1))
                .retryOnException(throwable -> throwable instanceof RemoteServiceException)
                .build())
                .retry("asyncRetry");
    }
}

@Service
public class Resilience4jAsyncRetryService {
    private final Retry retry;

    public Resilience4jAsyncRetryService(Retry retry) {
        this.retry = retry;
    }

    public CompletableFuture<String> callAsyncService() {
        return Retry.decorateCompletionStage(retry, () -> {
            // 异步调用逻辑
            return CompletableFuture.completedFuture("success");
        });
    }
}

内容的提问来源于stack exchange，提问作者Preksha Parikh