我想创建一个Source,然后像下面这样推送元素:val src = ... // create the Source here // and then, do something like this pushElement(x1, src) pushElement(x2, src) 请问怎样...
我将使用Scala和Akka Actors开发新的HTTP/REST服务。 我有使用Play的经验,但我并不需要完整的Web框架。从我所读的内容来看,我认为Spray是一个合适的选择。 我的问题是,随着新的AKKA-HTTP的到来,Spray项目的未来会怎样? Spray项目是否会独立于Akk...
我正在尝试使用Akka HTTP对我的请求进行基本身份验证。 恰好我有一个外部资源可以通过身份验证,因此我必须向这个资源发出rest调用。 这需要一些时间,在处理过程中,似乎我的API其余部分被阻塞,等待这个调用。 我已经用一个非常简单的例子重现了这个问题:// used dispatche...
所以我有一个函数,其参数是这样的(akka.http.model.HttpResponse):def apply(query: Seq[(String, String)], accept: String): HttpResponse 我只是在测试中获取一个值,例如:val resp = Tag...
我需要记录akka http客户端的请求以及它们的响应。虽然似乎有一些API可以记录这些请求,但没有清晰的文档说明应该如何实现。我的方法是创建一个已记录的请求,它透明地包装了Http().singleRequest(req),如下所示:def loggedRequest(req: HttpRe...
当涉及到使用akka http创建60多个API的REST web服务时,我该如何选择是使用akka streams还是akka actors?Jos在他的文章中展示了两种在akka http上创建API的方法,但他没有说明我应该在何时选择其中一种方式。
我正在对Akka-http框架(版本:10.0)进行负载测试,使用的是wrk工具。 wrk命令: wrk -t6 -c10000 -d 60s --timeout 10s --latency http://localhost:8080/hello 首次运行没有任何阻塞调用。object W...
有人能够解释一下Akka HTTP和Netty之间的主要区别吗?Netty还提供了其他协议,如FTP。Akka HTTP可以在Scala和Java中使用,并且基于Actor模型构建。但除此之外,两者都是异步的。我应该在何时使用Akka HTTP,在何时使用Netty?它们的典型用例是什么?
Akka HTTP和Spray提供了一个authenticateOAuth2指令,但是它们的文档说明: 该指令并未实现完整的OAuth2协议,而是通过从HTTP标头中提取所需的令牌来实现协议。 我也没有找到任何可以为Akka HTTP或Spray实现OAuth2的库。我是否遗漏了什么,...
Akka HTTP(以前称为Spray)的一个功能是能够自动将数据从JSON转换为案例类等,也可以自动将数据转换回JSON。我已经成功地使用这个功能。 目前,我正在尝试创建一个HTTP客户端,执行带有查询参数的GET请求。代码目前看起来像这样:val httpResponse: Future...