Akka http-如何将ResponseEntity解包到CustomClass？
我正在使用Akka http向第三方API发出请求。响应是“APPLICATION/JSON”，我想使用Akka http将它们转换成一个定制的案例类。我想做这样的事情： val request = RequestBuilding.Get("https://service.com/v1/api/items") val response : Future[ItemsResponse] = h
..
akka-http相关内容
如何使用反压溢出策略创建Akka-Http客户端？
我有未定数量的Akka-http客户端流从http服务下载数据。我使用Akka-http主机级连接池，因为我希望自定义池，因为有长时间运行的请求通过它。 因为客户端的数量是未定义的和动态的，所以我不知道如何配置连接池(max-open-request/max-connections)。此外，我可能希望连接池较小(少于客户端数量)，以不损害带宽。 因此，我想设置一个客户端流，以便对池的新
..
如何优雅地停止必须部署的 akka-http 服务器的参与者系统.
我刚刚使用 akka-http 创建了我的第一个 rest 服务器.问题是我不知道如何部署服务器，以便可以优雅地关闭 Actor 系统. 例如，我在这里找到了一些东西:https://stackoverflow.com/a/17399574/5388513 你可以使用 Akka 的微内核，但已弃用.我尝试使用 sbt-native-package，但我不知道如何优雅地关闭 actor 系统.
..
如何在断开连接后清理 akka-http websocket 资源然后重试?
下面的代码成功建立了一个websocket连接. websockets 服务器(也是 akk-http)使用 Andrew 在此处建议的答案故意关闭连接. 下面的 SinkActor 收到一条 akka.actor.Status.Failure 类型的消息，所以我知道从服务器到客户端的消息流已经中断.> 我的问题是...我的客户端应该如何重新建立 websocket 连接?sourc
..
Akka-http 在一个流中处理来自不同连接的 HttpRequests
Akka-http 文档 说: 除了将绑定在服务器端的套接字视为Source[IncomingConnection] 和每个连接作为一个Source[HttpRequest] 和 Sink[HttpResponse] 假设我们得到了包含来自许多 Source[IncomingConnection] 的传入连接的合并源. 然后，假设我们从 Source[IncomingConnec
..
Akka-http中获取客户端IP
我正在尝试编写一个 Akka HTTP 微服务(akka 版本 2.4.11，Scala 版本 2.11.8，在撰写本文时都是最新版本)，它知道客户端服务的 IP(即远程地址)，并且我无法让它工作. 我可以创建并运行显示“您好！"的服务使用这样的路线: val routeHello: Route = path("SayHello") {得到 {实体(作为[字符串]){身体 =>完全的 {
..
akka-http 中的连接池使用源队列实现线程安全吗?
参考下面提到的实现: http://doc.akka.io/docs/akka-http/10.0.5/scala/http/client-side/host-level.html val poolClientFlow = Http().cachedHostConnectionPool[Promise[HttpResponse]]("akka.io")val 队列 =Source.queu
..
Akka Http 客户端:自定义标头
我正在尝试使用 Akka-Http 来调用 REST url.我正在关注 这个 来自 akka 文档的例子.使用它，我可以拨打其余的电话.但我不知道如何添加自定义请求标头.我尝试使用 ModeledCustomHeader，但请求仍然没有标头.这是我的例子. final class ApiTokenHeader(token: String) extends ModeledCustomHeader
..
akka-stream + akka-http 生命周期
TLDR:当我将传出 http 请求作为流的一部分时，是按请求具体化一个流(即使用短期流)还是跨请求使用单个流具体化? 详细信息:我有一个典型的服务，它接受一个 HTTP 请求，将其分散到几个 3rd 方下游服务(不受我控制)并在将结果发回之前聚合结果.我将 akka-http 用于客户端实现，并使用 Spray 作为服务器(传统，随着时间的推移将转移到 akka-http).示意图:
..
我应该使用 akka.http.scaladsl.util.FastFuture 而不是 scala.concurrent.Future?
我应该使用 akka.http.scaladsl.util.FastFuture 而不是 scala.concurrent.Future 吗? 评论说: /*** 提供在 [[scala.concurrent.Future]] 上定义的基本转换操作的替代实现，* 尽可能避免调度到 [[scala.concurrent.ExecutionContext]] ，即如果给定的未来* 值已经存在.
..
Akka Stream + Akka Http - 获取错误请求
我有以下流，效果很好: 源代码.map(x => HttpRequest(uri = x.rawRequest)).via(Http().outgoingConnection(host, port)).to(Sink.actorRef(myActor, IsDone)).跑() 还有一个简单的actor来处理流完成时的响应状态和最终消息: /*** 一个简单的actor来计算已经处理了多少行
..
java.lang.NoSuchMethodError: akka.actor.ActorCell.addFunctionRef
我正在尝试设置一个简单的 akka-http 2.4.2 项目来测试它，但我没有这样做. 我的built.sbt: import NativePackagerHelper._懒惰的 val akkaVersion = "2.4.2"懒惰的 val root =(文件中的项目(“.")).设置(名称 := "akkTest",版本:=“0.1"，scalaVersion := "2.11.7
..
如何在响应流中将消息从订阅者发送到 Web 套接字连接中的发布者
我的应用程序有一个 Akka-Websocket 接口.Web 套接字由参与者订阅者和参与者发布者组成.订阅者通过将命令发送给相应的参与者来处理命令.发布者侦听事件流并将更新信息发布回流(并最终发布到客户端).这很好用. 我的问题:订阅者如何将事件发送回流?例如确认接收到的命令的执行. public class WebSocketApp extends HttpApp {private s
..
使用 Akka HTTP(正式名称为 Spray)的 GET 请求的查询参数
Akka HTTP(正式名称为 Spray)的功能之一是它能够自动将数据从 json 来回编组和解组到 case 类等中.我已经成功地让它正常工作. > 目前，我正在尝试制作一个使用查询参数执行 GET 请求的 HTTP 客户端.目前的代码如下所示: val httpResponse: Future[HttpResponse] =Http().singleRequest(HttpReques
..
Kubernetes - Akka 集群部署
我们有一个 docker 镜像和一个对应的 yaml 文件，用于使用 kubernetes 进行部署.我们构建的应用程序是在带有 akka-http 的 Scala 中.我们使用了 akka-cluster.我们在使用 pod ip 的应用程序代码中使用的配置文件中有一个特定的变量(在我们的例子中是种子节点 - akka 集群).但是，除非部署完成，否则我们不会获得 pod ip.我们应该如何着手
..
使用 Akka 将文件从服务器流式传输到客户端
基本上我想允许用户从服务器下载 csv 文件.假设 CSV 文件已存在于服务器上.API 端点通过 GET/export 公开.如何将文件从 Akka HTTP 服务器流式传输到客户端?这是我到目前为止... 服务: def export(): Future[IOResult] = {FileIO.fromPath(Paths.get("file.csv")).to(Sink.ignore
..
Akka Flow 在通过连接池发出 http 请求时挂起
我正在使用 Akka 2.4.4 并尝试从 Apache HttpAsyncClient 迁移(未成功). 以下是我在项目中使用的代码的简化版本. 问题是，如果我向流发送超过 1-3 个请求，它就会挂起.到目前为止，经过 6 个小时的调试，我什至无法找到问题所在.我在 Decider 中没有看到异常、错误日志、事件.什么都没有:) 我尝试将 connection-timeout
..
如何使用 Akka HTTP 从多个参与者/网络处理程序正确调用单个服务器?
我有一个服务(我们称之为服务 A)，它使用 Akka Server HTTP 来处理传入的请求.此外，我还有提供多种 Web 服务的第 3 方应用程序(服务 B).服务 A 的目的是转换客户端请求，调用服务 B 的一个或多个 Web 服务，合并/转换结果并将其返回给客户端. 我在某些部分使用 Actors，而在其他部分使用 Future.为了调用服务 B，我使用 Akka HTTP 客户端.
..
Scala 中的函数/方法.这是如何运作的?
我是 Scala 的新手，很难理解所有声明和使用函数的方法.有人可以一步一步解释这里发生了什么吗? 我正在学习介绍 Akka HTTP 的课程.代码有效，但我不明白路由方法: import akka.http.scaladsl.server.Directives._def route = path("你好") {得到 {完成(“你好，世界！")}} 我们正在定义一个方法 route，它被
..
在流中链接 Akka-http-client 请求
我想使用 akka-http-client 作为 Stream 链接 http 请求.链中的每个 http 请求都依赖于先前请求的成功/响应，并使用它来构建新的请求.如果请求不成功，Stream 应该返回不成功请求的响应. 如何在 akka-http 中构建这样的流?我应该使用哪个 akka-http 客户端级 API? 解决方案 如果您正在制作网络爬虫，请查看 这篇文章.该答案解决
..