腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
Akka
Streams
:
在
源
的
乞讨
和
结尾
添加
字符
akka-stream
我有一个json对象源代码,存储为
字符
串,我希望将其呈现为JSON数组。source.intersperse(",\n").concat(Source.single("]").prepend(Source.single("["))) 它似乎不起作用,我从未在输出中看到[
和
]
字符
。另外,我怎么才能告诉
Akka
Streams
流
的
结尾
已经到了(我知道结束消息),这样它就可以
添加
结束
字符</
浏览 12
提问于2019-10-14
得票数 0
回答已采纳
1
回答
使用
akka
流时
的
事件顺序
scala
、
akka-stream
、
akka-actor
merge ~> channelActorSink }我尝试通过使用actorRefWithAck (我在上面的代码中注释掉)来修复它(并在消息传递方面
浏览 4
提问于2017-11-11
得票数 0
回答已采纳
1
回答
使用
akka
进行Zip文件传输
akka
、
akka-stream
、
akka-http
我是
AKKA
的
新手(我使用
的
是java)。我不知道如何将zip文件传输到远程参与者。我应该使用
akka
-http吗?我尝试过
akka
-
streams
,但我不能理解如何将二进制文件传输到远程actors。
浏览 1
提问于2017-09-19
得票数 0
1
回答
Akka
似乎没有
在
故障期间重新启动
scala
、
akka
、
akka-stream
我在用可重新启动
的
源
和
接收器处理
akka
流中
的
错误。object Main extends App { } }) restartableSource.runWith(restartableSink)
浏览 8
提问于2022-01-10
得票数 1
回答已采纳
1
回答
在
Akka
中,PersistentView
的
典型用例是什么?
akka
、
system.reactive
、
akka-stream
、
event-sourcing
、
akka-persistence
这里写
的
是: 它与 / RX有何不同? 看上去和我很像。
浏览 4
提问于2017-03-29
得票数 1
回答已采纳
1
回答
将websocket客户端放在
Akka
.NET内部或外部
的
代理中
的
位置?
c#
、
akka.net
我是
Akka
.NET
的
新手,我正在构建某种websockets,我想使用
Akka
.NET来处理(转换
和
转发)传入
的
流量,使用它
的
参与者系统。但我想知道怎样才是最好
的
办法。我有以下问题: 我是否应该在Actor之外创建主侦听器,并为每个传入
的
“侦听”客户端实例化一个参与者?或者我应该把我
的
主要听众也放在一个演员里面?我是否应该与“发送”websocket客户端一起创建转发
和
转换逻辑?或者我应该把我
的</em
浏览 1
提问于2017-10-10
得票数 2
回答已采纳
2
回答
RxJava:如何在同一个
源
中实现带缓冲区
的
慢消费者
和
快消费者?
buffer
、
rx-java
、
reactive-programming
、
throttling
、
backpressure
在
处理各种背压场景时,我实现了这样一种情况:一个订阅者使用缓冲区
的
速度很慢,而另一个订阅者则消耗掉扔给它
的
任何东西。使用Scala
和
Akka
Streams
。如果愿意,您可以查看代码以及运行它
的
测试。 我通常尝试开发一个RxJava版本来进行比较,但我在这个版本上卡住了。
在
Akka
Streams
中,我可以构建一个图,其中一个
源
在
2个通道上广播,并从这些通道消耗一个慢接收器
浏览 1
提问于2016-09-02
得票数 2
1
回答
为什么
在
Akka
流中
添加
异步边界要花费大量
的
CPU?
scala
、
akka
、
akka-stream
我发现我
的
Akka
Streams
程序有意想不到
的
CPU使用量。下面是一个简单
的
例子:import
akka
.stream.ActorMaterializer .to(Sink.ignore) .run()
浏览 3
提问于2018-10-19
得票数 6
回答已采纳
1
回答
了解
akka
streams
Source.queue中
的
背压
java
、
akka
、
akka-stream
我正在尝试
akka
streams
,但在我
的
简单示例中,我无法获得工作
的
反压力。无可否认,我没有使用
akka
(
streams
)
的
经验,所以我可能错过了一些重要
的
东西。我生产(
在
队列中提供)整数
的
速度比消费它们
的
速度更快,所以我认为反压力会发挥作用。我
的
目标是始终使用放入队列
的
最新项(这就是为什么我
在
源
队列上使用bufferSi
浏览 0
提问于2017-05-28
得票数 3
1
回答
Java
Akka
执行元
和
流
java
、
akka
、
akka-stream
我开始从学习阿卡语
Akka
流是如何与Actor生命周期相关
的
?
浏览 0
提问于2020-05-15
得票数 0
1
回答
Akka
流Source.repeat
在
100个请求后停止
scala
、
akka
、
akka-stream
、
akka-http
我正在开发下面的流处理系统,以便从一个
源
、进程
和
发送到另一个
源
获取帧。我正在通过scapa使用
akka
-
streams
和
akka
-http
的
组合。管道非常短,但我似乎无法定位系统
在
精确地向端点发出100个请求之后决定停止
的
位置。}}
在
参考之前,我使用
的
是
akka
-
streams
版本2.5.19
和
akka</e
浏览 0
提问于2019-01-08
得票数 3
回答已采纳
1
回答
卡夫卡到MongoDB
的
Akka
流
mongodb
、
scala
、
apache-kafka
、
akka-stream
我对
Akka
streams
技术非常陌生,我没有找到任何关于我
的
用例
的
信息来源。实现这种行为<em
浏览 3
提问于2022-03-16
得票数 1
2
回答
动态合并
Akka
流
scala
、
merge
、
stream
、
akka
、
akka-stream
我正在尝试使用
Akka
streams
以以下方式构建一个pub sub总线:我
的
想法是合并所有的
源
,然后将过滤后
的
源
返回给订阅者。然而,由于发布者可以在任何点加入,所以可以
在
进行订阅之后
添加
源
,订阅者需要像主题
的
任何其他发布数据一样从
浏览 1
提问于2019-07-05
得票数 2
1
回答
Python忽略正则表达式
python
、
regex
我实际上正在开发排除某些文件路径
的
Python regex。我
在
一个属性文件中创建这个正则表达式,然后将其传递给我
的
python代码regex = "..*"现在,我想构建一个与任何内容都不匹配
的
正则表达式。有没有可能有这样
的
。任何帮助都是有帮助
的
! 谢谢!
浏览 1
提问于2021-04-07
得票数 0
1
回答
上传/下载文件
的
问题-http/
akka
-
streams
amazon-s3
、
akka-stream
、
akka-http
、
alpakka
我正在尝试使用
akka
-
streams
和
akka
-http以及alpakka库下载/上传文件到亚马逊S3。我看到两个可能相关
的
问题..。 处理请求时出错:“子流
源
没有
在
5000毫秒内物化”。完成500内部服务器错误响应。若要更改默认异常处理行为,请提供自定义ExceptionHandler。
akka
.str
浏览 4
提问于2017-09-19
得票数 2
1
回答
Source.combine不接受varargs吗?
scala
、
akka
、
akka-stream
Akka
是
在
试图传达Source.combine不应该与一系列源代码一起使用吗?或者我
在
函数定义上是不是太傻了?
Akka
Source.combine
在
vararags之前需要第一个
和
第二个
源
。Source.combine(sources:_*)(Merge(_)) 我不知道我
的
sources是否会有1个、2个或更多来源。因此,编写案例会增加几行代码。没什么大不了
的
,但我觉得我错过了什么。这是
akka
st
浏览 7
提问于2020-12-15
得票数 2
回答已采纳
4
回答
将文本文件读入
字符
串
python
我刚刚开始学习python,并有了如下所示
的
文本文件: World等55Hello55 55Hell
浏览 1
提问于2016-10-09
得票数 1
回答已采纳
1
回答
Streams
项目无法编译,"value ~>不是
akka
.
streams
.Outlet[In]
的
成员“
scala
、
intellij-idea
、
sbt
、
akka
、
akka-stream
我
在
Scala项目中使用
Akka
Streams
API,
在
Intellij中使用SBT插件。我有一个员工池流,如下所述:。这是我
的
代码:import
akka
.stream.scaladsl.我所知道
的
唯一改变就是安装Scala插件scalafmt,并在build.sbt中导入一些新
的
库。这是我
的
build.sbt nam
浏览 2
提问于2017-11-18
得票数 2
回答已采纳
3
回答
从
Akka
Streams
中
的
actor创建流
scala
、
akka
、
akka-stream
可以分别使用Source.actorPublisher()
和
Sink.actorSubscriber()方法从参与者创建
源
和
接收器。但是从actor创建Flow是可能
的
吗?从概念上讲,似乎没有充分
的
理由不这样做,因为它同时实现了ActorPublisher
和
ActorSubscriber特征,但不幸
的
是,Flow对象没有任何方法来实现这一点。
在
优秀
的
博客文章中,它是
在
Akka
Streams
浏览 1
提问于2016-08-24
得票数 24
回答已采纳
1
回答
使用
Akka
流
的
一个
源
到多个Sink
rx-java
、
akka-stream
我正在为我
的
一个已经使用Rx Scala
的
项目尝试使用
Akka
流
的
一些东西。我很想看看
Akka
流是如何适合取代Rx Scala库
的
。有一件事,我不可能看到
的
阿克卡流,是有可能有一个源头
和
许多沉没。比如说,在这个例子中,直接从
Akka
Streams
文档中提取出来:val sink = Sink.fold[Int, Int](0)(_ +//
浏览 4
提问于2016-04-26
得票数 2
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
GrowingIO 响应式编程探索和实践
如何在生产中为机器学习模型提供服务?
Akka HTTP实战:为Ant Design Pro提供后端接口
Kafka 2.0正式发布,带来众多改进
Akka HTTP开发中使用JSON
热门
标签
更多标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
活动推荐
运营活动
广告
关闭
领券