38得票7回答
Akka HttpResponse如何将body读取为String(使用Scala)

所以我有一个函数,其参数是这样的(akka.http.model.HttpResponse):def apply(query: Seq[(String, String)], accept: String): HttpResponse 我只是在测试中获取一个值,例如:val resp = Tag...

10得票1回答
如何在Akka HTTP中匹配所有路径

大多数Akka HTTP示例都表明,使用path定义Routes非常容易。我有以下(稍微简化)自入门示例中获得的内容:val route = path("hello") { complete( HttpEntity( ContentTypes.`text...

13得票1回答
使用Akka路由DSL获取HTTP头信息

我刚接触Scala,遇到了这个问题,很沮丧。如何从请求中获取所有的头信息?val route = { path("lol") { //get httpHeaders complete(HttpResponse()) } }

8得票1回答
如何在Akka-http 2.4.1中包含application/x-www-form-urlencoded的HttpHeader?

我正在使用Akka Http 2.4.1向Twitter API发送https请求。 根据他们的文档,我需要两个http头。即Authorization和ContentType。 引用他们的文档: 请求必须包括一个Content-Type标头,其值为application/x-www-f...

8得票1回答
Akka-http流式传输使用Slick 3.0数据库发布程序

我正在使用slick 3.0,并且有一个databasepublisher对象 def getAsStream = db.stream[Entity](tblquery.result) 我将使用akka-http作为rest层,如下所示: val route = path("stre...

9得票1回答
Akka HTTP API路由结构

我正在编写基于Akka-HTTP的REST API。由于我对Akka和Scala不是很熟悉,所以我不确定在项目中组织代码的最佳方式是什么。我将有大约7个不同的实体,每个实体都有基本的CRUD操作。这意味着API中将有超过25个路由。我希望根据逻辑关联将路由分组。如何实现这一点?目前,我从Git...

14得票2回答
使用Akka Streams有条件地跳过流程

我正在使用akka流,我的图中有一个部分需要有条件地跳过,因为该流无法处理某些值。具体来说,我有一个流程,它接收一个字符串并进行http请求,但是服务器无法处理字符串为空的情况。但我需要返回一个空字符串代替。有没有一种方法可以在不必知道请求会失败的情况下完成这个操作?基本上我有以下代码:val...

9得票2回答
如何使用Akka HTTP通过输出流生成内容

我对Akka Streams和Akka HTTP并不熟悉。 我想要创建一个简单的HTTP服务器,可以从文件夹中生成zip文件并将其发送给客户端。 org.zeroturnaround.zip.ZipUtil使得创建zip文件变得非常容易,但它需要一个outputStream。 以下是我的...

7得票1回答
在Actor内部进行Akka HTTP核心客户端请求是否可行?

下面是一个简单的Actor,需要通过HTTP调用从API接收数据。根据Akka HTTP核心请求级别客户端API,只需要隐式地使用ActorSystem和ActorMaterializer。 class MyActor extends Actor { import context.sy...

12得票3回答
使用Akka HTTP创建基本HTTP Post请求的惯用方式

我正在尝试使用Akka HTTP库创建基本的HTTP POST请求,以下是我得出的代码:val formData = Await.result(Marshal(FormData(combinedParams)).to[RequestEntity], Duration.Inf) val r = ...