scala – 如何发布或订阅物化的Akka Stream流程图？

发布时间：2020-12-16 08:58:09 所属栏目：安全来源：网络整理

导读：我正在玩Akka Stream,我试图在实现后弄清楚它的灵活性. 一种方法是使用低级反应流API： http://doc.akka.io/api/akka-stream-and-http-experimental/1.0-M3/#akka.stream.scaladsl.PublisherSource 但是,您需要定义这些点以进行发布或订阅.有没有办法发布或

我正在玩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~> B B~> ?

解决方法

不可能完全动态地改变流处理流水线的结构.我们确实预见到某些类型的动态处理阶段(例如“可能来来往往的工作人员的扇出”),但一般来说,流和流处理管道在实现之前应该有一个明确的布局.这也是有意义的,因为akka-streams和 reactive-streams中使用的背压机制 – 它必须在内部进行仔细管理,并且允许任意交互不是这种流模型的设计目的.

如果你想要任意互动,演员应该更适合你.如果你想拥有一个可以利用外部信号来控制处理流水线的处理元素,那么它将成为物化管道中的一个特殊元素,用于接收这些信号,而不仅仅是任何元素.

自从我发表这篇文章以来,我们添加了一些动态功能,这可能是登陆本网站的人们感兴趣的,尤其是MergeHub和BroadcastHub

请注意,由于编写稳定版本的Akka Streams是2.4.16.

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!