问题标签 [akka-http]

I can get enumerator from mongodb, using reactivemongo like,

How to stream from this enumerator, using akka-http and akka-stream ?

I have converted the enumerator to publisher using, play streams experimental library,

and stream from, akka-http like,

But, the stream does not ending, the client is still waiting for the data. Is there any issue while creating enumerator ?. Or the issue in converting the Enumerator to publisher ?

I have already posted the question in reactivemongo google user group and play user group https://groups.google.com/forum/#!topic/reactivemongo/uObGXFQFH0Y

我试图弄清楚如何使用 Akka HTTP（客户端 API）创建多部分表单数据请求，但我找不到表达表单数据的方法。

有谁知道如何创建将采用文件或输入流的表单数据？

我尝试编写一些简单的基于 akka-http 和 akka-streams 的应用程序来处理 http 请求，总是使用一个预编译流，因为我计划在我的 requestProcessor 流中使用带有背压的长时间处理

我的申请代码：

我找到了有关如何创建可以动态接受要处理的新项目的 Source 的解决方案，但是我可以找到有关如何在我的路由中获取流执行结果的任何解决方案

最近我开始使用 akka 流构建一些小型 Web 处理服务。这很简单，我从 redis 中提取 url，然后我下载这些 url（它们是图像），稍后我正在处理图像，并将它们推送到 s3 和一些 json 到 redis。

我正在从多个站点下载许多不同类型的图像，我收到了一大堆错误，例如 404、意外断开连接、响应内容长度 17951202 超过了配置的 8388608 限制、EntityStreamException：实体流截断和重定向。通过重定向，我正在调用 requestWithRedirects ，其地址位于响应的位置标头中。

负责下载的部分差不多是这样的：

TimeoutFuture 非常简单，它需要未来和超时。如果未来的时间超过超时，它会返回其他未来的超时异常。我遇到的问题是：一段时间后我收到一个错误：

我不确定可能是什么问题，但我认为我有一些下载没有正确完成，一段时间后它们会留在一些全局连接池中，导致提到的错误。任何想法可能导致问题？或者如何尝试找到问题的根源：我已经测试了 404 响应，并且响应内容长度超出了...错误，它们似乎不是我的麻烦制造者。

编辑：很可能问题出在我的 TimeoutFuture 上。我用这里描述的错误填充它https://stackoverflow.com/a/29330010/2963977但在我看来，实际上下载图像的未来永远不会完成，它正在占用我的连接池资源。

我想知道为什么这些设置对我的情况没有任何影响：

编辑2：

显然还不支持超时。这是我的错误报告 https://github.com/akka/akka/issues/17732#issuecomment-112315953

我是 akka-http 的新手。我在我的项目中使用它。我无法理解到底是marshalling什么unmarshalling。

如果有人可以用一个简短的例子来解释它，展示如何编组和解组 json。

我正在尝试将请求有效负载解组为字符串，但由于某种原因它失败了。我的代码：

例如，在这个SO 线程中，似乎默认情况下应该可以使用这个隐式。但也许这在 akka-http 中有所不同？

我尝试导入akka.http.scaladsl.unmarshalling.PredefinedFromEntityUnmarshallers具有 astringUnmarshaller但它没有帮助。也许是因为这返回类型FromEntityUnmarshaller[String]not FromRequestUnmarshaller[String]。还有一个字符串解组器，spray.httpx.unmarshalling.BasicUnmarshallers但这也无济于事，也akka.http.scaladsl.unmarshalling.PredefinedFromStringUnmarshallers

我怎样才能解组（和编组）成一个字符串？

（奖励：如何直接在 JsObject 中解组（播放 json）。但也只有字符串，因为我对为什么这不起作用并且它可能对其他情况有用）。

使用 1.0-RC3

谢谢。

这是我的服务器：

现在我想用 Specs2 测试这个服务器。这是我尝试过的：

我尝试使用step启动服务器。但是，该App特征没有提供在测试后停止服务器的方法。我想知道这是否是测试简单服务器的正确方法。

谢谢。

我们正在研究使用 Akka-HTTP Java API - 使用路由 DSL。

不清楚如何使用路由功能来响应 HttpRequest；使用无类型的 Akka Actor。例如，在匹配 Route 路径时，我们如何将请求交给“处理程序”ActorRef，然后它会以异步方式以 HttpResponse 响应？

Akka-User 邮件列表上发布了一个类似的问题，但没有类似的后续解决方案 - https://groups.google.com/d/msg/akka-user/qHe3Ko7EVvg/KC-aKz_o5aoJ。

我想在Source其上创建一个稍后推送元素，例如：

推荐的方法是什么？

谢谢！

我正在尝试为我的应用程序编写一个测试用例akka-http。下面给出了其中一个测试用例：

当我运行它时，它有时会正常工作，有时我会收到错误消息Request was neither completed nor rejected within 1 second。我添加了一个 Thread.sleep 让它现在工作。我知道这不是正确的解决方案。谁能告诉我如何让测试等待超过 1 秒？