问题标签 [akka-actor]

我正在使用 GetEventStore 作为 akka-persistence 持久化事件的日志提供程序，并访问akka.persistence.query.javadsl以从 eventstore 查询事件。演员系统和日志提供者是使用 spring 配置的。

事件存储配置如下：

期刊提供者代码如下：

事件存储通过参与者系统填充相关事件，以下代码测试传入事件并通过参与者作为接收器使用它们。

我在这里面临的问题是一些消息被丢弃，并不是所有的事件都被提供给流映射函数。

这是进行处理的演员

上述代码段注释中提到的问题是：

1. 传入的源流正在丢弃大量事件，并且某些事件没有被传输给参与者。
2. 我需要一些有关mapAsync流集成语法的帮助，因为文档中给出的那个给出了编译问题。
3. 再次为流集成使用actorWithRef的语法将非常有帮助。Akka 文档没有。

万分感谢 ！

我有一个具有默认配置的简单演员系统。

我有一个类扩展演员

这个演员有一个伴生对象

像这样进行功能提取是否安全：

并从另一个演员使用？

是否可以进一步限定序列化绑定？运行时类型似乎太有限了。

例如我有

我现在无法ToDo[MyPayload]使用不同的序列化程序进行序列化ToDo[OtherPayload]（即使在不同的 Actors 中！），因为它们的运行时类名称是相等的（PersistentExecutorProtocol$ToDo）。

我错过了什么吗？- 介绍一个AProtocolClass或做PersistentExecutorProtocol一个abstract class没有帮助。

我在接受连接时创建一个参与者，并使用该参与者处理 HttpRequest。

问题（1）：有没有更好的方法来实现这个？

问题（2）：现在，来自连接的请求被发送到同一个参与者，我可以token从 HttpRequest 中检索一个。如何根据 ? 向特定参与者发送请求token？下面的伪代码是我尝试做的。

我有一个对外部服务进行 Http 调用的演员。有时服务会以 Http 404 响应，有时还会出现 http 连接错误。再次重试时，这两个都消失了。

重试演员请求的最佳方式是什么。

我能想到的是

1. 使用主管策略并重新启动actor

2. 在重试http调用的actor中使用递归方法，最大重试次数

哪种方法是正确的，1 还是 2。我认为方法 1 对于像重试 Http 调用这样简单的事情来说是一种过度杀伤力。请分享您的建议。

我想定义一个可以与 Akka 演员混合的特征，该演员在一段时间后安排接收超时。这是我想要做的草图......

...但我不明白什么时候context.setReceiveTimeout会被调用。调用时会作为构造函数的一部分MyFancyAuctionActor调用吗？timeout或者它会更早被调用，因此由于尚未定义的事实而引发某种错误。

我使用 akka.net 可能会发生内存泄漏，因为它消耗大量内存并且一直在增加

我应该每次都创建一个新演员还是更早地将其创建为静态？

我正在尝试在 akka 路由中使用 resizer 与round -robin-pool。但它没有创建实例。它正在处理我在下界中提到的实例。我正在关注 akka版本 2.5.3的文档。

我的配置：

}

演员等级：

}

演员创作：

输出 ：

在每 4 个结果之后，它等待 5 秒以完成先前实例的作业。

请参阅线程 ID。对于演员实例的每一次创建，我都会让我的线程休眠一段时间。当时应该在不同的线程上分配新实例。但是这个过程一直运行到前三个实例。之后，它不会根据调整大小创建新实例。它按照循环池的正常流程附加消息。

我有一个 play(2.4.2 有 akka 2.4.18) 应用程序，我在其中使用 akka 演员来上传文件。我有一个具有这种层次结构的父主管 Actor

UploadSupervisor ---child---> UploadActor ---child--->
DataWriteActor & MetaWriteActor

叶演员 MetaWriteActor 和 DataWriteActor 进行实际的写作。我的代码的一个非常简化的版本如下：

首先我有一个演员监督：

上传演员：-

数据写入演员：

元写演员

演员系统之外的某个地方：-

问题是如何将响应发送到actor系统之外？因为在第 10 行和第 11 行，我不能使用 sender ！msg 因为当前的发送者是 UploadActor。

我真的对这个案子感到惊讶。有任何想法为什么会发生这种情况？

每次都可以正常工作：

如果孩子不存在，我们将创建演员。然后发送 Ping 消息。

这有时会挂断演员已经存在的情况：

为什么？