使用Akka Streams有条件地跳过流程
我正在使用akka流，我的图中有一个部分需要有条件地跳过，因为该流无法处理某些值。具体来说，我有一个流程，它接收一个字符串并进行http请求，但是服务器无法处理字符串为空的情况。但我需要返回一个空字符串代替。有没有一种方法可以在不必知道请求会失败的情况下完成这个操作？基本上我有以下代码：val...
Scala中的函数/方法。这是如何工作的？
我刚接触 Scala，对于声明和使用函数的方式感到困惑。请问有人能够逐步解释这里发生了什么吗？ 我正在学习介绍 Akka HTTP 的课程。代码可以运行，但是我不理解 route 方法的作用：import akka.http.scaladsl.server.Directives._ def...
如何将Akka HTTP请求实体解组为字符串？
我正在尝试将请求有效载荷作为字符串反序列化，但出现了某些问题。我的代码： path("mypath") { post { decodeRequest { entity(as[String]) {jsonStr => //could not find impli...
使用Akka路由DSL获取HTTP头信息
我刚接触Scala，遇到了这个问题，很沮丧。如何从请求中获取所有的头信息？val route = { path("lol") { //get httpHeaders complete(HttpResponse()) } }
使用Akka HTTP进行文件上传
我正在尝试使用Akka HTTP实现文件上传功能。 我正在使用akka-stream版本2.4.4。 这是代码（修改自akka-doc）path("fileupload") { post { extractRequestContext { ctx =>...
Circe - 在解析/编码json时使用case class中的默认字段
假设我有这个case类: case class Foo(bar: String, baz: Boolean = false) 该类用于解码/编码API请求/响应，使用akka-http-json 类似此示例：import akka.actor.ActorSystem import akk...
Akka HTTP抛出EntityStreamException: 实体流截断
我正在使用akka http库编写一个rest API的客户端。这个库看起来非常强大，但是对我来说它的工作非常不稳定。当我尝试消费HttpResponse.entity时，它经常（并非总是）抛出以下异常： EntityStreamException: Entity stream tru...
如何使用Akka Streams和HTTP将HTTP资源下载到文件中？
在过去的几天里，我一直试图找出使用Akka Streams和HTTP下载HTTP资源到文件的最佳方法。 最初，我从基于Future的变体开始，大致如下： def downloadViaFutures(uri: Uri, file: File): Future[Long] = { val...
如何在马歇尔中使用HTTP请求标头进行内容协商？
我的应用程序支持Protobuf和JSON序列化。对于JSON序列化，我使用com.trueaccord.scalapb.json.JsonFormat，我的数据传输对象（DTO）是从proto定义生成的。 com.trueaccord序列化器将选项类型包装为JSON对象，这会导致某些客户端...
使用Akka HTTP创建基本HTTP Post请求的惯用方式
我正在尝试使用Akka HTTP库创建基本的HTTP POST请求，以下是我得出的代码：val formData = Await.result(Marshal(FormData(combinedParams)).to[RequestEntity], Duration.Inf) val r = ...