我正在尝试使用Akka-Http调用REST URL。 我正在遵循akka文档中此示例。 使用此方法,我能够进行rest调用。 但是我无法找到如何添加自定义请求标头。 我尝试使用ModeledCustomHeader,但仍然没有请求头。 这是我的示例。final class ApiTokenH...
TLDR: 当我在流中使用传出的http请求时,是每个请求材料化一个流(即使用短暂的流)更好还是跨请求使用单个流材料化? 详细信息:我有一个典型的服务,接收HTTP请求,将其分散到几个第三方下游服务(不受我控制),并在发送它们之前聚合结果。我使用Akka-HTTP进行客户端实现,使用Spra...
我正在尝试客户端Websocket,按照 webSocketClientFlow 文档操作。以下是示例代码:import akka.actor.ActorSystem import akka.Done import akka.http.scaladsl.Http import akka.str...
是否可能将来自Akka HTTP的外部、长度未知的字节字符串流动态反序列化为域对象? 背景 我调用一个无限长的HTTP端点,它输出一个不断增长的JSON数组:[ { "prop": true, "prop2": false, "pro...
我有一个正在运行的Akka HTTP应用程序,我想关闭它。 在我的Shell上按下Ctrl + C(我目前使用的是Windows Git Bash)并不能使SBT停止运行(不起作用)。 有没有推荐的方法来优雅地关闭Akka应用程序?
我们正在开发一款iOS应用程序,用户需要使用电子邮件+密码(或手机号码)进行身份验证。我们的后端由几个使用Akka-Http的微服务构成,需要快速、可伸缩、并发,并且身份验证+授权应该适用于我们的多个服务。 我正在努力确定要使用哪种身份验证方法。目前,Akka-HTTP提供基本认证和OAut...
大多数Akka HTTP示例都表明,使用path定义Routes非常容易。我有以下(稍微简化)自入门示例中获得的内容:val route = path("hello") { complete( HttpEntity( ContentTypes.`text...
假设我已经设置了一个任意复杂的Flow [HttpRequest,HttpResponse,Unit]。 我已经可以使用这个流来处理传入的请求。Http().bindAndHandle(flow, "0.0.0.0", 8080) 现在我想要添加日志记录,利用一些现有的指令,比如logRequ...