腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
订阅
Akka
流
,
读取
文件
、
、
我正在尝试使用
Akka
Streams在Scala中
读取
一个
文件
,我想将结果放在一个列表中。我尝试了下面的代码,列表在接收器内部增加了新值,但在外部我得到了一个空列表。
浏览 26
提问于2019-06-25
得票数 0
回答已采纳
1
回答
play框架中的全局变量/跟踪开放流
、
、
基本上,我允许用户创建帐户,添加他们的个人关键字,并启动他们自己的
流
。 result.put("status", "OK");} 正如您所看到的,我正在将它们放在缓存中,但是我想让
流
长时间开放
浏览 4
提问于2014-02-16
得票数 1
回答已采纳
2
回答
通过
Akka
/Spring
流
从InputStream发送数据
、
、
、
、
这是我之前的问题:关键是,我可以实时地压缩/加密
文件</em
浏览 2
提问于2017-02-25
得票数 1
回答已采纳
1
回答
应用级背压与TCP本机流量控制
、
、
、
考虑到TCP提供本机
流
控制,我正在研究为什么某些系统实现应用程序级的背压。仅仅是为了从网络和TCP协议中抽象出异步通信的思想吗?其他更确切的问题是: 反应性
流
是否通过简单地让TCP处理它来实现TCP之上的应用层背压?
浏览 1
提问于2018-03-27
得票数 4
2
回答
Akka
Streams +
Akka
集群
、
、
、
我有一个关于使用
Akka
Streams和
Akka
集群的问题。我正在尝试做一个使用
Akka
Streams和
Akka
Cluster的分布式字数统计版本。我想构建一个
Akka
Streams客户端,它将文本
文件
作为
流
I/O
读取
,并将单词
流
发送到远程集群。ByteString.fromString(" "), 256, FramingTruncation.ALLOW)) .map(i -> i
浏览 5
提问于2018-11-10
得票数 2
1
回答
如何创建从
akka
流
源开始
订阅
的Flow.Publisher
、
、
我有一个必须实现的java接口,如下所示:此接口必须返回一个在
订阅
之前一直处于不活动状态的Flow.Publisher,并且
订阅
方调用Subscription.next(n)。JavaFlowSupport.Sink.asPublisher(AsPublisher.WITHOUT_FANOUT), actorSystem); 不幸的是,这似乎立即开始从我的LivePacketIterator中获取元素,即使没有订户
订阅
返回的但我
浏览 13
提问于2021-09-27
得票数 1
回答已采纳
1
回答
Scala将实时/正在增长的
文件
流
、
、
、
、
我的Scala应用程序启动了一个将
文件
写入磁盘的外部进程。在一个单独的线程中,我希望
读取
该
文件
并将其内容复制到OutputStream,直到进程完成,
文件
不再增长。有几个边缘情况需要考虑: 是否有一种优
浏览 1
提问于2018-04-21
得票数 0
回答已采纳
1
回答
阿克卡2.6如何阅读阿克卡打字的“死信”?
、
、
、
、
我读过这个博士,上面写着:import
akka
.actor.ActorRef; final ActorSystem s
浏览 5
提问于2019-12-06
得票数 5
回答已采纳
3
回答
Akka
/scala-OversizedPayloadException
、
、
、
、
我们在
akka
集群上有一个分布式应用程序。参与者“A”向远程演员发送大小较大的消息。我们收到以下警告: 2016-08-10 23:08:29,737 EndpointWriter错误-瞬态关联错误(关联保持活动)
akka
.remote.OversizedPayloadException
浏览 2
提问于2016-08-10
得票数 2
回答已采纳
1
回答
如何从
Akka
流
读取
HDFS
文件
?
、
、
有人能举个例子,通过
Akka
流
读取
HDFS位置上可用的文本
文件
吗?我是
Akka
的新手,在谷歌搜索了这么多之后,没有找到任何解决方案。任何帮助都将不胜感激。谢谢。
浏览 2
提问于2019-11-26
得票数 0
回答已采纳
2
回答
在
Akka
Streams Custom Graph Stage中包装Pub-Sub Java API
、
、
我正在使用一家提供实时
流
的数据供应商的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
ActorSystem的日志
流
、
、
、
、
我正在尝试
订阅
远程
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
流流图?
、
、
、
我在玩
Akka
,我试图在物化之后找出它的灵活性。但是,您需要定义要发布或
订阅
的这些点。是否有发布或
订阅
任意物化
流
图节点的方法?这应该是可能的,因为物化的
流
图只不过是参与者的集合。然后,部署流程图2和3: d ~> B ~> E
浏览 4
提问于2015-02-17
得票数 11
回答已采纳
0
回答
Akka
stream从外部世界获取无穷大流的当前值
、
获取无限流的当前值的最佳方法是什么,该无限流聚合了值,并且根据定义永远不会完成 .scan(0)(_+_)我想从
Akka
HTTP我应该使用动态
流
吗?该broadcastHub,然后从
Akka
http
订阅
无限流的GET请求?
浏览 6
提问于2017-12-07
得票数 0
回答已采纳
3
回答
Akka
流
:
读取
多个
文件
、
、
我有一份
文件
清单。我要: val sources = Seq("file1", "file2").map(new File(_)).map(f => Fi
浏览 3
提问于2016-06-13
得票数 5
回答已采纳
1
回答
如何
订阅
Akka
中的远程事件
、
如果我想
订阅
远程系统中事件流上发布的消息,推荐的方法是什么? 例如,在一个系统中,我有代码。
浏览 3
提问于2017-09-26
得票数 2
回答已采纳
2
回答
akka
-具有
akka
集群的
流
、
、
、
我的阿克卡
流
继续学习。我想将我的
akka
应用程序与集成。class ChatClient(name: String) extends Actor { case ChatClient.Message(from, text) => }我的问题是,我应该如何将
浏览 6
提问于2016-02-03
得票数 4
回答已采纳
1
回答
在scala中使用
akka
-http的
流
CSV
、
、
、
我是非常新的
akka
-http,我想
流
一个csv与任意数量的行。import
akka
.http.scaladsl.Httpimport
akka
.http.scaladsl.model._import
akka
.stream,data:
akka
.st
浏览 2
提问于2016-10-27
得票数 1
2
回答
流
JSON解码最好使用Circe和
Akka
流
、
、
我的用例类似于,希望从JSON对象中
读取
一个内部的、巨大的数组(以多千兆字节作为文本),例如: {...}, ]输入作为Source[ByteString,_] (
Akka
流
)可用,我在其他地方使用Circe解码JSON。我可以看到两个挑战: 以
流
的方式
读取
bs数组(获取用于使用它的Source[B,_] )
浏览 0
提问于2018-07-19
得票数 3
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
GrowingIO 响应式编程探索和实践
基于akka的多线程应用程序日志收集服务
腾讯牛人耗时三年,立足实际开发的巅峰之作,详解高并发程序设计
为什么BAT互联网都爱用kafka?看完你就知道了
腾讯《王者荣耀》公布App客户端权限使用说明
热门
标签
更多标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
活动推荐
运营活动
广告
关闭
领券