akka

由于某种原因，我无法创建演员（这是我的类层次结构的简单版本）： abstract class Class1[T <: Class2[_]: ClassTag] extends Actor { //.... val res = List(1, 2, 3) map { x => context actorOf Props(new T(x)) } // error } abs... »

我正在将应用程序从 Spray.io 迁移到 Akka-http。该应用程序是基于微服务的，我们在其上构建了许多小型库。以下是在一个特定微服务中组合指令和路由的示例： val routes = (decompressRequest & compressResponseIfRequested) { metricsRoute ~ healthStatusRoute ~ ... »

play framework doc (https://www.playframework.com/documentation/2.6.x/ScalaAkka) 中有一个例子，解释了如何将actor（需要注入的依赖项）注入控制器： @Singleton class Application @Inject() (@Named("configured-actor") configuredActor... »

我有一个 Actor 系统，它正在处理来自外部系统的连续流消息。我的系统中有以下演员。 SubscribeActor - 此 Actor 订阅 Redis 通道并创建一个新的 InferActor 并将 JSON 有效负载传递给它。 InferenceActor - 这个演员负责 2a.解析负载并从 JSON 负载中提取一些值文本值。 2b。调用外部REST service 将2a 中... »

我有一些零星的测试失败，并且很难找出原因。我有很多演员可以参加我想要测试的工作。在测试开始时，我传入了一个从 TestProbe() 获得的演员参考。稍后这组参与者做一些工作并将结果发送到给定的测试探针参与者参考。然后我用 TestProbe() 检查结果： class MyCaseSpec extends Spec with ShouldMatchers{ describe("The ... »

按照BroadcastHub 的示例，可以动态生成监听同一生产者的工作人员。但是这种生成必须在代码中显式完成。我想知道它是否可以编码为流中事件的反应。 在下面的示例中，我想在spawns 流中收到“Spawn”消息后再生成 2 个工人。有可能吗？ package com.example import akka.actor.ActorSystem import akka.stream.Act... »

我能找到的关于这方面的几个主题是针对 Scala 而不是 Java，并且没有一个针对远程参与者。 我有一个基本配置文件 (SERVER_CONFIG_FILE)： Include "akka-common" TheSystem { akka { actor { provider = "akka.remote.RemoteActorRefProvider" ... »

我实际上是在尝试将 Kamon 0.4.0 与我的 play (scala) 应用程序集成（顺便说一句很棒的框架！）。 这是我所做的： 在我的 build.sbt 中添加了以下依赖项： libraryDependencies ++= Seq( jdbc, anorm, "com.typesafe.play" %% "play-mailer" % "2.... »

我是 akka + playframework 的新手。我一直在 play async action 方法中使用直接 slick run 方法。 run(. ... ) 方法返回 Future[T]。现在我的问题是 - 可以在控制器的 play 异步操作中使用 actor ask 方法来执行 slick run 方法吗？ package controllers import akka.acto... »

我正在尝试使用 Akka HTTP 向我的本地主机发送一个 get 请求，但出现以下异常： EntityStreamSizeException: actual entity size (Some(10166731700)) exceeded content length limit (8388608 bytes)! You can configure this by setting akka.h... »

我想传递一个通用类，如下面的代码所示，但我遇到了一个异常： Incompatible equality constraint `Pair<A, B>` and `Pair`. 我该如何纠正它？还是有其他方法？ 注意：Flow.of(Pair<A, B>.class) 不起作用。我如何通过Pair<A, B> 而不是Pair？ Flow<Pair... »

Akka 文档说here： ask 操作涉及创建一个内部 actor 来处理这个回复，它需要有一个超时时间，之后它会被销毁，以免泄漏资源 有什么办法可以阻止这种内部演员的创建？... »

我有一个服务公开一个 REST 端点，经过几次转换后，它也通过其 REST 端点调用第三方服务。 我想对我的服务实施某种限制，以避免被此第三方服务限制。请注意，我的服务端点只接受一个请求，而不是它们的列表。我正在使用 Play，我们也有 Akka Streams 作为依赖项。 我的第一个想法是让我的服务将请求保存到数据库表中，然后使用 Akka Streams Source，利用 throt... »

我在 akka 流中实现了一个自定义组件，它将元素作为输入，根据一个键对它们进行分组和合并，然后通过十几个出口中的一个将它们发送出去。您可以将此组件视为一种 GroupBy 组件，它不会将流划分为子流，而是实际流。除了对传入的元素进行分区之外，它还将它们合并为一个元素，即组件内部发生了一些缓冲，因此 1 个元素输入并不一定意味着 1 个元素通过出口输出。 以下是所述组件的简化实现。 class... »

我有一个用例，我需要通过 websocket 将实时事件传递给客户端。我想为此使用Kafka。使用来自 kafka 的 msg 并通过 websockets 流式传输。但是，当客户端断开连接时，他需要从中断处获取数据。因此，对于这个寻求必须与新的消费者一起完成，并且普通消费者不应该传递消息，直到该客户端的先前消息已经传递。所以我觉得kafka不可能最适合这种情况。因为可以有很多客户从不同的偏移量询... »

我知道如何在 Akka 中 handle incoming http requests，但我希望我的基于 Akka 的 Web 应用程序也可以通过 HTTP API 通过发送出站调用与 Facebook 和 CouchDB 进行通信。有什么好的做法吗？调用应该是异步的吗？ ... »

使用akka-http，如何构造一个Flow[Message, Message, _] 传递给handleWebsocketMessage 只监听传入数据但不写回任何内容？无论如何都可以使用接收器吗？因为 Sink 听起来像是我需要的。... »

是否可以使用 Akka 框架在 Scala 中实现 JMS 消息队列？ Scala，而不是 SCALA。不用大喊大叫。... »

我是 akka 和 akka 远程处理和 akka 集群的新手。我已经构建了一个具有以下配置的系统 Application.conf akka { actor.provider = "akka.cluster.ClusterActorRefProvider" extensions = ["akka.contrib.pattern.ClusterReceptionistExtensi... »

Akka Streams 文档明确指出，要使流可运行，它必须有恰好一个源和恰好一个接收器。我想知道是什么强加了这种约束。将多个源合并为一个从单个流分叉的多个接收器的场景都是非常合理的。是否有任何技术原因支持这种限制？ ... »