Akka是一个开源工具包和运行时,简化了JVM上并发和分布式应用程序的构建。它实现了Erlang中已知的actor模型。
如何使用 Akka 保持对创建的 Actor 类实例的引用?
我有一个类,它本身就是一个 Actor: 类 Client(服务器: 服务器, systemActor: ActorRef) 扩展 Actor { ... } 我有一个管理连接的客户端的列表。产生客户行为的演员...
如何使用 Akka-http 将 HttpEntity 转换为 Scala 中的 Protobuf 对象?
我正在使用 Scala 和 akka-http。我有一个 protobuf 编组器,它在传入路由上工作得很好: 特性 ProtobufMarshalling[T <: GeneratedMessage, E <: GeneratedMessage] { implicit def
尝试从 akka 类型应用程序内部创建一个经典的 actor
我有一个 akka actor,它使用基于此 TCP 连接示例的经典风格:https://doc.akka.io/docs/akka/current/io-tcp.html 我正在尝试从...
调用 `ActorSystem.create` 时出现“Actor 名称 [用户] 不唯一”
背景 我正在尝试采用现有的 Java with Gradle 项目并使其使用 Akka Actor。当我创建演员系统时出现错误。这个错误似乎只在我运行代码时才会发生...
我正在尝试连接两个流程,但无法解释我的实现的输出。 val 源 = 源(1 到 10) val sink = Sink.foreach(println) val flow1 = Flow[Int].map(s => s + 1)...
类型安全配置:从 src/test/resources 加载配置
这是一个初学者问题。所以我的应用程序结构看起来像 src/main/java/... src/main/resources/application.conf src/测试/java/... src/test/resources/module/test.module.conf 应用程序配置文件
有没有办法创建一个 RSocket“forRequestStream”并将其作为 Pekko/Akka Sink 返回而不使用已弃用的 FluxProcessor?
在我的用例中,我需要使用 RSocket 协议通过网络创建反应流,并在客户端返回 pekko Source,在服务器端返回 pekko Sink。我没有
Scala Akka HTTP 向 API URL 路由添加多个段变量的问题
我正在构建一个 API 来使用 Scala、Akka HTTP 和 Akka Actors 跟踪学生数据。 但下面的 API 路由没有给我想要的结果。 路线 Littlerock/admins 和 Littlerock/school...
Akka - 原因:不兼容的类型:Behavior<Message> 无法转换为Behavior<Object>
我有一个 OrderManagerActor,它接受来自实现 Message 接口的类的消息。 该接口由以下类 CreateOrderMessage、DeleteOrderMessage 实现,
akka 共存是否支持混合 akka classic 和 akka typed 的节点之间的分布式发布-订阅?
我们有一个用java编写的akka 2.6集群,集群中有两个角色(名为“manager”和“executor”),具有不同的功能。目前都是akka经典。 我们想搬到 akka
我正在使用 scala 3.3 构建一个地图变量,临时存储学校的信息,如下所示。 地图的变量: “员工”-> 设置[CreateStaff] “学生”-> 设置[
Scala Akka HTTP Actor 类协议类型不匹配错误
我正在使用 scala 3.3 和 Akka actor 构建 Akka HTTP 应用程序。 当在 StarRegistry 对象中创建恒星、行星或月亮时,我希望将其值临时存储在注册表中...