akka 相关问题

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

现在我想在此应用程序中为Akka HTTP端点编写集成测试,如讨论

回答 1 投票 0








如何使用 Akka 保持对创建的 Actor 类实例的引用?

我有一个类,它本身就是一个 Actor: 类 Client(服务器: 服务器, systemActor: ActorRef) 扩展 Actor { ... } 我有一个管理连接的客户端的列表。产生客户行为的演员...

回答 1 投票 0

如何使用 Akka-http 将 HttpEntity 转换为 Scala 中的 Protobuf 对象?

我正在使用 Scala 和 akka-http。我有一个 protobuf 编组器,它在传入路由上工作得很好: 特性 ProtobufMarshalling[T <: GeneratedMessage, E <: GeneratedMessage] { implicit def

回答 1 投票 0

尝试从 akka 类型应用程序内部创建一个经典的 actor

我有一个 akka actor,它使用基于此 TCP 连接示例的经典风格:https://doc.akka.io/docs/akka/current/io-tcp.html 我正在尝试从...

回答 2 投票 0

调用 `ActorSystem.create` 时出现“Actor 名称 [用户] 不唯一”

背景 我正在尝试采用现有的 Java with Gradle 项目并使其使用 Akka Actor。当我创建演员系统时出现错误。这个错误似乎只在我运行代码时才会发生...

回答 1 投票 0

在 Akka 流中连接两个流

我正在尝试连接两个流程,但无法解释我的实现的输出。 val 源 = 源(1 到 10) val sink = Sink.foreach(println) val flow1 = Flow[Int].map(s => s + 1)...

回答 2 投票 0

类型安全配置:从 src/test/resources 加载配置

这是一个初学者问题。所以我的应用程序结构看起来像 src/main/java/... src/main/resources/application.conf src/测试/java/... src/test/resources/module/test.module.conf 应用程序配置文件

回答 3 投票 0

有没有办法创建一个 RSocket“forRequestStream”并将其作为 Pekko/Akka Sink 返回而不使用已弃用的 FluxProcessor?

在我的用例中,我需要使用 RSocket 协议通过网络创建反应流,并在客户端返回 pekko Source,在服务器端返回 pekko Sink。我没有

回答 1 投票 0

Scala Akka HTTP 向 API URL 路由添加多个段变量的问题

我正在构建一个 API 来使用 Scala、Akka HTTP 和 Akka Actors 跟踪学生数据。 但下面的 API 路由没有给我想要的结果。 路线 Littlerock/admins 和 Littlerock/school...

回答 1 投票 0

Akka - 原因:不兼容的类型:Behavior<Message> 无法转换为Behavior<Object>

我有一个 OrderManagerActor,它接受来自实现 Message 接口的类的消息。 该接口由以下类 CreateOrderMessage、DeleteOrderMessage 实现,

回答 1 投票 0

akka 共存是否支持混合 akka classic 和 akka typed 的节点之间的分布式发布-订阅?

我们有一个用java编写的akka 2.6集群,集群中有两个角色(名为“manager”和“executor”),具有不同的功能。目前都是akka经典。 我们想搬到 akka

回答 1 投票 0

创建 Map 时出现 Scala 类型不匹配错误

我正在使用 scala 3.3 构建一个地图变量,临时存储学校的信息,如下所示。 地图的变量: “员工”-> 设置[CreateStaff] “学生”-> 设置[

回答 1 投票 0

Scala Akka HTTP Actor 类协议类型不匹配错误

我正在使用 scala 3.3 和 Akka actor 构建 Akka HTTP 应用程序。 当在 StarRegistry 对象中创建恒星、行星或月亮时,我希望将其值临时存储在注册表中...

回答 1 投票 0

最新问题
© www.soinside.com 2019 - 2025. All rights reserved.