akka 相关问题

无法使用 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 = 构建...

kubernetes 滚动更新期间 Akka 集群切换

我一直在尝试使用推荐的rollingUpdate 加上集群应用程序版本在kubernetes 中部署akka 集群，以便以最短的停机时间实现顺利部署。然而移交过程是

AnnotationConfigServletWebServerApplicationContext - 上下文初始化期间遇到异常 - 取消刷新尝试

如果我在 LocalCosmosDBConfig.java 中取消注释 cosmosAsyncClient 方法，则会收到以下警告。如果我在同一文件中取消注释 cosmosConfig 方法，则会收到类似的警告。应用程序已开发...

如何在scala中自动重新运行sbt项目

我创建了一个 sbt 项目来学习使用 akka-http 进行简单的增删改查操作。首先，我添加了简单的路线来检查它是否正常工作。 通过运行 sbt run 命令，我发现它在本地运行