6
我想了解Akka Streams的縮放部分,我在這裏看到了各種回覆,但仍然無法理解如何實現此功能。Akka Streams在羣集節點上運行
有ActorPublisher /訂閱者,據我所知,它們是爲了與流進行交互,但同時它說這些不能是遠程的。
我該如何完成能夠使用akka集羣與流一起?我是否必須讓GraphStage將其工作「外包」給遠程演員?或者graphStage本身可以在羣集節點上運行?
我的用例是有一個管道包含幾個繁重的計算階段與連接和合並,並可能需要分發這些階段的一些階段。
更新
根據這一Crawling the Web with Akka Streams我看到一個圖中不能跨越幾個簇。在這種情況下,水平縮放會怎樣?
你只能在本地使用流。無論你在遠程節點之間做什麼,都必須以「舊」的方式完成。 –