问题标签 [akka.net]

Im thinking how can I spawn an actor with some additional parameters in F# ?

I have the following actor function definition

and Im trying to wrap that function to spawn an actor with

but here I run into a troubles... how can I pass those additional params? I know that I can create a custom C# style actor, but for now I want to try with F# :)

我可能做错了什么，但并不明显。我有以下代码：

问题是 Ask 返回的任务永远不会完成。其状态保持在等待激活状态。“Foo”确实打印在命令行上，所以我知道演员正在处理打印消息。在被覆盖的演员 PrintMsg 中我还应该做些什么来标记任务已完成？

我有一个场景，我有一个客户端（控制台）应用程序，它将由企业作业调度程序（AutoSys）调用。该客户端将工作发送到我的“服务器”（引用，因为这可能是一个集群）。对于与客户端工作请求相关的所有日志消息，我需要能够将日志消息从服务器发送到客户端。内置的日志记录是否支持这种分布？我可以就如何实现这一目标获得一些指导吗？

我在代码库中看到一些名为 的东西LoggingBus，这是我需要看的地方吗？

我的核心用例是能够跨远程参与者发送日志条目。

我有一个 Akka ActorSystem 的设置，如下所示：

我想要做的是用另一个值替换 {0}。我发现这样做的唯一方法是使用 Typesafe for Java，但我使用的是 C#。

我正在尝试测试我的 Akka.NET 演员，但在使用 TestKit 并了解它的工作原理时遇到了一些问题。

由于在 Akka.NET 中还没有关于单元测试的官方文档，我已经探索了 Akka.NET 存储库中的示例代码，但是那里使用的示例对我不起作用。

我用作参考的测试是ReceiveActorTests.cs和ReceiveActorTests_Become.cs，因为它们与我试图在我的应用程序中测试的场景很接近。

这是一些虚拟代码：

鉴于这位演员

我想测试它是否正确接收问候和告别消息，并正确进入成为状态。查看ReceiveActorTests_Become.cs测试，一个演员是由

并且一条消息被发送并断言

然而，当我尝试用这种方法来实例化一个演员时，以及许多其他基于 TestKit 方法的方法（见下文），我不断收到同样失败的测试错误：

这是我的测试：

我还尝试将 ExpectMsg 线移到 actor.Tell 线上方（因为在您采取行动之前期望某些东西并在之后验证期望更有意义），但这也会导致超时错误。

我已经尝试过 NUnit 和 XUnit TestKits。

我可能忽略了一些非常基本的东西。

我有一个演员通过向其父母发送消息来响应消息，就像这样......

我现在想测试消息是否已发送到 Actors 父级，但不知道如何发送。我当前的测试如下所示...

这当然行不通，因为 Actor 父级是测试 ActorSystem 而不是分配给 TestActor 属性的 Actor。

有谁知道我如何测试消息确实发送给它的父母，谢谢。

我目前正在学习使用 Akka 创建分布式软件，我正在尝试制作的程序是一个抓取程序。我面临的主要挑战是我需要控制发送到同一主机的simunitanies 请求数量，因此我不会被网站禁止。因为我以前从未使用过 Akka 到任何真正的扩展，我真的可以在我的设计中使用一些帮助，如果它很好或完全错过了重点。

我的设计理念是为每个主机制作一个路由器，其中包含我想要继续访问站点的路由数量。与协调参与者一起将请求发送到正确的路由器。

由于我的 Cordinator 是一个普通的actors，它一次只能路由一个请求，有没有办法让它像路由器一样能够同时路由多个请求，所以它不会是一个瓶颈？

我在代码中的想法。

我有一些来自工作示例的代码片段。此示例是在服务结构中进行 REST 调用 (WebAPI) 和轮询器来轮询请求。有五个参与者 (1) FileImportValidator用于验证文件名 (2) FileParser用于解析文件 (3) AgeValidator用于验证年龄 (4) FilePersister将名称和年龄作为事件持久保存。

请分享此设计是否符合使用 AKKA.NET 对事件源系统进行演员建模的预期。

PS。要解析的文件已经上传。REST 调用仅提供文件名。我有目的地消除了一些验证逻辑。

我已经设置了一个 Akka.Net 节点作为集群中的种子节点，我称之为前端，另一个节点我称之为后端。在前端节点中，我在代码中配置了一个集群路由器组，这使我可以将消息从前端发送到任何加入角色“后端”的节点（以循环方式）并且在 /user/ 有一个演员后端。我正在运行的代码如下所示：

现在我想将此配置移动到配置文件中（hocon）。我将如何去做这样我只需要下面的代码来实例化它？

我的尝试只产生了没有任何线索的异常。

有什么好的提示吗？我在异常中获得的唯一信息是：

是否可以将 Akka.NET 与 Photon Server 一起使用？

找不到任何有关此的信息。

这个解决方案的可扩展性如何？找到一些关于 Akka + Scala 游戏服务器的文章，但没有关于 Photon + Akka 兼容性的文章。