如何处理生产的节流到akka.net路由器

Question

我是新来akka.net和尝试读取尽可能多地。我有两个场景，我不知道如何处理，并会感谢任何帮助或示例的指针。

1）我有一个看起来对zip文件对土地的文件系统上，然后一个过程需要处理的包含在压缩文件中成千上万的XML文件10的。我已经创建了我的处理参与者，并使用动态路由器处理了几百个请求。我的问题是如何限制生产者（在这种情况下，只是循环访问每个XML文件的迭代器），这样我就不会将数以万计的消息推送到我的路由器池，而这些消息在某些时候会被淹没。基本上，我只是想让演员们一直忙着。有这样的标准模式吗？

2）在某个时刻，我可能需要其中每个演员将其输出发送到下一个演员在管线，直到最后完成演员处理与多个参与者的XML消息。我希望这个管道是灵活的，即我可能需要一个消息的Actor 1 - > Actor 2 - > Actor 3，但另一个人可能只需要Actor 1 - Actor 2.同样，是否存在某种模式。我应该看看溪流，因为这似乎有我所追求的一些东西，或者只是将消息从一个演员传递给另一个演员？

任何指针将受到欢迎

在此先感谢

迈克

Answer 1

是akka.net流似乎是你所需要的。你将能够支持你的生产者，以符合消费速度。请参阅stream integration with actors

对于第二部分，您想要使用只处理XML消息的处理步骤（输入和输出）的流程，您将能够灵活地添加/删除它们。好地方开始Akka.net streams