问题标签 [akka.net]

我有一个关于增加最大帧大小和发送/接收缓冲区大小值的问题。他们能走多高有限制吗？

我将大量数据传递给系统（比如 20mb），然后用于计算一些结果并返回。将上述参数设置为 100mb 会导致消息被丢弃。在这种情况发生之前我可以通过的最大块大约是 5mb。我试图增加连接和确认的超时时间，但似乎没有什么不同。

另外，如果消息被丢弃，有什么方法可以得到通知吗？有时它会发送一个 Dissassociated 错误，有时它只是无所事事。log-frame-size-exceeding = on 和 log-buffer-size-exceeding = 50000 设置似乎没有效果。

任何帮助表示赞赏。谢谢你。

我想使用 Akka.net TestKit 来编写单元测试，但我有一个问题。我有一个 SubscriptionService 类，它负责将消息传输给选定的参与者。

我该如何测试这种行为？我创建了这个测试，但在这个测试中我得到了异常。“附加信息：Assert.Fail 失败。失败：等待消息时超时 00:00:03 ”

我的意思是如何在 Test1 方法中获取 service1 和 service2 的消息？

我有一个基于 MassTransit 和 RabbitMQ 的现有分布式计算框架。本质上，有一个经理根据请求响应工作。每个工人都会根据物理机规格拿走一定数量的物品。然后，工作人员在完成后发送完成消息。它工作得相当好并且似乎具有高度可扩展性，因为唯一的链接是服务总线。

我最近评估了 Akka.Net，看看它是否是一个更简单的系统来实现相同的模式。看完之后，我有点困惑它到底是做什么用的。似乎如果我想做类似的事情，经理必须提前了解每个工人并直接发送工作。

我相信我遗漏了一些东西，因为该模型似乎无法很好地扩展。

这是在 Akka.NET中使用的官方示例：PipeTo()

问题是我们为什么要Sender在这里使用闭包？为什么不只使用：

在此示例和文档中，据说必须在此处使用闭包。但我看不出有任何理由这样做。

如果我们使用ContinueWith()在延续内部使用闭包是合理的，但不作为PipeTo()参数。

我错过了什么吗？

有一个配置ActorSystem了按层次组织的参与者，如下所示：

为了生成这个方案，我使用了下一个 C# 代码：

我的问题是我想将一个子角色添加到process1，process2或者process3从入口点代码（在 ProcessActor 之外）。但是现在我的手被束缚了，因为IActorRef对我隐藏了某些演员实例。

我该如何解决？

我们正在为我们的公司使用 WCF，我们希望确保我们在客户端和服务之间完全分离。

我们想研究一下使用 Akka.Net (Orlean) 或其中一个 Pub/Sub 框架是否可以帮助我们降低复杂性并可能改进我们当前的系统。

你会选哪一个 ？演员模型或 PubSub 以及为什么？

谢谢

我在一个非常简单的客户端服务器配置中使用 Akka.Net。目前没有什么非常先进的。在来回发送消息大约 3 或 4 天后，整个系统似乎处于断开连接状态。随着服务的重新启动，一切都重新连接并且没有问题。在此之前，事情会断开连接，但它似乎会立即重新连接。

在此期间，两台机器都可以在网络上访问，并且似乎没有任何实际的连接问题。

我不知道从这里去哪里。

客户端配置（服务器非常相似）

这个循环一开始是非常零星的，但是过了一段时间它会重复，直到服务重置之前什么都没有连接。

我正在尝试为我的所有演员实现某种控制台编写器。这是我的代码：

问题是，不知何故，演员没有收到任何消息。我从控制台得到了这个日志：

什么地方出了错 ？

我在文档中找不到答案，所以我在这里问。Akka.NET 是否保证消息的完整性？还是我需要为每条消息实现自己的 md5 哈希？我计划在演员之间传输 100Kb 大小的图像。因此，演员们必须完全接受它们。

谢谢你。

Given an Akka.net-based actor system with some basic structure like:

Coordinator actor defines supervision strategy with Directive.Restart used.

Child actors could fail for several reasons (for example, with ArithmeticException, InvalidOperationException and MyCustomException).

But when a child fails with MyCustomException, I'd like to have an ability to somehow additionally handle it without changing the default supervision mechanism (restart approach should still work here). For example, to add Console.Writeline with exception details.

How do I implement it?