Tag: akka http

如何使用Akka HTTP从多个actor / web处理程序正确调用单个服务器？

我有一个服务（让我们称之为服务A），它使用Akka Server HTTP来处理传入的请求。 我还有第三方应用程序（服务B），它提供了几个Web服务。 服务A的目的是转换客户端请求，调用服务B的一个或多个Web服务，合并/转换结果并将其提供给客户端。 我在某些部分使用Actors，而在其他部分使用Future。 要调用服务B，我使用Akka HTTP客户端。 Http.get(actorSystem).singleRequest(HttpRequest.create() .withUri(“http://127.0.0.1:8082/test”), materializer) .onComplete(…) 问题是，每个Service A请求都会创建一个新流，如果有多个并发连接，则会产生akka.stream.OverflowStrategy$Fail$BufferOverflowException: Exceeded configured max-open-requests value of [32] error 我已经问过这个问题，并建议使用单个Flow 如何正确调用Akka HTTP客户端以获取多个（10k-100k）请求？ 虽然它适用于来自单个地方的一批请求，但我不知道如何使用来自所有并发请求处理程序的单个Flow。 这样做的正确“Akka-way”是什么？

如何正确调用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 […]