1回答
我正在尝试使用Akka Streams在Scala中读取一个文件，我想将结果放在一个列表中。我尝试了下面的代码，列表在接收器内部增加了新值，但在外部我得到了一个空列表。
浏览 26提问于2019-06-25得票数 0
回答已采纳
1回答
基本上，我允许用户创建帐户，添加他们的个人关键字，并启动他们自己的流。 result.put("status", "OK");}
正如您所看到的，我正在将它们放在缓存中，但是我想让流长时间开放
浏览 4提问于2014-02-16得票数 1
回答已采纳
1回答
考虑到TCP提供本机流控制，我正在研究为什么某些系统实现应用程序级的背压。仅仅是为了从网络和TCP协议中抽象出异步通信的思想吗？其他更确切的问题是：
反应性流是否通过简单地让TCP处理它来实现TCP之上的应用层背压？
浏览 1提问于2018-03-27得票数 4
2回答
我有一个关于使用Akka Streams和Akka集群的问题。我正在尝试做一个使用Akka Streams和Akka Cluster的分布式字数统计版本。我想构建一个Akka Streams客户端，它将文本文件作为流I/O读取，并将单词流发送到远程集群。ByteString.fromString(" "), 256, FramingTruncation.ALLOW))
.map(i -> i
浏览 5提问于2018-11-10得票数 2
我有一个必须实现的java接口，如下所示：此接口必须返回一个在订阅之前一直处于不活动状态的Flow.Publisher，并且订阅方调用Subscription.next(n)。JavaFlowSupport.Sink.asPublisher(AsPublisher.WITHOUT_FANOUT), actorSystem);
不幸的是，这似乎立即开始从我的LivePacketIterator中获取元素，即使没有订户订阅返回的但我
浏览 13提问于2021-09-27得票数 1
回答已采纳
1回答
我的Scala应用程序启动了一个将文件写入磁盘的外部进程。在一个单独的线程中，我希望读取该文件并将其内容复制到OutputStream，直到进程完成，文件不再增长。有几个边缘情况需要考虑：
是否有一种优
浏览 1提问于2018-04-21得票数 0
回答已采纳
1回答
我读过这个博士，上面写着：import akka.actor.ActorRef;
final ActorSystem s
浏览 5提问于2019-12-06得票数 5
回答已采纳
我们在akka集群上有一个分布式应用程序。参与者“A”向远程演员发送大小较大的消息。我们收到以下警告：
2016-08-10 23:08:29,737 EndpointWriter错误-瞬态关联错误(关联保持活动) akka.remote.OversizedPayloadException
浏览 2提问于2016-08-10得票数 2
回答已采纳
1回答
有人能举个例子，通过Akka流读取HDFS位置上可用的文本文件吗？我是Akka的新手，在谷歌搜索了这么多之后，没有找到任何解决方案。任何帮助都将不胜感激。谢谢。
浏览 2提问于2019-11-26得票数 0
回答已采纳
我正在使用一家提供实时流的数据供应商的Java API。我想使用Akka streams来处理这个流。for (Event e : events) }
}); 我曾尝试在自定义图形阶段中嵌入此订阅和伴随缓冲区的创建谁能指导我使用Akka与这个API交互的最佳方式？Akka Streams是这里最好的工具吗？
浏览 32提问于2021-09-28得票数 1
回答已采纳
1回答
使用EventStream创建源
、、、、
我正在使用PlayFramework 2.5.3，并希望从akka.event.EventStream创建一个akka.stream.scaladsl.Source ( eventstream是参与者系统的一部分事件流将从特定类型生成事件，因此我需要订阅该特定类型的事件并使用play.api.mvc.Results.chunked推送它们。有什么简单的方法可以使用Akka Streams 2.4.5创建这样的Source吗？
浏览 5提问于2016-05-19得票数 6
1回答
我正在尝试订阅远程akka 的日志流，主要是编写一个控制台来显示remote Actors的运行日志。我认为这样做的唯一方法是:在日志记录ActorSystem中创建一个Actor，让该Actor订阅ActorSystem.eventStream，然后在控制台的ActorSystem中使用订阅该Actor因为日志管道看起来如下：
logging Actor --> eventStream --> Actor subscribed to eventStream --> local Acto
浏览 5提问于2015-06-19得票数 1
回答已采纳
1回答
我在玩Akka，我试图在物化之后找出它的灵活性。但是，您需要定义要发布或订阅的这些点。是否有发布或订阅任意物化流图节点的方法？这应该是可能的，因为物化的流图只不过是参与者的集合。然后，部署流程图2和3: d ~> B ~> E
浏览 4提问于2015-02-17得票数 11
回答已采纳
获取无限流的当前值的最佳方法是什么，该无限流聚合了值，并且根据定义永远不会完成 .scan(0)(_+_)我想从Akka HTTP我应该使用动态流吗？该broadcastHub，然后从Akka http订阅无限流的GET请求？
浏览 6提问于2017-12-07得票数 0
回答已采纳
3回答
我有一份文件清单。我要：
val sources = Seq("file1", "file2").map(new File(_)).map(f => Fi
浏览 3提问于2016-06-13得票数 5
回答已采纳
2回答
我的阿克卡流继续学习。我想将我的akka应用程序与集成。class ChatClient(name: String) extends Actor { case ChatClient.Message(from, text) => }我的问题是，我应该如何将
浏览 6提问于2016-02-03得票数 4
回答已采纳
1回答
我是非常新的akka-http，我想流一个csv与任意数量的行。import akka.http.scaladsl.Httpimport akka.http.scaladsl.model._import akka.stream,data: akka.st
浏览 2提问于2016-10-27得票数 1
我的用例类似于，希望从JSON对象中读取一个内部的、巨大的数组(以多千兆字节作为文本)，例如： {...}, ]输入作为Source[ByteString,_] (Akka流)可用，我在其他地方使用Circe解码JSON。我可以看到两个挑战：
以流的方式读取bs数组(获取用于使用它的Source[B,_] )
浏览 0提问于2018-07-19得票数 3
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
