akka 相关问题

执行 archetype:generate 时，Maven 错误 No POM in this Project

我正在尝试 Akka Pi java 教程 我正在尝试创建一个 Maven 项目，如教程中所述 但每当我输入命令来创建 Maven 项目时，我都会收到错误。 是...

Scala 折叠函数检测 Seq[String] 中值的出现

我正在尝试编写一个 scala 函数来检测目标站点 id (targetedSiteIds) 序列中是否存在站点 id (site_id)。 如果Seq中存在站点id，则函数filterSite...

集群分片钝化中每个实体类型活动实体限制

我有一个集群系统，其中有许多不同的实体类型，具有不同的内存和计算复杂性特征，并且希望在我的钝化圣中使用活动实体限制...

无法使用 Scala 从 SBT 加载最新的 Akka

我在这里加载了一些Akka库，实际上是我的项目中唯一的依赖项。它基于 Scala，非常简单，这是我的 build.sbt 的片段： scala版本 := "3.4.2"

使用 Akka 的 Actor 进行异步消息处理

在我的项目中，我使用 Akka 的 Actors。根据定义，Actor 是线程安全的，这意味着在 Actor 的 receive 方法中 def 接收 = { 案例消息 => // 这里有一些逻辑 } 只有一个

如何使用akka事件源读取特定时间点的日志

我目前正在尝试结合 CQRS 和 akka 事件源来实现类似 git 的存储。写入路径是通过 EventSourcedBehavior actor 实现的（将其称为 GitComm...

Akka 类型演员发现

我正在学习Akka远程处理和集群。当我尝试向远程 Actor 发送消息时，我没有得到预期的行为。 部署在 localhost:2552 上的远程 Actor 哦...

更新到 2.5.2 Akka 版本后出现错误：java.lang.NoClassDefFoundError：akka/stream/Fusing$

我正在使用 Akka 开发一个小型微服务。由 HttpServer 组成，如下所示： 对象 HttpServer 扩展 App { val config = ConfigFactory.load() 隐式 val 系统 = ActorSystem(co...

使用 Akka Actor 打印算术表达式

我需要编写一个程序来转换表达式，例如 在 Actor 的帮助下，“Add(Val(2), Add(Val(3),Val(2))”到 (2+(3+2))。 正确的方法是创建一个发送...的 Actor

安排 Akka Streams 中的 Kafka Consumer 在一天中的特定时间运行

我使用Akka Streams编写了一个Kafka消费者： RestartSource.withBackoff(consumerResetProps(), () -> Consumer.committablePartitionedSource(consumerProps(), Subscriptions.top...

如何更改akka.net集群中服务的各个版本？

我正在尝试构建一个 Akka.Net 集群应用程序。它形成一个集群，我可以使用 pbm 工具进行查询： > pbm localhost:9110 集群显示 响应：来自pbm命令的响应 我的问题...

Apache Spark - 工作人员连接被拒绝

嗨，我是 apache Spark 的新手，我正在尝试学习它 在创建新的独立集群时，我遇到了此错误。 我启动了我的 master，它在端口 7077 上处于活动状态，我可以在 ui 中看到它（

Akka 类型的 actor 向另外两个 actor 询问信息的正确方法是什么？

我是 Akka 新手，我正在将传统服务转换为 Actor。 我理解其中大部分内容并没有太大困难，但我对询问另外两个人的正确方法有点困惑

在 Slick 事务中处理 Akka 流

软件版本： 阿卡2.4.4 光滑3.1.0 我想在 Slick 事务中处理 Akka 流中的元素。 下面是一些简化的代码来说明一种可能的方法： def 插入(d:

在 Akka Stream BroadcastHub 中使用泛型类

我正在尝试创建 ConsumerRecord 类型的 BroadcastHub 来自相同元素类型的 Source，但不允许泛型类类型。 可运行图 我正在尝试创建一个 BroadcastHub 类型的 ConsumerRecord<String, String> 来自相同元素类型的 Source，但不允许泛型类类型。 RunnableGraph<Source<ConsumerRecord<String, String>, NotUsed>> graph = source.toMat( BroadcastHub.of(ConsumerRecord.class, 256), Keep.right() ); 发现类似的问题已得到解答here，但看起来没有类似的方法BroadcastHub 目前我只能选择将泛型类型包装到包装类中 RunnableGraph<Source<ConsumerRecordWrapper, NotUsed>> graph = source.map(ConsumerRecordWrapper::new) .toMat( BroadcastHub.of(ConsumerRecordWrapper.class, 256), Keep.right() ); 有更好的解决方案吗？ 根本问题是擦除。 由于 ConsumerRecord.class 的存在只是为了指导类型推断（在运行时，无论类型如何，类对象都是相同的，并且有效地表现得像它始终 ConsumerRecord<Object, Object> 一样），因此可以安全地使用 Class 对象的未经检查的强制转换来让类型发挥作用。 所以这样的东西适合我编译 @SuppressWarnings("unchecked") final Class<ConsumerRecord<String, String>> consumerRecordStringToStringClass = (Class<ConsumerRecord<String, String>>)(Class<?>)ConsumerRecord.class; RunnableGraph<Source<ConsumerRecord<String, String>, NotUsed>> graph = source.toMat( BroadcastHub.of(consumerRecordStringToStringClass, 256), Keep.right() ); （这是其中一些答案的专业化）

Scala Akka Http - 编写一个路由编组器来为我的 API 请求返回 XmlResponse

我的路线方法是这样的（inSome和inSomeStatus是返回类型Route的函数） def 路线(serviceSid: String): 路线 = { 路径（“一些”）{ inSome(serviceSid...

由于许可变更，需要从项目中删除 Akka 框架 [已关闭]

我最近加入了一家新公司，并被分配到一个使用Scala、SNMP、Akka Framework、Kafka、Kubernetes和Spark等技术的项目。随着 Lightbend 最近的变化...

为什么Classic Akka在创建actor时无法使用Java的类型转换？

我在 Java 中使用 Classic Akka 时遇到问题。看来 Akka 在创建 actor 和使用 .tell() 时无法使用 Java 的内置类型转换。 下面是一个简化版本...

Scala Akka Http：com.typesafe.config.ConfigException$Missing：找不到键“调度程序”的配置设置

使用scala Akka创建API，代码在IDE中运行，但是创建jar时无法运行代码： 使用 scala 2.11.12，下面是 build.sbt 此构建/版本：=“0.1.0-SNAPSHOT”

将 Akka GraphDSL 与 Zip 阶段结合使用

考虑以下代码： GraphDSL.create() { 隐式构建器 => 导入 GraphDSL.Implicits._ val in = 源（0 到 10） val fanOut = builder.add(广播[Int](2)) val toString = 构建...