Akka-http - 写入响应输出流
我需要创建一个大的制表符分隔文件作为对 HTTP GET 请求的响应.在我的路由中创建一些 Scala 对象，然后我想将这些对象的一些自定义表示写入输出流. 这不仅仅是序列化到制表符分隔而不是 JSON，因为我还需要创建一个带有列名的标题，所以恕我直言，这无法通过自定义封送处理来解决. 那么我怎样才能从 HttpRequest 中获得一个 writer 或 outputstream?
..
akka-http相关内容
如何读取akka-http中的查询参数?
我知道 akka-http 库在处理请求时对类类型进行编组和解组.但是现在，我需要读取 GET 请求的请求参数.我尝试了 parameter() 方法，它返回 ParamDefAux 类型，但我需要这些值作为字符串类型 我检查以下问题的答案. 我该如何解析在喷雾路由中获取请求参数? 查询参数对于使用 Akka HTTP(正式名称为 Spray)的 GET 请求 但不能做我需
..
如何测试客户端 Akka HTTP
我刚刚开始测试 Akka HTTP 请求级客户端 API(基于未来).我一直在努力弄清楚的一件事是如何为此编写单元测试.有没有办法模拟响应并完成未来而无需实际执行 HTTP 请求? 我正在查看 API 和 testkit 包，试图了解如何使用它们，结果却在文档中找到了它的实际内容: akka-http-testkit 用于验证服务器端服务实现的测试工具和实用程序集 我在想一些 T
..
如何在 akka http 路由中处理长时间运行的请求
我正在使用 akka http 我的路由之一是通过 akka http 客户端 api 与外部服务交互，并且 httpRequest 持续运行我无法使其工作这是我的用例->我正在与 janus 服务器进行交互，并在服务器以“keepAlive"或“事件"进行响应后立即执行长轮询获取请求.我再次请求，因此服务器不断响应 所有这一切都发生在一个演员内部，我有一个 akka htttp 路由，它正
..
Akka websocket - 如何通过服务器关闭连接?
这里是我的 websocket 服务器实现. val route = get {pathEndOrSingleSlash {处理WebSocketMessages(websocketFlow)}}def websocketFlow: Flow[Message, Message, Any] =流程[消息].collect { case TextMessage.Strict(textMessage)
..
找不到 Akka-HTTP 路由?
我正在学习使用 Akka-Http 构建服务器，这是我目前所写的 import akka.actor.ActorSystem导入 akka.http.scaladsl.Http导入 akka.http.scaladsl.server.Directives._导入 akka.stream.{Materializer, ActorMaterializer}导入 Spray.json.DefaultJ
..
swagger-akka-http 2.x 在响应中设置对象列表
我有问题.我想在使用 Swagger 的 API 响应中发送对象列表.type = "array" 对我不起作用.我看到一个主题 在 Swagger API 响应中设置对象列表，但它是旧版本的lib.注释已更改.ApiResponse 曾经有 responseContainer 参数，但现在没有了.我有 akka-http 服务器. val akkaVersion = "2.5.17"val a
..
将 index.html 作为 Akka HTTP 的 getFromDirectory 中的默认文件
假设我有一个文件夹 foo，其中包含一个 index.html 文件，以及下面用于 Akka HTTP 的以下最小(但很可能不起作用)服务器代码: object Server 扩展 App {价值路线:路线=路径前缀(“富"){getFromDirectory("foo")}Http().bindAndHandle(route, "0.0.0.0", 8080)} 如果我在浏览器中打开 htt
..
Akka http -ERROR :Substream Source 不能被物化不止一次如果 Payload 大小增加
我正在使用 Akka Http，在那里我将路由定义为 val route = (path(HttpConstants.CreateJob) & post) {(entity(as[JobDetailsEntity]) & entity(as[JobEntity])) {(jobDetailsEntity: JobDetailsEntity, jobEntity: JobEntity) =>val
..
Akka HTTP“每个请求的参与者"图案
目前我正在尝试实施 "actor-per-request" 模式由 NET-A-PORTER devs 在 Akka HTTP 中提出.我面临的问题是文档中的任何地方都没有记录这种模式.似乎没有办法做到以下几点: IO(Http) !Http.Bind(serviceActor, "localhost", port = 38080) 如何在不使用 Spray 的情况下为每个请求使用一个 Akk
..
将Akka HTTP重定向到HTTPS
当前，我有一个可同时用于HTTP和HTTPS的API，但是即使URL是使用HTTP调用的，我也需要将其仅路由到HTTPS.例如，两者都在工作: http://app1_0.cloud.example.net/getSomethinghttps://app1_0.cloud.example.net/getSomething Akka文档中有一些关于为证书添加 httpscontext 的内容
..
类型与akka.http.scaladsl.server.Route不匹配
我已经使用akka http创建了一个http服务器，如下所示： import akka.actor.typed。{ActorRef， ActorSystem} 导入akka.http.scaladsl.Http 导入akka.http.scaladsl.server.Route 导入com.sweetsoft.LoggerActor.Log 导入akka.actor.typed
..
如何以编程方式执行拒绝处理程序的Route并获取结果HttpEntity？
如何以编程方式执行拒绝处理程序的 Route 并得到结果 HttpEntity ？ 例如，假设我有 RequestContext 对象和 Rejection 对象在其上执行 RejectionHandler.default 并获得 HttpEntity 。 这是我要执行的操作的示例： 隐式def myRejectionHandler = RejectionHandler.ne
..
使用Akka-http Java加载静态html文件
我一直在努力从一个简单的aka-http Java服务器中加载静态文件。我尝试了多种选择，但始终会遇到以下错误： [ERROR] [09/07/2018 11：52：06.258] [AkkaRestApiApp-akka.actor.default-dispatcher-4] [akka.actor.ActorSystemImpl（AkkaRestApiApp）]处理请求期间出错：“ j
..
将Akka HTTP部署到Azure
我一直在寻找有关如何将Akka Http应用程序部署到Azure的信息。 Azure支持Java Web Apps，但我认为它仅适用于在TomCat或类似版本中运行的应用程序。但是Akka Http是一个独立的应用程序-是否有对此的支持，无论如何，我应该如何进行处理？ 我知道sbt-native-packager可以产生各种可安装的格式，但是看到从Visual Studio部署.NET应用程
..
Akka http（联合国）马歇尔特质
我们假设以下代码： 密封特征操作{ def run（）：布尔值 } 案例类SimpleAction（parameter：String）扩展了动作{ //一些impl } 案例类ExtendedAction（parameter1：String， parameter2：字符串）扩展动作{ //一些隐含 } 现在我想定义一个可以检索操作的Web服务。我该如何将
..
如何在后台实现Akka HTTP封送处理？
将编译以下Scala代码： import spray.json.DefaultJsonProtocol._ import akka.http。 scaladsl.marshallers.sprayjson.SprayJsonSupport._ import akka.http.scaladsl.server.Directives.complete case class It
..
Akka-Http 2.4.9引发java.lang.NoClassDefFoundError：akka / actor / ActorRefFactory异常
我正在尝试使用Akka-http构建一个简单的Web服务。我遵循了此指南： http://doc.akka.io/docs/akka/2.4.9/scala/http/low-level-server-side-api.html ，当我运行sbt run时一切正常。 / p> 当我执行java -jar PROJECT.jar时，它会返回： 线程“主”中的异常java.lang.NoC
..
在连接源和接收器之前，等待客户端websocket流连接
我正在使用akka-streams设置客户端网络套接字。我正在尝试使用以下签名的方法封装安装程序： def createConnectedWebSocket（url：String）：Flow [消息，消息，_] 很明显如何创建Web套接字流，但未连接还没有： val webSocketFlow：流[消息，消息，将来[WebSocketUpgradeRespons
..
断开连接后如何清理akka-http websocket资源，然后重试？
下面的代码成功建立了一个Websocket连接。 websockets服务器（也称为akk-http）故意使用安德鲁的建议答案在这里。 SinkActor 下面收到类型为 akka.actor.Status.Failure 的消息，因此我知道从服务器到客户端的消息流已中断。 我的问题是...我的客户应如何重新建立websocket连接？ source.via（webSocketF
..