腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
使用
Akka
Streams
设置
正常
关闭
的
更好
方法
scala
、
akka
、
akka-stream
、
akka-http
我有一个非常简单
的
应用程序,它有一个
Akka
HTTP端点,执行一些处理,并将结果写入任何一个输出文件。确保
正常
关机
的
代码看起来有点复杂,有没有办法让它更简洁?allDone.onComplete { result => case Failure(ex) => case Success(_) =>
浏览 50
提问于2021-10-26
得票数 0
1
回答
如何在argo和kubernetes中运行
akka
流媒体应用?
kubernetes
、
akka
、
akka-stream
、
argo-workflows
、
argoproj
如何在argo和kubernetes中运行
akka
streams
应用程序,我找到了关于kubernetes和
akka
集群
的
文档,但我不需要
akka
集群,我只需要运行一个具有许多参与者
的
短暂
akka
应用程序;还是
akka
集群是必要
的
?
浏览 29
提问于2021-02-12
得票数 0
回答已采纳
2
回答
使用
Akka
Streams
通过SFTP传输文件
scala
、
akka
、
sftp
、
jsch
、
akka-stream
我目前在我
的
scala-
akka
代码中
使用
Jsch库()从远程服务器下载一些文件。根据文件
的
大小,下载文件大约需要1-10分钟。因此,在此期间,其中一个线程会被阻塞,直到文件下载完成。我正在研究
Akka
Streams
,想知道它是否会是一个
更好
的
选择,是否可以将它与现有的纯Jsch
的
SFTP文件下载代码集成在一起?
浏览 0
提问于2018-04-02
得票数 0
1
回答
如何将
akka
.stream.javadsl.Source转换为java.util.concurrent.Flow.Publisher
akka-stream
、
java.util.concurrent
、
reactive-streams
我正在试验reactive
Streams
的
Test Compatability Kit (tck),并且我自己测试了几个Publisher,我想测试一个
akka
Source。createFlowPublisher(long elements) { return new FlowPublisher((int) elements); // <-- how to test an
akka
.Source有没有一些关于这个问题
的
文档,或者有人知道答案?
浏览 1
提问于2019-07-11
得票数 0
1
回答
通过保持消息顺序
的
Akka
并发消息处理
concurrency
、
queue
、
jms
、
akka
在我们
的
项目中,我们将消息发布到JMS代理或从JMS代理消费消息。我们有一个PL/SOL生产者和一个Java消费者。但问题是,生产者
的
速度是消费者
的
10倍。因此,在读取和处理消息时,我们希望将
使用
者更改为
使用
多线程。 但是我们也需要保持消息
的
顺序。也就是说,消息应该按照它们发布到jms代理
的
顺序发送到目标系统。我是
Akka
的
新手,我正在尝试了解它
的
特性。我们可以
使用
akka</em
浏览 0
提问于2015-10-26
得票数 0
2
回答
如何从
Akka
获取WebSocket
关闭
代码?
scala
、
akka
、
akka-stream
、
akka-http
我们
使用
Akka
HTTP来
使用
akka
streams
API来处理我们
的
网络套接字连接。我们
使用
的
是一个流,它将传入
的
消息传输到“连接参与者”。WebSocketOpened(ws)) 当网络套接字
关闭
时,连接参与者被发送"WebSocketClose“消息,我们清理内部资源。我们现在需要知道根据标准
关闭
连接
的<
浏览 0
提问于2018-06-19
得票数 1
回答已采纳
1
回答
使用
akka
流时
的
事件顺序
scala
、
akka-stream
、
akka-actor
阅读
akka
的
文档,我不太清楚消息
的
顺序,以及是否可以强制执行。让我用我为聊天服务器编写
的
一小部分代码来
设置
我问题
的
上下文。在终端中打印
的
事件顺序是完全不确定
的
。我也不知道该怎么解决。这是我得到
的
输出-- [INFO] [11/10/2017 17:42:20.431] [
akka
-
streams
-
akka
.actor.default-dispatcher-5]
浏览 4
提问于2017-11-11
得票数 0
回答已采纳
1
回答
传出连接流已
关闭
akka-http
我有个演员有这样
的
行为: case Info(message) =>receiveN(3)[
浏览 2
提问于2015-06-26
得票数 6
1
回答
已建立连接上
的
TLS
java
、
akka
、
akka-stream
我正在用
akka
io/
streams
编写Java XMPP服务器。根据XMPP规范,连接模式可以在飞行中切换到TLS模式。
使用
akka
.io或
akka
.
streams
有什么好
的
/标准
的
方法
来实现这一点吗?谢谢!
浏览 0
提问于2015-12-09
得票数 1
1
回答
当产生多条消息时,为什么
Akka
HTTP
关闭
用户连接?
scala
、
websocket
、
connection
、
akka
、
akka-http
我有一个简单
的
WebSocket应用程序,它基于
Akka
HTTP/Reactive
streams
,比如这个。Source (由Publisher生成)和流:当我每秒向客户端生成超过30条消息时,
Akka
将
关闭
一个连接。我不明白,
设置
在哪里,它配置了这种行为。我知道,但我没有明确地配置它。 看起来,我有OverflowStrategy.fail(),或者我<
浏览 0
提问于2019-04-16
得票数 1
回答已采纳
1
回答
如何从反应兔库中以编程方式终止io.scalac.amqp.Connection
scala
、
rabbitmq
、
reactive-programming
、
akka-stream
我正在结合
使用
akka
streams
和reactive-rabbit库来构建一个脚本,该脚本将一些信息推送到我本地rabbitmq服务器上
的
一个交换。package prototype import
akka
.act
浏览 0
提问于2015-03-12
得票数 4
1
回答
Java
Akka
执行元和流
java
、
akka
、
akka-stream
我开始从学习阿卡语
Akka
流是如何与Actor生命周期相关
的
?
浏览 0
提问于2020-05-15
得票数 0
1
回答
阿克卡流与火花流
apache-spark
、
akka-stream
使用
akka
流与火花流进行流处理有什么优缺点?比如,内置背压,性能,容错,内置转换,灵活性等。我不是在问
akka
vs火花正反严格流组件。另外,我并不是在问引擎盖框架架构
的
差异。
浏览 1
提问于2016-07-06
得票数 9
回答已采纳
1
回答
了解
Akka
如何提供背压
solr
、
cassandra
、
akka
、
akka-stream
、
reactive
因此,我们在我们
的
生产系统中有一个用例,我们可能会
使用
Akka
streams
。为了了解
Akka
streams
究竟是如何提供背压
的
,我想更深入地了解我们
的
需求。这可以转换成一个问题,可以
使用
Akka
streams
来解决,其中来自/sql处理程序
的
Solr流将是
akka
Source,而Cassandra存储将是Sink,而介于两者之间
的</e
浏览 18
提问于2020-09-20
得票数 0
1
回答
如何以惯用
的
方式向我
的
Akka
流添加错误日志记录?
scala
、
logging
、
akka
、
akka-stream
我目前正在运行类似于以下内容
的
Akka
streams
设置
:┌─────────────┐ │,我想有一些了解生产系统,即是否有错误和什么样
的
错误。onFinish = Logging.WarningLevel, )这确实为我提供了一些洞察力,例如,我将得到下游已经
关闭
的
日
浏览 1
提问于2020-03-05
得票数 4
1
回答
Akka
HTTP和
Akka
streams
-
使用
带有高级路由
的
流API
scala
、
akka
、
spray
、
akka-http
、
akka-stream
这个问题已经在
Akka
Streams
和
Akka
HTTP
的
旧版本中被问到了。这个答案
的
问题是,对于每个流,你需要为每个请求物化一个新
的
流,这并不便宜。一年后,在最新版本中,将流与路由DSL集成
的
最佳方式是什么?同样,我有一个想要添加到路由
的
复杂Flow,如果我将流映射到Flow[HttpRequest, HttpResponse, _],我可以
使用
此流完成路由吗?有没有
更好
的
方法
浏览 0
提问于2017-05-23
得票数 2
1
回答
如何在
akka
http
设置
file-io-dispatcher?
scala
、
akka
、
akka-stream
、
akka-http
当我尝试启动
akka
时,ConfigFactory.load()出现以下错误 Exception in thread "main" com.typesafe.config.ConfigException$UnresolvedSubstitution: reference.conf @ jar:file:/home/faoxis/.ivy2/cache/com.typesafe.
akka
/
akka
-http_2.12/jars/
akka
浏览 2
提问于2018-09-15
得票数 0
3
回答
IAsyncEnumerable是
akka
streams
的
源码
c#
、
akka-stream
、
akka.net
、
iasyncenumerable
我想
使用
IAsyncEnumerable作为
akka
streams
的
源码。但是我没有找到,怎么做呢。using System.Threading.Tasks;
浏览 5
提问于2021-09-22
得票数 0
4
回答
在C#中以小块下载大文件
asp.net
、
c#-4.0
、
httpwebrequest
、
websocket
我需要下载一些大于25MB
的
文件,但我
的
网络只允许请求25MB
的
文件。我正在
使用
下面的代码 long Chunk = 26214400; byte
浏览 5
提问于2012-11-26
得票数 3
回答已采纳
1
回答
播放框架/
Akka
Streams
:检测WebSocket何时
关闭
scala
、
playframework
、
akka
、
akka-stream
在直接
使用
Akka
Streams
处理WebSockets时,我找不到一种适当
的
方法
来知道客户端何时断开连接(无论是
正常
断开还是由于崩溃或超时)。我
使用
的
是一个基本
的
例子,类似于官方文档中
的
例子: import play.api.mvc._ def socket = WebSocket.accept
浏览 13
提问于2019-01-11
得票数 1
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
GrowingIO 响应式编程探索和实践
如何在生产中为机器学习模型提供服务?
浅谈java响应式编程以及Reactor 3框架
聊聊reactive streams的processors
Java9特性及示例
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券