akka 相关问题

Akka是一个开源工具包和运行时，简化了JVM上并发和分布式应用程序的构建。它实现了Erlang中已知的actor模型。

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

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

java akka akka-stream akka-typed

回答 1 投票 0

在 Slick 事务中处理 Akka 流

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

akka slick akka-stream slick-3.0

回答 1 投票 0

在 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() ); （这是其中一些答案的专业化）

java akka akka-stream

回答 1 投票 0

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

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

scala routes akka marshalling akka-http

回答 1 投票 0

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

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

java scala akka scalaz zio

回答 1 投票 0

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

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