腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
了解
Akka
如何
提供
背
压
solr
、
cassandra
、
akka
、
akka-stream
、
reactive
因此,我们在我们的生产系统中有一个用例,我们可能会使用
Akka
streams。为了
了解
Akka
streams究竟是
如何
提供
背
压
的,我想更深入地
了解
我们的需求。我正在研究
Akka
streams,并理解它是Reactive streams的一种实现。最值得注意的是,
Akka
streams
提供
背
压
的方式,以确保客户不会被生产商淹没。现在,关于我的用例,我想<em
浏览 18
提问于2020-09-20
得票数 0
1
回答
应用级
背
压
与TCP本机流量控制
akka-stream
、
flow-control
、
reactive-streams
、
backpressure
考虑到TCP
提供
本机流控制,我正在研究为什么某些系统实现应用程序级的
背
压
。仅仅是为了从网络和TCP协议中抽象出异步通信的思想吗?其他更确切的问题是: 反应性流是否通过简单地让TCP处理它来实现TCP之上的应用层
背
压
?
浏览 1
提问于2018-03-27
得票数 4
1
回答
(HTTP上的
背
压
)
scala
、
rest
、
akka
、
akka-stream
、
reactive-streams
我想找到一些资源或例子,它展示了
如何
构建一个端到端、完全
背
压
的REST服务+客户端。我的意思是,我希望看到,如果REST客户机实现了反应性流(无论是在
Akka
、JS还是其他类型的),我将拥有(并且能够“可视化”)在构建的整个REST服务器中处理
背
压
,例如使用
Akka
-Http。为了明确起见,我正在搜索类似于以下谈话的内容(但我找不到幻灯片或视频来证实): 我对大多数示例表示怀疑的是,我可以找到很多情况,REST服务(服务器)在后端使用
Akka
Http
浏览 3
提问于2015-05-18
得票数 5
回答已采纳
1
回答
如何
创建不受
背
压
影响的源
scala
、
akka
、
akka-stream
、
backpressure
我想测试一些
Akka
特性,比如conflate。为此,我需要在一个简单的单元测试中构造一个不受
背
压
影响的源。天真的尝试不要因为
背
压
而工作。
如何
为不受
背
压
影响的单元测试创建简单 Source?
浏览 2
提问于2017-05-03
得票数 4
回答已采纳
1
回答
Akka
HTTP
背
压
连接
scala
、
http
、
stream
、
akka
、
backpressure
说在Http().bindAndHandle()上:
如何
使用
akka
公开
背
压
HTTP端点?
浏览 2
提问于2015-08-10
得票数 1
回答已采纳
1
回答
Akka
是同步的还是异步的?
akka
、
reactive-programming
、
actor
我相信反应式系统应该是异步的,但我无意中多次听说
Akka
有同步参与者? 那么这是否意味着
Akka
是同步的呢?或者参与者以同步方式工作,但由于多个参与者,系统是异步的?
浏览 24
提问于2020-01-30
得票数 1
回答已采纳
1
回答
AkkaHttp
背
压
什么时候起作用?
http
、
tcp
、
akka
、
akka-http
、
backpressure
我正在寻找一种方法来实现以下目标: 让我们假设服务器上有一个可反
压
的数据源,比如Apache Kafka主题。
浏览 18
提问于2020-05-20
得票数 0
1
回答
使用
akka
进行Zip文件传输
akka
、
akka-stream
、
akka-http
我是
AKKA
的新手(我使用的是java)。我不知道
如何
将zip文件传输到远程参与者。我应该使用
akka
-http吗?我尝试过
akka
-streams,但我不能理解
如何
将二进制文件传输到远程actors。
浏览 1
提问于2017-09-19
得票数 0
1
回答
Akka
Streams的ActorPublisher作为网络响应源-
背
压
是
如何
工作的
scala
、
akka
、
akka-http
、
akka-stream
、
backpressure
我使用
akka
-streams的ActorPublisher参与者作为每个连接发送到传入的WebSocket或HTTP连接的数据的流。ActorPublisher的是通过
提供
一个下游可以接受的元素数量来定期请求数据。如果需求为0时,我不应该发送更多的元素。为了流,我使用
akka
-http的能力将WebSocket输出和HttpResponse数据设置为Source of Messages (或ByteStrings)。我想知道在这种情况下,当我通过网络向客户端传输数据时,
背
压
是
如何
工作的
浏览 0
提问于2017-06-13
得票数 3
2
回答
Java并发性,
Akka
和RxJava之间的区别?
java
、
concurrency
、
akka
、
rx-java
今天我发现,对于java中的并发,我们有很好的框架,比如
Akka
,我还发现,有一个像RxJava这样的反应式编程框架,可以在应用程序中执行multithreading。但我还是很困惑!如今,反应式编程是一个成熟的话题,大多数语言都支持Functional Reactive Programing,如Netflix
提供
了多种语言的关于Reactive programming的API。根据RxJava的说法,它们在内部使用actors来维护multithreading,
Akka
也使用Actors进行multithreading编程。那么,
浏览 1
提问于2014-12-17
得票数 37
回答已采纳
1
回答
在阿克卡转寄一封死信
akka
问题是使
Akka
的“死信范式”适应上述步骤。在第三步,我需要一种告诉A失败的方法,这封信应该保存到以后。似乎您通过让这些参与者subscribe到DeadLetter事件总线来“告诉”他们。
浏览 4
提问于2017-02-14
得票数 0
2
回答
带
背
压
的逐行文件IO水槽
scala
、
akka
、
akka-stream
我有一个文件处理工作,目前使用带有手动管理
背
压
的
akka
参与者来处理处理管道,但我从未能够在输入文件读取阶段成功地管理
背
压
。这似乎是使用文件作为接收器的
Akka
流的一个很好的用例,但我仍然不确定有三件事:2)我
如何
根据每行的ID进行分组?3)我
如何
施加
背
压
,使我在内存中读行的速度不会超过下游处理数据的速度?
浏览 6
提问于2016-04-15
得票数 5
回答已采纳
1
回答
如何
订阅在不同JVM上运行的reactive streams实现?
jvm
、
akka-stream
、
reactive-streams
让我们假设我们有两个
Akka
Stream流,每个流都在自己的JVM上运行。Subscribe the second stream to the first stream这个示例在一个JVM上运行得很好,但是我
如何
订阅运行在另一个
浏览 0
提问于2015-03-06
得票数 2
1
回答
Spring DeferredResult +
Akka
演员应用程序中的
背
压
spring
、
spring-mvc
、
akka
、
backpressure
、
deferred-result
我正在考虑使用一条
Akka
工作人员链在基于DeferredResult的Spring应用程序中建模一个工作流。本质上,控制器将返回一个DeferredResult,链中的参与者将工作来填充一个CompletableFuture,该CompletableFuture在完成时为DeferredResult
提供
信息。我不知道的是:*若然,我
如何
察觉这情况正在发生?
浏览 1
提问于2017-12-19
得票数 1
回答已采纳
1
回答
这是阿克卡卡夫卡流配置的好处,从
背
压机制的阿克卡流?
akka
、
akka-stream
、
akka-kafka
我们有一个
Akka
应用程序,它使用一个Kafka主题并将接收到的消息发送给
Akka
Actor。我不确定我的编程方式使用了
Akka
流内置的
背
压机制的所有优点。 .toMat(Sink.ignore)(Consumer.DrainControl.apply)这实现了我期望的业务用例,myActor接收命令更新(MyAvro) 我对
背
压
的技术概念更加恼火所以我的水槽为了
背
<
浏览 2
提问于2020-12-03
得票数 1
回答已采纳
1
回答
Akka
Http连接拒绝错误
scala
、
akka
、
akka-http
、
connection-refused
我有一个用
Akka
编写的web服务,在这里,我向每个用户发出一个post请求(加密一些数据)如下: http.singleRequest(HttpRequest(method = HttpMethods.POST此外,在上述情况下,
如何
在
Akka
HTTP中关闭连接。
浏览 1
提问于2018-03-08
得票数 0
1
回答
Scala通过
akka
流读取大量块数据
scala
、
akka
、
akka-stream
、
akka-http
我正在尝试通过scala读取大量数据,如下所示:Scala read continuous http stream import
akka
.actor.ActorSystemimport
akka
.stream.ActorMaterializer implicit这似乎是
背
浏览 10
提问于2020-06-18
得票数 0
回答已采纳
1
回答
阿克卡流与火花流
apache-spark
、
akka-stream
使用
akka
流与火花流进行流处理有什么优缺点?比如,内置
背
压
,性能,容错,内置转换,灵活性等。我不是在问
akka
vs火花正反严格流组件。另外,我并不是在问引擎盖框架架构的差异。
浏览 1
提问于2016-07-06
得票数 9
回答已采纳
1
回答
使用
akka
流或
akka
参与者创建动态管道
akka
、
actor
、
akka-stream
通常,我认为最好的方法是使用
Akka
流(带有
akka
http),因为它为您处理
背
压
等。问题是,我必须在运行时(基于http调用)创建多个不同配置的管道。目前,我不确定是否真的能够在运行时动态地旋转新的平行
akka
流管道(并删除和重新启动其中的一些管道)。对我来说,现在使用
akka
演员做这个听起来更好(基于队列使用者参与者和
akka
http参与者,我和我可以在运行时动态地创建一对),但是要使用它们,我还必须手动实现
背
压
等等。你认为可
浏览 1
提问于2018-07-02
得票数 0
回答已采纳
1
回答
将
Akka
HTTP连接到
Akka
流
akka
、
akka-stream
、
akka-http
我想用
Akka
HTTP构建一个REST服务,该服务连接到现有Sink (使用Kafka反应性流),但我不知道
如何
将HTTP流链接到
Akka
流接收器. 当
背
压
太高时500?有可能吗?
浏览 4
提问于2017-02-27
得票数 4
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
GrowingIO 响应式编程探索和实践
了解如何利用 SOLIDWORKS 提供的工具克服您的数据迁移挑战
英国政府提供100万英镑以了解如何发展芯片行业
了解目标用户:如何在店铺详情页面中提供最适合的信息
如何在生产中为机器学习模型提供服务?
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券