Akka是一个开源工具包和运行时，简化了JVM上并发和分布式应用程序的构建。它实现了Erlang中已知的actor模型。
Akka Streams：向 QueueSource 提供 StreamDetachedException
我们有一个 DownloadFileFlow 类，它使用 Akka Streams 和 Akka Http 从不同域下载文件；有时（~50%）在向我们遇到的 QueueSource 提供服务时
我尝试在 homepet 项目中使用 akka-typed，但不知道如何正确找到演员或生成并发送消息。 我的第一次尝试：从接待员那里包装“清单”并通过适配器发送 - 非常......
我必须通过 supervision.decider 但在 akka 2.6.0+ Materializer 中没有类似的设置。 任何人都可以分享如何在更高版本中编写以下代码： 验证垫：ActorMaterializer =
我有一个带有路由和指令的 Akka-HTTP 项目，我想打印本地地址和端口号 Http().newServerAt("localhost", 8080).bind(myRoutes) 我想打印像
如果 postStop() 失败，我们如何重试/重启 graphStage？ 我对 akka 比较陌生，非常感谢您的帮助。 这是我正在尝试做的事情： 来源 .via(音频...
如何将自定义泛型类 Tree[T] 翻译成带有 Json 注解的 Json？
我想在 Akka 中使用 Json 序列化器序列化泛型树 [T]。 我声明了一个容器 Tree[T]。 性状 NodeId { def id: 整数 } 特质树[T<: NodeId] { def find(id: Int): Option[T]...
Akka Classic Routing (scala) optimal-size-exploring-resizer 的用途
我正在学习 Akka 经典路由。我已经学会了使用调整器并理解了这一点，但是有一个最佳尺寸探索调整器。我无法理解为什么我们需要最佳尺寸探索资源...
在具有高吞吐量和低延迟的系统上比较 Akka Actors pipToSelf 和 Future
我有一个关于 pipeToSelf vs Futures 的问题。 假设我们有一个 Scala Web 后端应用程序，它在具有 16 个内核的 n2d-standard-16 谷歌云机器类型上运行，其中每个节点托管一个 ...
错误( 没有找到参数responseSerializer的牵连。MessageSerializer[Seq[SearchFormData], _] )
在这里输入图片描述 在scala rest API中传递Seq[]作为响应时得到错误。而当我删除Seq时，工作正常。谢谢你
如何统计akkaHttp RejectionHandler的拒绝和成功？
我正试图计算由RejectionHandler返回的拒绝，我想我现在做这个的方式不是最好的，甚至是不正确的。我只是想在我的......中调用增量方法。
我使用persistenceActor工作，但当我调用persist()方法时，回调从未到达，我在终端actor中找不到任何错误代码 class MajorEventActor extends Timers with ...
我正在使用akka集群。每次akka创建Actor系统实例时，都会在临时目录下创建大量的aeron-{user}-clustersystem文件，占用了大量空间。请问...
如何在akka中通过ConsistentHashingPool向所有角色广播相同的字符串消息。
我是Akka的新手，被这个问题困扰着。我有4个演员，但不知何故，广播的消息总是去一个演员这里是一个示例代码def hashMapping: ConsistentHashMapping = { ...
我正在使用Akka Kafka连接器开发一个Kafka消费者应用程序。我希望消费者能够并行处理消息，我应该选择哪个消费者组 选择消费者？ 我如何能 ...
所以我明白，如果你给一个死掉的演员发送消息，消息会被转到DeadLetters，但是已经被该演员排队的消息会发生什么。它们是否也会被转发到那里......。
我有一个actor，它从Helper中调用了一个静态方法，我想对其进行模拟： public class ExampleActor extends AbstractActor { public Receive createReceive() { .match(CachedFile.class, ...)。
Akka HTTP：如何让流Http().superPool()在遇到坏的URL时不抛出异常？
我有很多URL，我想用Akka HTTP，用流来获取。这些URLs可能是错误的，或者DNS可能无法解析主机名。在这些情况下，我希望 ...
使用akka-typed，我试图创建一个事件来源的应用程序，在这个应用程序中，对一个actor的命令可以对另一个actor造成影响。具体来说，我有以下情况。RootActor BranchActor...
我使用Scala v2.13.1和AKKA HTTP v10.1.11。我有一个路由，结构如下： def foo(a: String): Directive1[String] = { provide(a) } def bar(a: String): Directive1[String] = { ...
我们使用Alpakka Kafka流来消费Kafka的事件。下面是流的定义。ConsumerSettings consumerSettings = ...