akka 相关问题

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

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

scala akka akka-stream

回答 2 投票 0

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

java configuration akka typesafe typesafe-stack

回答 3 投票 0

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

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

scala akka project-reactor rsocket pekko

回答 1 投票 0

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

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

scala akka akka-http

回答 1 投票 0

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

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

java akka actor actorsystem

回答 1 投票 0

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

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

java akka publish-subscribe akka-cluster

回答 1 投票 0

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

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

scala akka akka-http

回答 1 投票 0

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

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

scala akka akka-stream akka-http

回答 1 投票 0

如何防止实体在 Pekko/Akka 中多次实体化？

我在 Pekko 代码方面遇到了一些问题，我相信这与默认 Flow 已经具体化数据这一事实有关： def addSha(请求：HttpRequest)(使用如：ActorSystem[任何]， ...

scala akka akka-stream akka-http pekko

回答 1 投票 0

Akka Http Server 中的 ExecutionContext 问题

为什么 Akka http 不使用我在这段代码中定义的自定义执行上下文，并且总是回退到默认执行和默认线程池？ com.vaz.www 包导入 akka.actor.typed。

scala akka akka-http akka-actor

回答 1 投票 0

Akka - 如何告诉系统在达到策略的最大重试次数后要做什么？

假设主管参与者定义了某种策略：私有静态 SupervisorStrategy 策略 = new OneForOneStrategy(10, Duration.create("1 分钟"), DeciderBuilder. ...

java akka akka-supervision

回答 2 投票 0

构造函数与 preStart：何时使用哪个？

在 Akka 中，你可以在构造函数中初始化 actor 的状态。此外，作为 actor 生命周期的一部分，可以重写 preStart 方法来初始化 actor 的状态，并且将

scala akka

回答 1 投票 0

如何解决Akka库依赖错误

我正在尝试使用 Scala 设置 API，并发现了一些建议使用 akka 的在线资源。我是 Scala 新手，所以我正在关注一些文档，还查看了 https://doc.akka.io/docs/akka/curr...

scala sbt akka

回答 1 投票 0

Akka 到 Pekko 迁移和 Grpc

嘿嘿大家，我正在做一个宠物项目的 Akka 到 Pekko 迁移（我正在学习 scala atm）。到目前为止，一切都很顺利，但有一件事我无法修复，那就是 grpc 插件。在我的建筑中...

scala akka grpc pekko

回答 1 投票 0

Akka HTTP Scala JWT 身份验证错误“没有方法解码的重载替代方案”

我正在尝试将 JWT 身份验证添加到我的 Akka HTTP Scala 应用程序 API。我正在使用 Maven 存储库中的 Maven 依赖模块 jwt-circe 和 jwt-core。然而当前的代码是 gi...

scala akka akka-http

回答 1 投票 0

Akka HTTP SBT 模块已解决，ProjectRrf 中存在冲突的跨版本后缀

我正在使用 Scala 3 和 SBT 构建一个 Akka HTTP 应用程序，它一开始运行良好。但是当我将下面的新依赖项添加到 build.sbt 时，应用程序开始给出错误模块......

scala maven sbt akka akka-http

回答 1 投票 0

Akka HTTP 新的 SBT 依赖项未安装，并出现“未解析的依赖项路径”错误

我正在使用 Scala 3 和 SBT 构建 Akka HTTP 项目。在我将下面的新依赖项添加到 build.sbt 之前，该应用程序运行良好。添加的新依赖项是：akka-http-circe、a...

scala maven sbt akka

回答 1 投票 0

Scala 读取列表类中的参数值时出现问题

鉴于下面的 Scala 列表，我想访问元素 x 和 y 以及整个 Page 类元素的值。我需要在另一个函数中再次使用这些值。列表（营地（x=2，UG，目标（

scala playframework akka akka-http

回答 1 投票 0

Scala Akka HTTP 访问包含在 Option[String] 中的 post 请求参数时出现问题

我正在尝试使用 Akka HTTP Server 和 Scala 编程语言创建 Post 请求路径。当我成功发出并接收post请求数据后，我想访问该值...

scala akka akka-http spray-json

回答 1 投票 0

Scala Akka HTTP 访问 post 请求参数时出现问题

我正在尝试使用 Akka HTTP 服务器和 Scala 编程语言创建 Post 请求路径。但是当我成功发出请求后，我发现很难访问re的值...

scala sbt akka akka-http

回答 1 投票 0

akka 相关问题

最新问题