akka 相关问题

从akka.stream.scaladsl.Source读取第一个字节

我正在尝试从akka.stream.scaladsl.Source [ByteString，Any]读取前16个字节，并返回[Array [Byte]，Source [ByteString，Any]]。读取前16个字节后，我想流式传输...

您如何为Spring编写Akka类型扩展，以进行构造函数依赖注入？

在Akka 2.6之前，或在经典Actor上，可以编写Akka扩展名，以访问Akka未类型化actor中Spring的@Inject注释。这样的一个例子是：https：//github.com/typesafehub / ...

Alpakka AMQP：如何检测声明异常？

我有一个带有声明的AMQP源和AMQP接收器：List 声明= new ArrayList （）{{add（QueueDeclaration.create（sourceExchangeName））;添加（...

Java Akka演员和流

我从https://doc.akka.io/docs/akka/current/index.html开始学习akka。 DeviceManager是...

如何使用主机应用程序提供的日志适配器从基于Akka的库进行日志？

我正在制作一个小型库-确实是一个Flow-并希望从其代码中进行一些调试日志记录。该库将在Log4J2和基于Logback的应用程序中使用。我会...

创建一个返回接收器的测试

[如果我有一个测试，要在akka流中模拟来自Sink的响应，其类型为：Sink [String，Future [Integer]]我想找到一种方法来生成此类型的默认值，但是我...

正在播放中测试对akka演员的呼叫

我已经重构了一个播放应用程序中的大量电子邮件发送代码，以使用actor异步地执行此操作。当我需要发送电子邮件时，现在可以注入一个EmailActor，然后致电...

是否可以在Akka群集中定义几个停止消息

我不确定为群集分片配置Akka Actor，我不太确定的一件事是，是否可以为实体配置多个停止消息以正常关闭。例如，实体...

我如何从Akka提取实时FileIO状态？

我正在使用Akka制作文件传输系统。我看文件已经有一段时间了。当前的进度状态是Actor2收到了Actor1发送的文件，并将其写入本地...

播放2.7后台任务和异步服务

我想知道在Play后台Akka任务中使用异步服务（返回Future [OfResult]）的正确方法是什么。播放文档中没有关于此的信息，看来我不能只是...

Akka中的System Actor和User Actor有什么区别？

所以我可以使用actor系统创建许多actor。我还可以使用SpawnProtocol创建许多演员。这两种类型的参与者之间有什么区别。我能想到的是-我们得到...

如何从Akka客户端HttpResponse中解析json主体

我正在使用Akka的HTTP客户端库来请求json，并且我想使用Play Framework的play-json来解析json。在获得Akka的HttpResponse之后，我不知道如何从...

根据发送的消息恢复Akka的要求

我通过Ask向演员发送不同的消息。超时时，我想提供一个默认值，该默认值对于询问参与者的消息是不同的。由于超时异常始终是...

如何从Akka事件流构建Akka流源？

当MyActor收到开始消息时，它将运行Akka流，并将接收到的每个项目发布到Akka事件流。 MyActor类（隐式系统：ActorSystem，实现：Materializer，ec：...

akka.persistence.typed.internal.JournalFailureException：恢复期间的异常。如何解决？

使用Akka持久性，我得到此异常：引起原因：akka.persistence.typed.internal.JournalFailureException：恢复期间的异常。最后已知序列号[0]。 PersistenceId [...

要求失败：未配置默认日志插件，请参阅'reference.conf'

我在与cassandra一起使用persistentActor期间遇到错误，我什至找不到问题所在，甚至我在应用程序.conf文件中将cassandra添加为日志错误[错误] [04/29/2020 14：55：57.517] [...] >

Config Profiles Akka群集

我正在使用akka群集，并尝试为不同的环境设置两个不同的配置。一个用于我的本地设置，其中我将使用种子节点启动应用程序。第二个用于我的...

如何在akka-http中有条件地添加路由路径？

我有一系列看起来像这样的路径； path（“ slides” / Segment）{segment => getFromDirectory（s“ $ {cfg.slidesDir} / $ segment”）}〜path（“ foo” / Segment）{segment => getFromDirectory（s“ $ {...

在Akka Sharding上启动时初始化实体

如何在集群启动时预启动实体？我已经找到了一种方法，但是我认为这不是正确的方法。它包括将StartEntity（entityId）消息发送到...

Scala和Akka HTTP：读取具有多个字段的有效负载

我正在尝试在Akka HTTP中创建一个HTTP请求，该请求将能够通过HTTP请求发送两个字符串“ string1”和“ string2”。我目前有以下代码可以处理简单的...