Akka Http Java：如何简化HTTP响应体的字符串提取？

你完全可以用Akka Http内置的toStrict方法来简化代码，不用手动处理流的拼接操作。下面是简化后的完整实现：

import akka.actor.ActorSystem;
import akka.http.javadsl.Http;
import akka.http.javadsl.model.HttpRequest;
import akka.http.javadsl.model.HttpResponse;
import com.typesafe.config.ConfigFactory;

public class App {

    public static void main(String[] args) {
        ActorSystem actorSystem = ActorSystem.create(ClientConfig.class.getSimpleName(), ConfigFactory.defaultApplication(App.class.getClassLoader()));
        Http httpClient = Http.get(actorSystem);
        HttpRequest httpRequest = HttpRequest.create("https://stackoverflow.com");

        String responseBody = httpClient.singleRequest(httpRequest)
                .thenCompose(HttpResponse::toStrict) // 把流式响应体转为完整的StrictEntity
                .thenApply(strictEntity -> strictEntity.getData().utf8String()) // 直接转换为字符串
                .toCompletableFuture()
                .join();

        System.out.println(responseBody);
    }
}

关键改进说明 #

• HttpResponse.toStrict方法会帮你自动完成字节流的拼接工作，将流式的响应体转换为一个完整的StrictEntity，省去了手动写fold和Sink.head的繁琐逻辑
• 拿到StrictEntity后，直接调用getData()获取完整的ByteString，再通过utf8String()一键转成字符串，整个流程线性清晰，可读性强很多

原来的代码复杂是因为重复实现了Akka Http已经封装好的流收集逻辑，用内置方法能大幅简化代码结构。

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