测试包含Akka Http cachedHostConnectionPool流的Akka流
Akka是一种基于Actor模型的并发编程框架，它提供了一种高效、可扩展的方式来构建分布式、并发的应用程序。Akka Http是Akka框架中的一个模块，用于构建基于HTTP协议的应用程序。
cachedHostConnectionPool是Akka Http中的一个流操作符，用于创建一个与指定主机建立连接的流。它会缓存已建立的连接，以便在后续的请求中重复使用，从而提高性能。
Akka流是Akka框架中的一个模块，用于处理数据流。它提供了一种响应式的、可组合的方式来处理数据流，可以进行各种转换、过滤、合并等操作。
测试包含Akka Http cachedHostConnectionPool流的Akka流是指在使用Akka流处理数据流时，其中包含了使用Akka Http的cachedHostConnectionPool流操作符来与指定主机建立连接的过程。
这种流的应用场景可以是在构建分布式应用程序时，需要与其他服务进行通信。通过使用Akka Http的cachedHostConnectionPool流操作符，可以高效地与其他服务建立连接，并在数据流中传输数据。
腾讯云提供了一系列与云计算相关的产品，其中包括云服务器、云数据库、云存储等。这些产品可以帮助用户快速构建和部署基于云计算的应用程序。
关于Akka和Akka Http的更多信息，您可以参考腾讯云的文档和官方网站：
- Akka官方网站：https://akka.io/
- Akka Http官方文档：https://doc.akka.io/docs/akka-http/current/index.html
- 腾讯云云服务器产品介绍：https://cloud.tencent.com/product/cvm
- 腾讯云云数据库产品介绍：https://cloud.tencent.com/product/cdb
- 腾讯云云存储产品介绍：https://cloud.tencent.com/product/cos
相关·内容
关于如何最好地测试包含Akka Http流的Akka流，有什么想法吗？我正在努力使用下面的方法：
def akkaHttpFlow(server: String)(implicit actorSystem: ActorSystem, actorMaterializer: ActorMaterializer) = {
val uri = new java.net.URI(server)
val port: Int = if( uri.getPort != -1) { uri.getPort } else { 80 }
Http().cachedHostConnectionPool
浏览 7提问于2018-01-29得票数 0
我正在尝试创建一个示例akka流，该流接受CSV文件，将其更改为XML (使用已经存在的具有toXml函数的对象)，然后将其发布到端点。我创建的代码如下所示：
val poolClientFlow =
Http().cachedHostConnectionPool[Thing]("localhost",5000)
val file = new File("./example.csv")
val uploadPipeline =
FileIO.fromFile(file)
.via(Framing.delimiter(ByteString(&#
浏览 1提问于2017-05-18得票数 1
回答已采纳
akka http文档在中提到，我们不应该在参与者的未来中使用access状态形式。
相反，这应该是使用的模式：
import akka.actor.Actor
import akka.http.scaladsl.Http
import akka.http.scaladsl.model._
import akka.stream.scaladsl.ImplicitMaterializer
class Myself extends Actor
with ImplicitMaterializer
with ActorLogging {
import akka.pattern.pipe
浏览 2提问于2016-02-03得票数 1
回答已采纳
我使用Source.queue对HttpRequests进行排队，并在客户端限制它，以便从远程服务器下载文件。我知道Source.queue不是线程安全的，我们需要使用MergeHub来使它成为线程安全。下面是使用Source.queue和cachedHostConnectionPool的代码片段。
import java.io.File
import akka.actor.Actor
import akka.event.Logging
import akka.http.scaladsl.Http
import akka.http.scaladsl.client.RequestBuildin
浏览 0提问于2017-09-22得票数 3
我在java项目中使用akka框架来处理HTTP服务，这就是为什么我使用javaDSL来处理akka流。所以，下面是我的故事。我创建了http缓存池(在我的参与者中)：
val pool = Http.get(getContext().system()).cachedHostConnectionPool(
"https://somehost.com",
ActorMaterializer.create(getContext().system())
)
然后我创建了一个基于HttpRequest的源代码：
val sourc
浏览 12提问于2016-09-09得票数 2
1回答
我是非常新的akka-http，我想流一个csv与任意数量的行。
例如，我想返回：
a,1
b,2
c,3
使用以下代码
implicit val actorSystem = ActorSystem("system")
implicit val actorMaterializer = ActorMaterializer()
val map = new mutable.HashMap[String, Int]()
map.put("a", 1)
map.put("b", 2)
map.put("c", 3)
val `text/c
浏览 2提问于2016-10-27得票数 1
我必须实现一个进程，它从队列中轮询消息并将数据转发到http端点。通常，我认为最好的方法是使用Akka流(带有akka http)，因为它为您处理背压等。问题是，我必须在运行时(基于http调用)创建多个不同配置的管道。另一个要求是，应该可以在运行时动态地停止其中的一个管道，然后用另一个配置启动它。
目前，我不确定是否真的能够在运行时动态地旋转新的平行akka流管道(并删除和重新启动其中的一些管道)。对我来说，现在使用akka演员做这个听起来更好(基于队列使用者参与者和akka http参与者，我和我可以在运行时动态地创建一对)，但是要使用它们，我还必须手动实现背压等等。
你认为可以通过akk
浏览 1提问于2018-07-02得票数 0
回答已采纳
让我们想象一下基于akka-streams和akka-http的代理应用程序，它接收(作为TCP服务器)一些本地格式的消息，从它们发出http请求，请求其他http服务器，将http响应转换回本地格式，并回复客户端。简化代码如下：
// as Client part
val connPool = Http().cachedHostConnectionPool[CustHttpReq](someHost, somePort)
val asClientFlow = Flow[CustHttpReq]
.via (connPool)
.map (procHttpResp)
def pr
浏览 10提问于2018-08-09得票数 0
回答已采纳
我正在尝试在akka-http websocket服务器和简单的javascript之间建立一个基本的连接。
在大约20个连接中，有1个成功，其余的失败。我不知道为什么连接的设置如此不可靠。
Application.scala：
import akka.actor.ActorSystem
import akka.http.scaladsl.Http
import akka.stream.ActorMaterializer
import services.WebService
import scala.concurrent.Await
import scala.concurrent.durat
浏览 0提问于2015-07-23得票数 2
1回答
我目前正在使用Akka-HTTP构建一个客户端WebSockets消费者。我不想尝试在接收器中进行解析，而是希望将代码包装在一个函数中，该函数发出来自接收器的结果，然后使用该输出(来自该函数)进行进一步处理(更多parsing...etc。)。 我现在可以打印来自Sink的每条消息；但是，函数的返回类型仍然是Unit。我的目标是为落入接收器的每个项目从函数发出一个String，然后使用返回的字符串进行进一步的解析。我已经有了到目前为止的代码(注意:它主要是样板代码)。 import java.util.concurrent.atomic.AtomicInteger
import akka.
浏览 11提问于2020-07-08得票数 0
回答已采纳
1回答
如何从Akka做SQL？
、、、、
从Akka应用程序发出SQL语句的惯用Akka方法是什么？
具体来说，我有一个Akka Http REST端点，它希望执行SQL命令。是否有正式的SQL支持或异步或消息传递样式的SQL库？
浏览 5提问于2017-02-22得票数 2
回答已采纳
1回答
我玩的是Akka Http客户端。我已经创建了一个简单的请求，但是我如何解组响应呢？在服务器端，使用circe编组响应很容易，但在客户端我遇到了困难
import akka.actor.ActorSystem
import akka.http.scaladsl.Http
import akka.http.scaladsl.model.Uri.Query
import akka.http.scaladsl.model._
import akka.http.scaladsl.unmarshalling.Unmarshal
import akka.stream.Materializer
impor
浏览 1提问于2017-01-12得票数 1
我试图使用akka以流的方式使用S3中的一组文件：
S3.listBucket("<bucket>", Some("<common_prefix>"))
.flatMapConcat { r => S3.download("<bucket>", r.key) }
.mapConcat(_.toList)
.flatMapConcat(_._1)
.via(Compression.gunzip())
.via(Framing.delimiter(ByteString("\n
浏览 3提问于2020-06-05得票数 1
对akka演员来说有点新鲜感
但是我想知道TestKit，TastActorRef和TestProbe之间的用法和区别
在akka单元测试中使用。
我见过它们用于单元测试akka系统，但似乎不理解这个概念
已尝试在互联网上搜索，但文档看起来很稀少。
欢迎任何简短的解释。
谢谢。
浏览 0提问于2012-10-23得票数 7
回答已采纳
我正在学习一个关于akka http的教程。但是想知道akka角色模型是如何在akka http中实现的。有人能解释一下吗？
浏览 2提问于2020-01-15得票数 0
我正试图向akka-http发送200k信息。
protected val someRouts: Route = pathPrefix("foo") {
pathEndOrSingleSlash {
put {
entity(as[Foo]) { foo =>
log.debug(s"/foo update $foo")
complete(Future(Foo("a")).map(f => s"Got - $f
浏览 5提问于2017-09-05得票数 1
回答已采纳
1回答
我第一次使用akka-http -我通常选择的web框架是，而我通常编写端点单元测试来处理akka-http-testkit提供的路由测试的方式遇到了问题。
通常，我使用ScalaTest (FreeSpec风格)来设置端点调用，然后对响应运行几个单独的测试。对于akka-http-testkit，如下所示：
import akka.http.scaladsl.model.StatusCodes
import akka.http.scaladsl.server.Directives._
import akka.http.scaladsl.server.Route
import akka.htt
浏览 10提问于2018-03-07得票数 2
Akka-http 说：
除了将服务器端的套接字绑定视为SourceIncomingConnection之外，还将每个连接视为带有SinkHttpResponse的SourceHttpRequest。
假设我们获得了包含来自多个SourceIncomingConnection的传入连接的合并源。
然后，假设我们从Source获得SourceHttpRequest。
然后，没有问题，我们可以提供一个流来将HttpRequest转换为HttpResponse。
问题就在这里--我们如何才能恰当地减少反应呢？我们如何加入对连接的响应？
用例背后的整个想法是优先处理来自不同连接的传入请求的可能
浏览 5提问于2015-12-16得票数 4
1回答
我想链接http请求使用akka-http-客户端作为流。链中的每个http请求取决于先前请求的成功/响应，并使用它来构造新请求。如果请求不成功，流应该返回不成功请求的响应。
我怎样才能在akka-http中构建这样的流呢？我应该使用哪个akka-http客户机级API？
浏览 1提问于2016-09-11得票数 8
回答已采纳
1回答
我是AKKA的新手(我使用的是java)。我不知道如何将zip文件传输到远程参与者。我应该使用akka-http吗？我尝试过akka-streams，但我不能理解如何将二进制文件传输到远程actors。
浏览 1提问于2017-09-19得票数 0
1回答
Akka流中的协调流
、、、、
我们正在使用Kafka，并且希望使用来访问我们州商店中的数据。我们有一个现有的服务，它使用Akka HTTP来提供REST，我们希望将交互式查询集成到流中。
似乎是一个完美的适合这一点。但是，它通过公开一个使用低级别API的route属性来集成到Akka，该API映射到一个Flow[HttpRequest, HttpResponse, Any]。我们之前的所有代码都使用Akka HTTP的路由DSL连接代码。
我希望像下面这样的代码能够工作，但它不能：
implicit val system:ActorSystem = ActorSystem("web")
implicit v
浏览 1提问于2018-10-17得票数 0
回答已采纳
2回答
我有一个现有的akka应用程序构建在socko websockets上。与套接字的通信在单个参与者内部进行，离开和进入参与者的消息(分别为传入消息和传出消息)被标记为套接字id，该套接字id是socko websocket的第一类属性(在socko中，连接请求到达带有id标记的连接请求，所有生命周期转换(例如握手、断开连接、传入帧等)都有类似的标记)。
我想使用akka-http重新实现这个单独的参与者(目前，由于明显的原因，socko或多或少是放弃软件)，但这并不简单，因为这两个库在概念上非常不同；akka-http隐藏握手、断开连接等的较低级别的细节，只需发送任何一个参与者绑定到http服
浏览 0提问于2016-05-26得票数 2
回答已采纳
我最近实现了一个akka流流，它解析一些json消息，验证给定密钥(destination_region)的存在，并将包含原始消息和destination_region字符串的case类传递到下一阶段。
我实现了一个自定义决定器，以便当它面临任何解析或键错误时，它将在记录异常后触发Supervision.Resume。
一个极简的实现看起来应该是：
package com.example.stages
import com.example.helpers.EitherHelpers._
/*
import scala.concurrent.Future
import scala.util.{
浏览 0提问于2018-04-30得票数 1
回答已采纳
我们有以下架构 SQS (源) SQS轮询器->我们的业务逻辑->接收器，它从SQS中删除消息。 这是一个akka流(我们的业务逻辑有多个阶段)。 现在，我们希望通过添加HTTP服务器(而不是Akka HTTP)来扩展此体系结构。 现在我们的服务也有了一条路径 HTTP服务器->我们的业务逻辑->接收器，它完成了一个未来，表明HTTP响应已经完成。 现在，每当HTTP请求到来时，我都需要一种机制来调用流。 现在，SQS源代码本质上是一个长时间运行的线程，它调用服务并将消息推送到akka流的其余部分。 我本质上是在尝试创建一个“可调用的”akka源代码，这样只有当我们收
浏览 14提问于2019-01-09得票数 0
回答已采纳
1回答
我尝试编写一些简单的基于akka-http和akka流的应用程序，它处理http请求，总是使用一个预编译的流，因为我计划在我的requestProcessor流中使用长时间的背压处理。
我的应用程序代码：
import akka.actor.{ActorSystem, Props}
import akka.http.scaladsl._
import akka.http.scaladsl.server.Directives._
import akka.http.scaladsl.server._
import akka.stream.ActorFlowMaterializer
import a
浏览 1提问于2015-06-09得票数 0
回答已采纳
2回答
我知道在ActorMaterialzer上使用监控策略重新启动akka流是可能的
val decider: Supervision.Decider = {
case _: ArithmeticException => Supervision.Resume
case _ => Supervision.Stop
}
implicit val materializer = ActorMaterializer(
ActorMaterializerSettings(system).withSupervisionStrategy(decid
浏览 2提问于2016-03-31得票数 5
回答已采纳
1回答
你如何节流在最新的阿克卡(2.4.6)？我想节流Http客户端流，将请求的数量限制在每秒3个请求。我在网上发现了下面的例子，但是对于老Akka和akka-streams API变化太大了，我想不出如何重写它。
def throttled[T](rate: FiniteDuration): Flow[T, T] = {
val tickSource: Source[Unit] = TickSource(rate, rate, () => ())
val zip = Zip[T, Unit]
val in = UndefinedSource[T]
val out = Unde
浏览 2提问于2016-05-24得票数 4
回答已采纳
1回答
分离akka流的模式
、、、
我正在选修Akka Streams Udemy课程，提供了以下代码：
package multiflow;
import akka.NotUsed;
import akka.actor.typed.ActorSystem;
import akka.actor.typed.javadsl.Behaviors;
import akka.stream.ClosedShape;
import akka.stream.FlowShape;
import akka.stream.SinkShape;
import akka.stream.SourceShape;
import akka.stream.j
浏览 0提问于2022-01-27得票数 0
回答已采纳
我正在将一个应用程序从Spray迁移到Akka HTTP。在配置中，我有：
spray {
can {
client.request-timeout = infinite
}
}
Akka HTTP的等效配置是什么？现在看来，request-timeout只在server上可用，而不是在client上。
请参阅
浏览 12提问于2016-12-03得票数 0
回答已采纳
如何从Akka HTTP路由向Akka Sink发送元素/消息？我的HTTP路由仍然需要返回一个正常的HTTP响应。
我想这需要一个溪流分支/交界处。正常的HTTP路由是来自HttpRequest -> HttpResponse的流。我想添加一个分支/连接，这样HttpRequests就可以在我的独立接收器中触发事件，并生成正常的HttpResponse。
下面是一个非常简单的单路径akka-http应用程序。为了简单起见，我使用了一个简单的println接收器。我的生产用例，显然会涉及一个不那么琐碎的接收器。
def main(args: Array[String]): Unit =
浏览 2提问于2017-02-24得票数 5
回答已采纳
我正在尝试使用akka-streams和akka-http以及alpakka库下载/上传文件到亚马逊S3。我看到两个可能相关的问题..。
我只能下载非常小的文件，最大的一个8kb。
我不能上传更大的文件。它与消息失败。
处理请求时出错：“子流源没有在5000毫秒内物化”。完成500内部服务器错误响应。若要更改默认异常处理行为，请提供自定义ExceptionHandler。akka.stream.impl.SubscriptionTimeoutException:子流源没有在5000毫秒内物化
这是我的路线
pathEnd {
post {
浏览 4提问于2017-09-19得票数 2
2回答
我对akka-http非常陌生，在同一条路径上并行运行查询有困难。
我有一个路由，可以非常快地返回结果(如果缓存的话)或不返回结果( CPU多线程计算量很大)。我想并行地运行这些查询，如果一个简短的查询在计算量很大的长查询之后到达，我不希望第二个调用等待第一个查询完成。
但是，如果这些查询位于相同的路由上(如果在不同的路由上并行运行)，则这些查询似乎不会并行运行。
我可以在一个基础项目中复制它：
将服务器并行调用3次(在上使用3 Chrome选项卡)将使响应分别达到3.0s、6.0s和9.0s。我认为查询不会并行运行。
在Windows 10和jdk 8的Windows 10上运行6核(使用H
浏览 4提问于2016-11-10得票数 5
我正在尝试将集成到一个严重依赖的应用程序中。该应用程序还利用了。
我在运行时遇到了依赖问题。特别是，当我尝试使用Mongo连接器提供的NoClassDefFoundError方法时，我得到了一个成功/失败包装器的MongoSink.insertOne。一个完整的堆栈跟踪：
java.lang.NoClassDefFoundError: com/mongodb/reactivestreams/client/Success
at akka.stream.alpakka.mongodb.scaladsl.MongoFlow$.$anonfun$insertOne$1(MongoFlow.sc
浏览 0提问于2020-12-30得票数 0
回答已采纳
我已经添加了最新的akka-http到我的项目，但这包括非常老的2.4.19版本的akka-演员。因此，我还在依赖项中添加了akka-参与者版本2.5.4。然而，这会导致以下错误：
Detected java.lang.NoSuchMethodError error, which MAY be caused by incompatible Akka versions on the classpath.
我的maven配置如下：
<dependencies>
<dependency>
<groupId>com.typesafe.akka
浏览 1提问于2017-08-27得票数 2
回答已采纳
给定Scala中的下列单例对象：
package demo
import akka.actor.ActorSystem
import akka.http.scaladsl.Http
import akka.http.scaladsl.server.Directives._
import akka.stream.ActorMaterializer
import scala.concurrent.Future
import scala.io.StdIn
object WebServer extends App {
implicit val system = ActorSystem(&#
浏览 0提问于2016-04-19得票数 3
回答已采纳
我基本上是想以适当的方式理解角色模型。在下面的代码中，我想了解什么是akka actor，actor，actor actormaterializer，actor dispatcher和dispatcher。
import akka.actor.ActorSystem
import akka.http.scaladsl.Http
import akka.http.scaladsl.server.Directives._
import akka.stream.ActorMaterializer
import scala.io.StdIn
object MainRunner extends Ap
浏览 8提问于2017-01-17得票数 0
1回答
val behavior: Behavior[Message] = Behaviors.setup {
actorContext ⇒
logger.info("starting...")
implicit val actorSystem = actorContext.system.asInstanceOf[ActorSystem]
implicit val materializer = ActorMaterializer()(actorContext.asInstanceOf[ActorContext])
implicit val exec
浏览 0提问于2018-04-03得票数 5
回答已采纳
1回答
是否有任何无缝机制来执行来自Akka的restful请求(只使用带有java的akka )。有一个喷雾客户端，但它接缝，没有api的java或ssl支持。
此外，还有Akka-Http包，但仍然是实验性的，我找不到客户端api的描述。
到目前为止，我有一种方法来使用jersey ()，并将同步调用隐藏在Akka路由器后面，由一些参与者来完成这项工作。
还有其他建议吗？
浏览 1提问于2015-09-29得票数 2
回答已采纳
1回答
我在用可重新启动的源和接收器处理akka流中的错误。
object Main extends App {
implicit val system: ActorSystem = ActorSystem("akka-streams-system")
val restartSettings =
RestartSettings(1.seconds, 10.seconds, 0.2d)
val restartableSource = RestartSource.onFailuresWithBackoff(restartSettings) {() => {
浏览 8提问于2022-01-10得票数 1
回答已采纳
我有很多的网址，我想得到使用Akka HTTP，并使用流。
URL的格式可能不正确，或者DNS可能无法解析主机名。在这些情况下，我希望superPool()流作为TryHTTPResponse简单地返回一个失败，而不是抛出异常并终止整个流。
我该怎么做呢？我已经搜索过了，但什么也没有找到，也找不到一种方法来处理文档本身中的esceptions。
编辑:在摆弄了一下之后，我发现唯一的问题是HTTPS urls，即使这样流也没有关闭，但我在控制台上打印了错误，这是不应该发生的。下面是一个复制的小示例：
import akka.stream.scaladsl.{Sink, Source}
i
浏览 8提问于2020-05-07得票数 0
回答已采纳
1回答
我发现了一个例子，在这个例子中，akka-http与Source.single一起使用来发出请求。现在，我想使用Source.tick来实现轮询请求，每X秒执行一次，如下所示：
import akka.http.scaladsl.model._
import scala.concurrent.duration._
val request: HttpRequest = RequestBuilding.Get(Uri("http://api.someSite.com"))
val source: Source[HttpRequest, Cancellable] = Source.
浏览 3提问于2017-07-10得票数 1
回答已采纳
1回答
为了解决以下问题，我尝试使用akka-streams和akka-http：
我们有两个http客户端(A和B)发送请求到一个http服务器(C)。双方使用akka-http进行通信。
与B相比，来自A的请求具有更高的优先级，但这两个请求都应该是相同的进程。所以C应该先处理来自A的请求，B的请求是第二优先
当然，我们希望每一端都有背压。
为了将传入的连接合并到一个输出中，我提出了以下代码：
val g = RunnableGraph.fromGraph(FlowGraph.create() { implicit b: FlowGraph.Builder[Unit] =>
浏览 5提问于2015-12-16得票数 0
回答已采纳
如何在argo和kubernetes中运行akka streams应用程序，我找到了关于kubernetes和akka集群的文档，但我不需要akka集群，我只需要运行一个具有许多参与者的短暂akka应用程序；还是akka集群是必要的？
浏览 29提问于2021-02-12得票数 0
回答已采纳
我尝试过: EventStream -> Source -> Akka HTTP (SSE)
在我看来，这是行不通的，因为源将由Akka HTTP complete(Source, ...)实现，并将消息从EventStream发送到我需要的物化源(有办法获得ActorRef吗？)
我在GitHub上找到了一个解决方案，它使用ActorPublisher：
但是由于ActorPublisher是一个内部API，我仍然希望得到干净的解决方案。
浏览 3提问于2017-11-29得票数 0
回答已采纳
我想让一个演员打电话给一个简单的休息服务。为此，我使用了akka-http-experimental_2.11和akka-http-jackson-experimental_2.11。尽管我可能会尝试，但我找不到一个可理解的java示例。调用将进行异步，并将响应映射到POJO。
你能帮忙吗？我迷失在Sinks，Flows和CompletionStage<HttpResponse>s之间。
谢谢java hAkkers :)
浏览 1提问于2016-07-05得票数 0
我有未定义数量的akka-http客户端流下载数据从一个http服务。我使用akka-http主机级连接池，因为我想定制这个池，因为通过它会有长时间运行的请求。
由于客户端的数量是未定义的和动态的，所以我不知道如何配置连接池(max-open-requests/max-connections)。此外，我可能希望连接池很小(少于客户端的数量)，以避免破坏带宽。
因此，我希望设置一个客户端流，以便对池的新连接和请求进行反向压力：
1.这是否意味着我需要一个单一的物化客户流？
2.我如何实现尽可能多的客户流，这样，如果没有可用的连接(来自下游的需求)，请求将受到压力。
我的第一次尝试是，但是这个方法
浏览 2提问于2017-12-11得票数 2
我们开始实现docs：中提到的模式。
这是文档中的(精简)示例。
val poolClientFlow = Http()
.cachedHostConnectionPool[Promise[HttpResponse]]("akka.io")
val queue =
Source.queue[(HttpRequest, Promise[HttpResponse])](
QueueSize, OverflowStrategy.dropNew
)
.via(poolClientFlow)
.toMat(Sink.foreach({
浏览 2提问于2017-05-29得票数 5
今天，我想在ImpermamentDatabase页面上编写一些使用Neo4j的测试：它说，为了包含测试类，neo4j-kernel jar必须与<type>test-jar</type>一起添加。
现在，这是我的build.sbt
name := """scheduling-backend"""
version := "1.0"
scalaVersion := "2.10.2"
resolvers += "spray repo" at "http://repo
浏览 0提问于2014-02-26得票数 0
回答已采纳
1回答
我正在尝试创建一个基本的http客户端，使用Akka HTTP将一些数据发布到REST API，但我无法使以下代码工作：
def sendData(e : GenericEvent): Future[Either[(String,StatusCode),(GenericEvent,StatusCode)]] = {
val request = Marshal(e).to[RequestEntity]
val responseFuture: Future[HttpResponse] = request map { req =>
Source.single(HttpRequest(me
浏览 0提问于2016-01-15得票数 0
我正在使用Akka流从AWS S3桶读取.gz文件，应用程序读取数据块并对其进行处理。
当我从一开始读取文件时，下面的代码运行良好，但是如果我从特定的偏移量启动文件，则解压缩失败并抛出ParsingException。
代码：
object StreamApp extends App {
// Run 1
//startStreaming(0)
// Run 2
startStreaming(33339)
def startStreaming(pointer: Long): Unit = {
println("Stream A
浏览 0提问于2018-02-26得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
