如何为Micronaut非声明式HTTP客户端添加重试机制

对于动态创建的Micronaut HTTP客户端，无法直接通过ServiceHttpClientConfiguration添加重试配置——因为重试属于AOP层面的逻辑，需要借助Micronaut的RetryExecutor来实现自动重试。以下是具体实现步骤：

1. 确保引入Retry依赖 #

首先确认项目中已包含Micronaut Retry模块（以Maven为例）：

<dependency>
    <groupId>io.micronaut.retry</groupId>
    <artifactId>micronaut-retry</artifactId>
    <scope>compile</scope>
</dependency>

2. 动态构建重试配置 #

根据运行时获取的参数，创建RetryConfiguration实例，自定义重试次数、延迟时间以及触发重试的异常类型：

// 从运行时获取重试参数（示例值，实际替换为你的动态获取逻辑）
String runtimeRetryAttempts = "3";
String runtimeRetryDelay = "1000";

// 构建重试配置
RetryConfiguration retryConfig = RetryConfiguration.builder()
        .maxAttempts(Integer.parseInt(runtimeRetryAttempts))
        .delay(Duration.ofMillis(Long.parseLong(runtimeRetryDelay)))
        // 指定需要触发重试的异常，比如网络异常、特定HTTP状态异常
        .retryOn(IOException.class, HttpStatusException.class)
        // 可选：设置指数退避的间隔倍数
        .multiplier(2.0)
        .build();

// 创建RetryExecutor实例
RetryExecutor retryExecutor = RetryExecutor.create(retryConfig);

3. 用RetryExecutor包裹HTTP请求 #

将HTTP请求逻辑放入retryExecutor.execute()方法中，即可实现自动重试：

// 动态创建HTTP客户端
var configuration = new ServiceHttpClientConfiguration("myId", null, 
                                  null, new DefaultHttpClientConfiguration());  
HttpClient client = new DefaultHttpClient("http://127.0.0.1:8200", configuration);

// 构建请求
var uri = UriBuilder.of("http://127.0.0.1:8200").path("/v1/kv/data/").build();
var request = HttpRequest.GET(uri).header("username","password");

// 执行带重试的请求
HttpResponse<String> response = retryExecutor.execute(() -> 
    client.toBlocking().exchange(request, String.class)
);

补充说明 #

• 如果代码运行在Micronaut IoC容器中，可直接注入RetryExecutor实例，无需手动创建，只需通过配置类动态覆盖重试参数即可。
• 可根据需求扩展重试逻辑，比如添加重试监听、自定义退避策略等。

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