常数“阅读超时” Micronaut声明客户的例外

Question

我的Micronaut应用程序中有两个声明性客户端，它们以非阻滞方式（以及其他一些异步方法）收集他们的结果。但是他们偶尔会产生io.micronaut.http.client.exceptions.readtimeoutexception：read timeout。也许就像每个人都会发生的每10或20个请求一样，但我很确定外部服务没有按时出现，因为它们快速且高度可用。

这是我的客户的样子：

@Client("https://foo.bar")
public interface ServiceClient {
    @Post("/data/myData")
    CompletableFuture<List<ServiceResponse>> getDataAsync(@NonNull @Body ServiceRequest request);
}

这就是我在@async方法中称呼它们的方式：

.
.
@Inject
private Provider<ServiceClient> serviceClient;
.
.
@Async
public CompletableFuture<Map<String, Optional<ServiceResponse>>> getDataAsync() {
    ServiceRequest request = buildRequest(); // Some method

    return serviceClient.get().getDataAsync(request)
            .thenApply(this::parseResponse) // Some method
            .exceptionally(
                    ex -> {
                        LOG.error("Failed to connect to service", ex);
                        return someDefaultMap;
                    }
            );
}

在我的主要方法中，我得到了声明性客户端的结果 +其他一些异步方法并将它们组合在一起：

CompletableFuture<Map<String, Optional<ServiceResponse>>> servideFuture = getDataAsync();
CompletableFuture<Object> future2 = anotherAsyncMethod();
CompletableFuture<Object> future3 = andAnotherAsyncMethod();

CompletableFuture.allOf(servideFuture, future2, future3).thenApply(it -> {
    Map<String, Optional<ServiceResponse>> servieRes = servideFuture.join();
    Object future2Res = future2.join();
    Object future3Res = future3.join();

    // Some aggregation
})

我为客户设置了5秒的超时，这已经足够了，因为我要打电话的其他服务非常快。我还为我的I/O执行人使用了缓存类型。这是我的配置：

  http:
    client:
      read-timeout: 5s
  executors:
    io:
      type: cached

Answer 1

我想我发现了这个问题。由于我的请求量很高，我的客户似乎正在等待默认事件循环。我仅针对声明的客户定义了一个自定义事件循环，现在运行良好。

micronaut:
  netty:
    event-loops:
      default:
        num-threads: 3
      httpclient:
        num-threads: 5
  http:
    client:
      read-timeout: 5s
      event-loop-group: httpclient