Akka-http在Java中创建分块实体(从Scala转换)

import akka.actor.ActorSystem;
import akka.http.javadsl.Http;
import akka.http.javadsl.model.HttpRequest;
import akka.http.javadsl.model.HttpResponse;
import akka.http.javadsl.model.StatusCodes;
import akka.http.javadsl.model.headers.ContentDispositionTypes;
import akka.http.javadsl.model.headers.ContentTypes;
import akka.http.javadsl.model.headers.HttpHeaders;
import akka.http.javadsl.server.AllDirectives;
import akka.http.javadsl.server.Route;
import akka.stream.ActorMaterializer;
import akka.stream.javadsl.Source;
import akka.util.ByteString;

public class ChunkedEntityExample extends AllDirectives {
    public Route createRoute() {
        return path("chunked", () ->
                get(() ->
                        complete(HttpResponse.create()
                                .withStatus(StatusCodes.OK)
                                .withEntity(ContentTypes.TEXT_PLAIN_UTF8, createChunkedEntity()))
                        )
                );
    }

    private Source<ByteString, ?> createChunkedEntity() {
        // 创建一个包含多个分块的Source
        return Source.from(List.of(
                ByteString.fromString("Chunk 1"),
                ByteString.fromString("Chunk 2"),
                ByteString.fromString("Chunk 3")
        ));
    }
}

public class Main {
    public static void main(String[] args) {
        // 创建Actor系统和材料化器
        ActorSystem system = ActorSystem.create();
        ActorMaterializer materializer = ActorMaterializer.create(system);

        // 创建路由
        ChunkedEntityExample example = new ChunkedEntityExample();
        Route route = example.createRoute();

        // 启动HTTP服务器
        Http.get(system).bindAndHandle(route.flow(system, materializer), ConnectHttp.toHost("localhost", 8080), materializer);
    }
}