akka 相关问题

akka 流中`Flow.batch`的逆

Flow.batch 有逆向吗 我希望该方法的签名为 Flow[Vector[T],T,NotUsed] 它应该解包一个 Vector 并将 Vector 的每个元素作为单个元素发送到下游。

Scala-3.3.0：dotty.tools.FatalError：无法解析对

我在 scala-3.3.0 和 akka（或 pekko）中看到此错误： dotty.tools.FatalError：无法解析对 akka.stream.scaladsl.type.Source 类型的引用 dotty.tools.FatalError：无法解析引用...

特定分片参与者的自定义调度程序

有没有办法为特定的分片参与者分配自定义调度程序？我找到了非分片演员的示例，但没有找到分片演员的示例。

关于actor系统和akka流的干净关闭

我们希望在 akka 流关闭时完成以下任务 源头停了， 流中的元素在超时点之前已完成 然后流/演员系统关闭 我们有...

我在Flutter中的info.plist中添加了依赖，但还是不行

我正在开发一个考试项目。我使用 Akka HTTP 创建了一个服务器并使用 postman 进行了尝试。一切正常。但是当我尝试使用 Flutter 发送请求时（顺便说一句，这是第一次......

是否可以以非编程方式合并不同层次结构级别的配置对象？

我正在使用 TypeSafe 配置。想象一下，我希望为弹性模式提供应用程序范围的默认值，但专门在较低的配置级别覆盖它们。我更希望有一个通用的解决方案...

Akka 内存不足问题

我们正在使用Akka（使用JAVA）框架将消息发送到后端服务器。我们的应用程序在5-6小时内工作正常，发送了大约160万条消息。然后它变得没有响应。

akka 流的 Xml 框架

我正在使用 akka 流从 TCP 端点消耗 ByteString 流。数据块应该形成一个或多个 XML 文档。我希望我的流输出带有完整 Xml 的 ByteString。 例如...

[WARN]：非法请求，响应状态为“501 Not Implemented”：不支持的 HTTP 方法：PROXY

启动 ActorSystem 时，会生成以下警告： logMessage="非法请求，响应状态为'501 Not Implemented'：不支持的 HTTP 方法：PROXY"，logS ...

Akka Streams：向 QueueSource 提供 StreamDetachedException

我们有一个 DownloadFileFlow 类，它使用 Akka Streams 和 Akka Http 从不同域下载文件；有时（~50%）在向我们遇到的 QueueSource 提供服务时

如何正确找到演员或在原地重生

我尝试在 homepet 项目中使用 akka-typed，但不知道如何正确找到演员或生成并发送消息。 我的第一次尝试：从接待员那里包装“清单”并通过适配器发送 - 非常......

akka 2.6.0 中的监督决策策略

我必须通过 supervision.decider 但在 akka 2.6.0+ Materializer 中没有类似的设置。 任何人都可以分享如何在更高版本中编写以下代码： 验证垫：ActorMaterializer =

Akka HTTP 服务启动时需要打印本地地址和端口号

我有一个带有路由和指令的 Akka-HTTP 项目，我想打印本地地址和端口号 Http().newServerAt("localhost", 8080).bind(myRoutes) 我想打印像

GraphStage akka的重试机制

如果 postStop() 失败，我们如何重试/重启 graphStage？ 我对 akka 比较陌生，非常感谢您的帮助。 这是我正在尝试做的事情： 来源 .via(音频...

如何将自定义泛型类 Tree[T] 翻译成带有 Json 注解的 Json？

我想在 Akka 中使用 Json 序列化器序列化泛型树 [T]。 我声明了一个容器 Tree[T]。 性状 NodeId { def id: 整数 } 特质树[T<: NodeId] { def find(id: Int): Option[T]...

Akka Classic Routing (scala) optimal-size-exploring-resizer 的用途

我正在学习 Akka 经典路由。我已经学会了使用调整器并理解了这一点，但是有一个最佳尺寸探索调整器。我无法理解为什么我们需要最佳尺寸探索资源...

在具有高吞吐量和低延迟的系统上比较 Akka Actors pipToSelf 和 Future

我有一个关于 pipeToSelf vs Futures 的问题。 假设我们有一个 Scala Web 后端应用程序，它在具有 16 个内核的 n2d-standard-16 谷歌云机器类型上运行，其中每个节点托管一个 ...

错误( 没有找到参数responseSerializer的牵连。MessageSerializer[Seq[SearchFormData], _] )

在这里输入图片描述 在scala rest API中传递Seq[]作为响应时得到错误。而当我删除Seq时，工作正常。谢谢你

如何统计akkaHttp RejectionHandler的拒绝和成功？

我正试图计算由RejectionHandler返回的拒绝，我想我现在做这个的方式不是最好的，甚至是不正确的。我只是想在我的......中调用增量方法。

为什么persist方法从来不工作？

我使用persistenceActor工作，但当我调用persist()方法时，回调从未到达，我在终端actor中找不到任何错误代码 class MajorEventActor extends Timers with ...