我如何发布或订阅一个物化的Akka流流图？
共有1个答案
完全动态地改变流处理管道的结构是不可能的。我们确实预见到了某些类型的动态处理阶段（如“工人的扇出，可能来来去去”），但一般而言，流和流处理管道在具体化之前应该有一个定义好的布局。这也是有意义的，因为在AKKA流和反应流中使用的背压机制--它必须在内部仔细管理，允许任意交互不是这个流模型的设计目标。
如果你想要任意的互动，演员应该更适合你。如果您想要一个能够接收外部信号的处理元件来控制处理流水线，那么它应该是实体化流水线内部的一个专门用来接收这些信号的特殊元件，而不仅仅是任何一个元件。
自从我发表这篇文章以来，我们添加了一些动态特性，这些特性可能会引起登陆该站点的人的兴趣，最显著的是MergeHub和BroadcastHub
-
我正在构建一个Akka应用程序，并希望向外部消费者公开一些参与者的FSM状态转换。（最终目标是能够将状态转换消息推送到websocket，以便可以实时查看。）
-
我正在学习与Akka溪流一起工作，并且真的很喜欢它，但是物化部分对我来说仍然有些神秘。 引用自http://doc.akka.io/docs/akka-stream-and-http-experimental/snapshot/scala/http/client-side/host-level.html#host-level-api ...通过对池客户端流具体化到的HostConnectionPo
-
我在服务器上有这个发布 在客户端上，我想订阅。但我怎样才能接触到背后的数据呢？我尝试了以下内容： 并找到方法 我做错了/理解错了，但我认为我很接近。谢谢
-
本文向大家介绍system.reactive 共享一个订阅（发布），包括了system.reactive 共享一个订阅（发布）的使用技巧和注意事项，需要的朋友参考一下 示例 给定一个IObservable<Offer>的offers从商家购买或以固定价格出售某些类型的项目，我们可以按照如下匹配对买家和卖家的： 问题在于，每个订阅trades将订阅offers两次。我们可以sellers和buyer
-
简介 Redis 的列表类型键可以用来实现队列，并且支持阻塞式读取，所以 Redis 能够非常容易的实现一个高性能的优先队列。同时在更高层面上，Redis 还支持“发布/订阅”的消息模式，可以基于此构建一个聊天系统。 发布示例 发布（Publish）即将消息发布到频道中。示例代码： // 发送消息 Redis::publish('chan-1', 'Hello, World!'); // 发送消息
-
走这条路对吗？如果没有，流量控制该怎么做？