在 Armeria 上使用第三方 http 客户端答案

【问题标题】：Using third party http client on Armeria在 Armeria 上使用第三方 http 客户端
【发布时间】：2020-10-24 06:56:52
【问题描述】：

我正在发现 Armeria 框架，我想使用 REST 服务。使用 Armeria WebClient：

WebClient webClient = WebClient.of("http://localhost:9090");
RequestHeaders getJson = RequestHeaders.of(HttpMethod.GET, "/some-service",
            HttpHeaderNames.CONTENT_TYPE, "application/json", "SomeHeader", "armeriaTest");
return webClient.execute(getJson).aggregate().thenApply(resp->{
        if(HttpStatus.OK.equals(resp.status())) {
            return parseBody(resp.contentUtf8());
        }else if(HttpStatus.BAD_REQUEST.equals(resp.status())){
            throw new IllegalStateException("not exists");
        }
        throw new RuntimeException("Error");
    });

此代码返回一个将异步解析的 CompletionStage，因为如果我在这里执行 join() 或 get() 会导致“java.lang.IllegalStateException：阻塞事件循环，不要这样做。”

我的问题是：如果我想使用第三方 httpclient 库（如 Apache HttpClient）而不是 Web 怎么办？客户端调用也应该包含在 Future 中？我应该如何管理客户端请求以适应框架方法并避免“阻塞事件循环”问题？

谢谢大家！

【问题讨论】：

标签： armeria

【解决方案1】：

是的。当您的代码在事件循环线程中运行时，您不应该执行任何阻塞操作。您可以通过将阻塞操作提交到专门用于处理阻塞操作的其他线程池来执行阻塞操作。

如果您在服务器端使用 Armeria，您可以通过 ServiceRequestContext.blockingTaskExecutor() 获得一个：

Server server = Server
    .builder()
    .service("/", (ctx, req) -> {
        CompletableFuture<String> f1 = CompletableFuture.supplyAsync(() -> {
            // Perform some blocking operations that return a string.
        }, ctx.blockingTaskExecutor());

        CompletableFuture<String> f2 = f1.thenApply(result -> {
            // Transform the result into an HttpResponse.
            return HttpResponse.of("Result: %s", result);
        });

        return HttpResponse.from(f2);
    })
    .build();

如果你不是在服务器端使用 Armeria，你可以使用你的平台提供的其他Executor，甚至可以创建一个新的ThreadPoolExecutor 专门用于处理阻塞操作。

【讨论】：