Akka HTTP层的目的是通过HTTP将Actors暴露给Web,并使它们能够将HTTP服务作为客户端使用。它不是HTTP框架,它是一个基于Actor的工具包,用于与Web服务和客户端进行交互。
当使用指令getFromFile时(在此处记录:https://doc.akka.io/docs/akka-http/current/routing-dsl/directives/file-and-resource-directives/getFromFile.html#description)如何处理完成...
在我们的应用程序中,我们有流式JSON文档的路由。这是一个例子:/ ** GET api / 1 / tenant /(tenantId)/ ads / * / def getAllAdsByOwner(advertiserId:AdvertiserId):Route = get {...
我正在使用Akka HTTP缓存来缓存我的结果。但我面临着测试它的问题。 class GoogleAnalyticsController @Inject()(cache:Cache [String,HttpResponse],...
我有一个现有的Akka HTTP HttpRequest,我想添加两个标头。 val req:HttpRequest = ??? val hs:Seq [HttpHeader] = Seq(RawHeader(“a”,“b”))req.addHeaders(hs)预期:一个新...
无法使用Jackson解组LocalDate和LocalTime类
我正在使用akka制作一个POST路由,我将我的Json数据反序列化为Video对象,但是下面的curl请求:curl -H“Content-Type:application / json”-X POST -d'{“title” : “视频 ...
我正在尝试在我的Akka应用程序中实现HTTP客户端以使用第三方API。我想要配置的是超时和发生故障时的重试次数。以下是......
我对akka世界有点新意,所以我的知识领域有点小。我正在创建一个https服务器并使用akka流和http处理它,对于特定的URL,我需要将文件发送回...
Akka Streams - 用于Source.unfoldAsync的Backpressure
我目前正在尝试读取分页的HTTP资源。每个页面都是一个多部分文档,如果页面包含更多内容,页面的响应将包含标题中的下一个链接。一个......
如何优化akka-stream中REST API调用的吞吐量
我目前正在学习akka流,我正在尝试实现一个简单的流,它从源获取项目并为每个项目调用REST api。我的代码的简化版本看起来像......
如何在akka-Http中返回JSON而不是Case Class
我创建了一个路由来流式传输JSON中的案例类列表。但是如果我使用ByteString,则打印case类而不是JSON def streamRoute:Route = pathEndOrSingleSlash {val byteString = ...
我想发送一个文件以响应客户的请求。我需要路由的代码来发送响应的文件。我想在java中使用akka构建路由。 public Route createRoute(){...
akka-http错误:无法找到参数um的隐式值:akka.http.scaladsl.unmarshalling.FromRequestUnmarshaller
我知道已经有人问过,但我似乎无法找到答案。这是我的代码:import akka.http.scaladsl.marshallers.sprayjson.SprayJsonSupport import spray.json.DefaultJsonProtocol final ...
我需要使用Akka的HTTP客户端(v2.0.2)来使用REST服务。逻辑方法是通过主机连接池执行此操作,因为我们期望大量的同时连接。流......
如何使用akka-http创建自定义unmarshallers来处理参数列表?
我正在尝试从发送到我的路由的输入中解组参数,以便路由能够处理参数并在参数未正确格式化时发回BadRequest。 ......
如何将收到的消息广播到两个不同的流我正在使用akka流websocket客户端来请求和接收数据websocket服务器。通过websocket收到的数据,我......
我通过websocket客户端将传入的消息从Kafka转发到Web服务器。以下代码显示了我是如何做到的:import akka.Done import akka.actor.ActorSystem import akka.http.scaladsl ....
我必须实现一个GET,我可以有5个不同的查询参数,但只有传递一个参数时,请求才有效。我是Scala世界的新手。什么是最好的方法?目前我......
我正在使用akka http websocket客户端,并希望让客户端保持活力。在自动保持活动Ping支持部分,它说,将配置放入application.conf如下:...
我有一个简单的WebSocket应用程序,它基于Akka HTTP / Reactive流,像这样https://github.com/calvinlfer/akka-http-streaming-response-examples/blob/master/src/main/scala/com / ...
我正在设置一个Akka集群,以便能够使用Artery远程连接到其他节点。我按照以下教程设置了几个本地节点来模拟这种效果(https:// ...