在Akka Streams中推荐使用GraphStage，但我找不到任何关于在Java语言中使用getStageActor()方法的文档(我找到的所有文档都使用Scala)。
浏览 28提问于2018-02-10得票数 1
回答已采纳
我需要写一个GraphStage，但是遇到了一些问题。我已经将代码压缩到下面，希望你们能为我提供一些启发。import akka.stream._import akka.stream.scaladsl
浏览 0提问于2017-03-25得票数 1
对于以前版本的Akka Streams，groupBy返回了一个Source%s的Source，它可以被物化到一个Source[Seq[A]]中。在Akka Streams 2.4中，我看到groupBy会返回一个SubFlow --我不清楚如何使用它。我已经编写了一个extends GraphStage类，它通过GraphStageLogic中的可变集合进行聚合，但是有内置的功能吗？我错过了SubFlow的要点吗？
浏览 1提问于2016-07-07得票数 3
1回答
我刚开始使用Akka Streams API。我正在尝试创建自定义图形阶段。对于我的每个阶段，我希望每个“元素”都是scala集合，例如，一个整数向量。示例代码：
val res
浏览 1提问于2017-07-24得票数 1
回答已采纳
: Collect.in -> GraphStage.out GraphStage.out -> Collect.in unknown-operation.out-> StreamUtil
浏览 2提问于2016-08-11得票数 2
我试图通过使用akka流参考文件将音频流从服务A发送到服务B (akka-streams库版本: 2.6.3)。$StageActor.internalReceive(GraphStage.scala:243) at akka.stream.sta
浏览 1提问于2020-03-30得票数 0
回答已采纳
我正在写一个GraphStage，它需要查找一个SQL表(在一个不同的数据库中)。如果查找失败，那么它才应该查找第二个表(在不同的数据库中)，如果该查找也失败，则在第三个表中查找(在不同的表中)。如果我能将上面的流程分解成3个独立的流程，然后通过我的graphstage中的orelse子句将它们连接起来，那就太好了。
浏览 1提问于2017-09-19得票数 1
下面是简化的代码片段，其中GraphStateLogic实现作为构造函数参数传递给GraphStage：import akka.stream._
//This is base graph s
浏览 0提问于2019-05-18得票数 1
嗨，我想知道是否有人能帮助我理解第三方创建的GraphStage的异常处理。下面是一个演示我的问题的示例GraphStage。import akka.stream.{Attributes, FlowShape, Inlet, Outlet}
import akka.stream.sta
浏览 0提问于2018-11-25得票数 0
回答已采纳
1回答
(GraphStage.scala:1601) at akka.stream.stage.TimerGraphStageLogic$anonfun$getTimerAsyncCallback$1$adapted(GraphStage.scala:1590)
at akka
浏览 9提问于2021-04-05得票数 0
我试图设置一个简单的akka-http 2.4.2项目来测试它，但我没有这样做。" %% "akka-actor" % akkaVersion, at akka.stream.stage.Gr
浏览 4提问于2016-02-23得票数 3
回答已采纳
因此，我正在构建一个Akka自定义组件来学习框架。我需要创建一个UnifromFanOut形状自定义组件。因此，我试图扩展形状，但问题是如何用1输入和3输出创建形状。我刚开始学习Akka，这样我就能理解我的方法是否错误。此外，本练习的目的是创建一个自定义组件，我知道我可以通过GraphDSL完成逻辑，但它需要是一个自定义组件。我的问题是如何正确地创建这个形状。
浏览 11提问于2022-02-08得票数 0
回答已采纳
1回答
我试图理解Akka流的扩展部分--我在这里看到了各种各样的回复，但仍然无法理解这个功能是如何完成的。我怎样才能使用akka集群来处理流呢？我必须让GraphStage将其工作“外包”给远程演员吗？或者graphStage本身能在集群节点上运行吗？
浏览 5提问于2016-04-18得票数 6
回答已采纳
2回答
我写了很少的样本来理解akka流和背压。我想看看一个缓慢的消费者压力是如何一个AkkaPublisher
import akka.stream.actor.ActorPublisherMessage._
浏览 4提问于2018-01-08得票数 1
回答已采纳
有没有什么例子可以让somone使用slick3.0查询mysql，并将查询结果转换成AkkaStream GraphStage？
我不想编写自己的自定义GraphStage (除非绝对必要)。我非常确定，应该有某种方法将查询结果转换为GraphStage
浏览 8提问于2017-07-11得票数 0
回答已采纳
我在Akka stream中有一个运算符/组件，它的目标是在5秒的窗口内计算值。因此，我使用TimerGraphStageLogic创建了我的操作符/组件，您可以在下面的代码中看到。class WindowProcessingTimerFlow))import akka.stream.s
浏览 12提问于2020-12-16得票数 0
回答已采纳
请注意，给定的Akka版本在您正在使用的Akka的所有模块中必须是相同的，例如，如果您使用akka-actor 2.5.4 (从当前类路径解析)，则所有其他核心Akka模块必须具有相同的版本。未捕获来自线程my-system-akka.actor.default-dispatcher-5的错误:由于为ActorSystemmy-system akka.actor.ActorCell.addFunctionRef(Lscala/Function2;)Lakka/acto
浏览 0提问于2017-09-13得票数 1
import akka.stream.{ Outlet, Inlet, Attributes, BidiShape }
private object Impl extends GraphS
浏览 0提问于2016-05-13得票数 1
我有一个具体的GraphStage子类，它定义了一些受类参数影响的自定义逻辑。 我希望我的应用程序的用户能够提供这些自定义GraphStages的Seq。import akka.NotUsedimport akka.stream.stage.{GraphStage, GraphStageLogic}
impo
浏览 15提问于2021-07-14得票数 1
回答已采纳
云服务器
ICP备案
对象存储
即时通信 IM
云直播
腾讯云开发者
