Tag: akka stream

如何正确调用Akka HTTP客户端多个（10k – 100k）请求？

我正在尝试使用Akka HTTP 2.0-M2编写批量数据上传工具。 但是我面临akka.stream.OverflowStrategy$Fail$BufferOverflowException: Exceeded configured max-open-requests value of [32] error. 我试图隔离一个问题，这里的示例代码也失败了： public class TestMaxRequests { private static final class Router extends HttpApp { @Override public Route createRoute() { return route( path(“test”).route( get(handleWith(ctx -> ctx.complete(“OK”))) ) ); } } public static void main(String[] args) { ActorSystem actorSystem = ActorSystem.create(); Materializer materializer = ActorMaterializer.create(actorSystem); Router router […]