akka 相关问题

使用Akka时丢弃非单位值错误

我有Scala Play应用程序，并且正在像这样的类中调用Scala Akka Scheduler：@Singleton类Foo @Inject（）（actorSystem：ActorSystem，）（隐式executeContext：...

Akka超时异常，但实际上已发送邮件

我正在使用具有以下技术的Scala 2.13堆栈：播放！框架2.8 akka输入2.6.3 alpakka kafka 2.0.3 Akka流作业从Kafka读取事件，要求演员计算...

尝试创建CoordinatedShutdown帮助器功能

我有一个函数，它将使用CoordinationShutdown流执行一些清理代码。 def shutdown（cs：CoordinatedShutdown，makePhase：CoordinatedShutdown.type =>字符串，名称：String）（f：（...

如何创建方法并在Akka runWith（）中使用此方法

Akka流代码：Source.range（1，100）.map（i-> {return Stream.of（i * 4）.t oList（）;}）。runWith（Sink.foreach（a-> System.out .println（a）），实现器）；我想创建一个方法，说...

将现有的SBT Scala应用程序转换为Play

我一直在与Akka actor一起构建应用程序，现在我已经完成了基于actor的业务逻辑，我想为其提供RESTful + websocket前端。我正在尝试找到...

如果只有第一个接收器成功，则将元素发送到第二个接收器

我想使用akka流进行跟踪。。我尝试了广播，也尝试了To，但并没有解决我的问题。Source-> DBSink-> APISink。我首先想在交易时将元素发送到数据库...

将元素发送到多个接收器

我想依次使用Akka Stream。源-> Sink1-> Sink2示例：假设我们有List（1,2,3）作为源Elem 1：将其发送到Sink1，如果接收器1成功，将其发送到接收器2

Play 2.5使用的Akka Streams是什么版本？

[从2.5版开始，Play的默认流处理库是Akka Streams。我在任何地方都找不到官方文档，我想知道Play 2.5使用的Akka Stream版本到底是什么？

如何使用Akka类型的actor系统实现REST API

[我正在尝试使用带有akka-http的scala启动REST API。我是akka和actor模型范例的新手，所以我想实现一个类型化的actor系统，但是我收到了sbt编译错误：找不到...

Java / Kotlin- Akka流Source.reduce如果Source中为null，则不起作用

在Akka Streams Doku中，给出了一个Scala示例，其中包含一个空值的列表。该列表转换为Source，并像示例中那样减少。不幸的是，在Java / Kotlin中，这不是...

在线程“ main”中获取Akka流代码时出错，异常java.lang.NoClassDefFoundError：scala / Function1 $ class

[当我运行akka流代码时，我遇到了以下Java错误：**线程“ main”中的异常java.lang.NoClassDefFoundError：akka.stream.Supervision $$ ...处的scala / Function1 $ class ...

[从alpakka kafka消费时我收到了死信

[INFO] [06/01/2020 05：05：53.947] [default-akka.actor.default-dispatcher-6] [SingleSourceLogic（akka：// default）] [7347a]正在启动。 StageActor Actor [akka：// default / system / Materializers / StreamSupervisor-0 / ...

未从Web客户端发送或接收到Web套接字的消息

在Play应用中，我创建了一个套接字服务器：程序包控制器import play.api.mvc._ import play.api.libs.streams.ActorFlow import javax.inject.Inject import akka.actor.ActorSystem import akka.stream。 ..

[现在正在使用从我的scala / akka / play应用程序发布的SNS时，获取池正在关闭来自akka的消息

我有一些流大约每分钟醒来，并从数据库中提取一些文档并执行一些操作，最后将消息发送到SNS。滴答间隔当前为每1分钟。 ...

自定义处理Akka Streams流中将来的故障

我尝试在Akka流中连接多个流，并根据流以不同的方式处理它们的错误。可以使用诸如此类的东西来实现：Flow [String，Either [ProcessingError，...

akka Actor中的可变集合返回NullPointerException

我有一个演员，每次调用websocket时都会调用websocket并更新地图。演员在命令的另一点使用相同的地图。类...

Akka流并行性

根据文档[1]，我一直试图在Akka Stream中并行化流，但是由于某些原因，我没有得到预期的结果。我遵循了文档中概述的步骤，...

将mapAsync提取到AkkaStreams中的方法

我有一个Akka Streams流，有一点我需要对代码块使用mapAsync。 （...）.via（flow1）.mapAsync（1）（response => *几行代码her *）.via（...

Scala Akka http发布请求，带有正文和喷雾json

[这是我目前使用的方法之一-val uri =“ https：// blahblah / blah / export” val body = Map（“ search”->“最早搜索= -2040h index = app_events sourcetype = kube ：container：shop | ...

是否有可能从Akka Streams Flow中生成多个元素

假设我有一个字符串“ sky is blue”，并且在内部流程中，我将其分为几个元素，我希望将这些元素向下传播。 Source.single（“仅一个元素”）.via（Flow.fromFunction（...