问题标签 [akka-http]

我刚刚开始研究 swagger 如何与 akka-http 一起工作，然后我开始使用名为“Spray-Slick-Swagger Sample”的类型安全激活器示例并开始运行。此代码也可在此处获得。

由于这是一个说明性示例，我猜测并非所有 sbt 的“最佳实践”都被遵循。特别是，我注意到所有用于 swagger 的 Web 资源都已签入到 src/main/resources。

在实际项目中，我希望能够建立对 swagger 版本“xxxx.whatever”的依赖，然后我希望 sbt 的依赖管理工具下载适当的 Web 资源（在 swagger .jar 中），然后我想执行一些代码以某种方式打开依赖的 swagger jar 并将 Web 资源提取到正确的位置（即 src/main/resources）...更好的办法是将这些从 src/ 中排除main/resources 并放入 target/... 某处，以便“干净”操作使自动生成的内容轻松消失。

我猜必须有一个插件或一些众所周知的配方。如果有人能指点我一个，那就太棒了。谢谢 ！

我将以下标头发送到我的 akka-http api: "Content-type": "application/json", "Accept": "application/json", "AppId": "some_id".

如何在我的 akka-http 路由中获取“Ap​​pId”自定义标头？

谢谢。

我试图弄清楚如何使用 Akka HTTP 库创建一个基本的 HTTP POST 请求。这就是我想出的：

问题是它对我来说似乎有点不习惯。还有其他方法可以从 FormData 创建 HttpEntity 吗？Await特别是对于这样一个简单的任务，即使数据很容易获得，我也必须使用或返回 Future 的事实似乎过于复杂。

我正在使用sbt-native-packager在 Scala 中构建我们基于 Akka HTTP 的应用程序的 docker 映像。但是，最近它在运行sbt docker:publishLocal命令时开始抛出以下错误：

我正在尝试 Akka HTTP，并且我创建了一个服务，该服务在 HttpResponse 中返回域对象的 Json 数组。在客户端中，我想将其转换为域对象的源，以便后续流和接收器可以使用它。

参考 Json 支持部分： http ://doc.akka.io/docs/akka-stream-and-http-experimental/1.0/scala/http/common/json-support.html

我已经完成了定义隐式 RootJsonReader 等的必要工作，但我不知道如何使用 FromEntityUnmarshaller。

我的代码在这里： https ://github.com/charlesxucheng/akka-http-microservice

它基于 akka-http-microservice 激活器模板。Service2.scala 是我的服务器实现并且正在运行。AkkaHttpClient.scala 是客户端实现，它是不完整的。

要构建，请使用 Gradle，因为 build.sbt 不是最新的。

谢谢。

我正在尝试创建将捕获的异常包装到带有登录用户的用户对象的异常中的路由。理想情况下，我更喜欢将这些信息放入其中ContextRequest以便在我的中使用它，ExceptionHandler但它是不可变的。

我得出的结论是，正确的方法是使用本示例mapInnerRoute中描述的方法。

我这样使用

的内容completeWithUserAwareException永远不会被调用。我怀疑这与外部路线的动态性质有关。

如何实现将用户上下文信息传递给异常处理程序的目标？

我目前有一个指令用于保护 Akka HTTP 应用程序中的资源，如下所示：

whereLoggedInUser.findByAccessToken()对数据库进行阻塞查询，我想将此异步切换为ask可以提供相同数据的参与者，我可以将ActorRef作为参数传递给指令，但我不知道如何处理Future询问返回的问题。

Akka HTTP 附带的Directive1示例似乎都没有这样做（至少我找不到），尽管有返回的指令示例Route。

我想做的甚至可能吗？是否有一种可能的方法来创建具有StandardRoute用户凭据字段的子类并以某种方式返回？

我有这个带有akka-http客户端和服务器的粗略测试示例。

服务器.scala：

客户端.scala：

目前Server只回复一个“测试”。

如何更改输入HttpResponse以Server每 1 秒在无限循环中将“测试”作为分块（流）发送？

寻找有关如何使用 akka HTTP 进行身份验证的良好解释。给定一条看起来像的路线

该文档概述了一种方法，但随后省略了执行实际身份验证的相关部分......

我在哪里可以找到这种身份验证器的示例实现？我已经有了对给定用户名和密码的用户进行身份验证的逻辑，但我不知道如何从 HTTP 请求（或 RequestContext）中获取用户名/密码（或包含两者的令牌）。

我akka-http用来向发送回分块响应的 http 服务发出请求。这就是相关代码的样子：

命令行中生成的输出如下所示：

数据的逻辑部分 - 在这种情况下是一个 json 以行尾符号结束\r\n，但问题是，json 并不总是适合单个 http 响应块，如上面示例中清晰可见的那样。

我的问题是 - 我如何将传入的分块数据连接到完整的 json 中，以便生成的容器类型仍然是Source[Out,M1]or Flow[In,Out,M2]？我想遵循akka-stream.

更新：值得一提的是，响应是无止境的，聚合必须实时完成