2016-09-22 41 views
1

我是新來akka.net和嘗試讀取儘可能多地。我有兩個場景,我不知道如何處理,並會感謝任何幫助或示例的指針。如何處理生產的節流到akka.net路由器

1)我有一個看起來對zip文件對土地的文件系統上,然後一個過程需要處理的包含在壓縮文件中成千上萬的XML文件10的。我已經創建了我的處理參與者,並使用動態路由器處理了幾百個請求。我的問題是如何限制生產者(在這種情況下,只是循環訪問每個XML文件的迭代器),這樣我就不會將數以萬計的消息推送到我的路由器池,而這些消息在某些時候會被淹沒。基本上,我只是想讓演員們一直忙着。有這樣的標準模式嗎?

2)在某個時刻,我可能需要其中每個演員將其輸出發送到下一個演員在管線,直到最後完成演員處理與多個參與者的XML消息。我希望這個管道是靈活的,即我可能需要一個消息的Actor 1 - > Actor 2 - > Actor 3,但另一個人可能只需要Actor 1 - Actor 2.同樣,是否存在某種模式。我應該看看溪流,因爲這似乎有我所追求的一些東西,或者只是將消息從一個演員傳遞給另一個演員?

任何指針將受到歡迎

在此先感謝

邁克

回答

0

是akka.net流似乎是你所需要的。你將能夠支持你的生產者,以符合消費速度。請參閱stream integration with actors

對於第二部分,您想要使用只處理XML消息的處理步驟(輸入和輸出)的流程,您將能夠靈活地添加/刪除它們。好地方開始Akka.net streams