问题标签 [spray-client]

我的应用程序中有一个特定的管道，它必须遵循所有重定向（为了理智起见，最多可以说 50 个），跨越任何域和协议（例如，它可以遵循http://somewhere.com到https://somewhere.else。 com )，但仅适用于 GET 请求。我的应用程序中没有其他管道应该这样做。

这是它现在的样子：

如何以与主机无关的方式（即不通过配置选项或HostConnectorSetup）在管道的配置中指定它？

FormData应该Content-Type自动设置标题，但它不起作用。所以我尝试手动设置它，但我收到警告。

在任何一种情况下，我从服务器得到的响应都是我没有设置Content-Type标头时得到的响应。

我HttpEntity是否正确地构建了管道？我应该使用编组器FormData吗？

The entity “nbsp” was referenced, but not declared解析包含实体的有效 HTML 时出现异常&nbsp（这使其无效XML；我不控制服务器），同时将 a 解组HttpEntity为NodeSeqwith spray.httpx.unmarshalling.BasicUnmarshallers.NodeSeqUnmarshaller。

我可能可以预处理要删除的 HTML ，但是使用 Spray&nbsp解析 HTML（带有）的公认方法是什么？&nbsp

我试图有一个 Akka 流，其中一些阶段是 http 调用。由于 http 调用有时会（并且将会）失败，我更愿意将相关数据放入单独的队列（甚至可能在我的应用程序外部），一段时间后将它们拉出并在流中使用它们。

我正在使用喷雾客户端进行 http 调用。但我对其他客户（包括较新的 akka-http）持开放态度。

实现这一目标的最干净的方法是什么？我不能进行同步重试，因为这会阻塞舞台。目前我将失败的http请求放到raabitmq，在每个http阶段之前添加一个RMQ消费者源和一个合并节点。这符合我的目的，但使流代码丑陋且难以管理。使用这种方法，即使是简单的线性拓扑也会变成复杂的图。

我使用 Akka 流（通过普通的 akka 解决方案）主要是为了方便组合和背压。

在这种情况下（在 akka-stream 内外）我有什么选择。对于其他设计约束，我想坚持使用 Akka 解决方案。

我正在使用POSTMAN应用程序来REST call (POST, GET)处理我的 Scala Akka 应用程序。如果我从 angularJS 进行相同的调用，它可以工作，但是当我从 POSTMAN 触发它时，它会给出以下错误：

我的POST电话是：

其中包含我在BodyPostman 选项卡中添加的 3 个请求参数。我的 Header 需要一个值，即App_Id我添加的Headers我也添加了

在页眉中。但邮递员仍然给出上述错误。

我的申请代码是：

我有一个返回字符串的 Akka HTTP 服务，如下所示：

我有一个 Akka HTTP 客户端，它试图访问这个路由。但是下面的代码失败了：

我根本没有输出。但是，如果我将 unmarshal 与 flatMap 一起使用，我会得到输出：

为什么 mapTo 在这里失败，为什么我需要 flatMap 和 Unmarshal？

编辑：

我了解 Unmarhsal 的必要性，我正在尝试了解 map 和 flatMap 之间的区别

例如，下面的代码给了我预期的结果：

但是，如果我尝试用地图替换它，如下所示，我得到的输出为FulfilledFuture(You just accessed hello)

我有一个返回字符串的 Akka HTTP 服务，如下所示：

我试图了解 map 和 flatMap 之间的区别

例如，下面的代码给了我预期的结果：

但是，如果我尝试用地图替换它，如下所示，我得到的输出为FulfilledFuture(You just accessed hello)

为什么我的 map() 没有按预期工作？

这是我试图通过喷雾 http 包 org.exadatum.xstream.service.http 创建 Post 请求的代码

我的休息服务正在运行。localhost:3000这样做会导致错误

我尝试了使用喷雾发送带有 json的帖子中提到的解决方案？

我是scala和spray的新手。我能够中止来自 reactJS 的请求。并且它在浏览器控制台的网络选项卡中显示请求被取消。但是从 scala 开始，它并没有中止。在日志中我可以看到 api 被击中。对于 Rest API，我在 scala 中使用喷雾。这是我的 reactJS 代码：

Ans 这是我的 scala 代码：

那么当它从 reactJS/promise 中止时如何中止这个完整的请求

我是斯卡拉的新手。我正在尝试使 api 请求超时。我正在使用喷雾来发出 API 请求。我有喷雾客户端从其他服务器获得响应。在我的 application.conf 中，我在 spray.can 中指定了请求超时，例如：

现在，我想在我的一个 api 中覆盖这个请求超时。我写了类似的api：

那么，如何将 request-timeout 放在这个方法中呢？通过覆盖 application.conf

我试过了

我得到了这个：