我在玩Akka Stream，并试图在实现后弄清楚它的灵活性。
一种方法是使用低级响应流API：http : //doc.akka.io/api/akka-stream-and-http-experimental/1.0-M3/#akka.stream.scaladsl.PublisherSource
但是，您需要定义这些要发布或订阅的点。有没有办法发布或订阅任意物化流程图节点？这应该是可能的，因为物化流程图只不过是参与者的集合。
例如：首先，部署流程图1：A〜> B〜> C
然后，部署流程图2和3：D〜> BB〜> E
不可能完全动态地更改流处理管道的结构。我们确实预见到了某些类型的动态处理阶段（例如“扇动可能进出的工人”），但总的来说，在实现之前，流和流处理管道应具有定义的布局。这也是有道理的，因为通常在akka流和反应流中采用背压机制–必须在内部对其进行仔细管理，并且允许任意交互并不是此流模型设计的目的。
如果您想要任意交互，Actor应该更适合您。如果您想拥有一个可以接收外部信号来控制处理管道的处理元素，那么它将是物化管道内部旨在接收这些信号的特殊元素，而不仅仅是任何元素。
自从我发布了这篇文章以来，我们添加了一些动态功能，这些功能对于那些登陆该网站的人来说可能是有趣的，尤其是MergeHub和BroadcastHub
请注意，编写Akka Streams的稳定版本为2.4.16。
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句