我对整个反应式范式都是新手，我正在尝试理解当从SQS这样的队列中读取时，背压是如何工作的。在Reactor中，你会有你的Flux，在RxJava中，你会在后台有你的可观察到的轮询SQS，比如： Future<ReceiveMessageResult> future您如何告诉轮询器由于速率限制而放慢速度，这样您最终就不会有一堆可能OOM的实时消息驻留在内存中？
浏览 0提问于2017-07-15得票数 0
回答已采纳
我在我的安卓应用程序中使用RxJava，我想从数据库中加载数据。
通过这种方式，我使用Observable.create()创建了一个新的可观察到的EventLog列表。此外，既然数据库加载了一个元素列表，那么立即发出整个列表是有意义的吗？还是我应该一次发出一个项目？
浏览 2提问于2015-12-10得票数 32
回答已采纳
2回答
在RxJava中，背压并不是真正的背压，而只是忽略了一些元素。RxJava不能影响元素发射，所以开发者需要自己实现它。想到的最简单的方法是使用一些计数器，在发射时递增，在完成时递减。
浏览 2提问于2016-11-12得票数 2
我是"backpressure".的初学者，我对RxJava的含义很好奇或者这是否意味着消费者正在对生产者施加压力？(相反方向的压力)
浏览 4提问于2017-10-01得票数 28
1回答
我需要处理我的流量中的背压，它接收一个对象列表作为输入。列表的大小从几百到几十万个元素不等。我需要把收到的所有数据都交给reactiveHandleDataService，我不能丢了一条消息。
在这种情况下，我如何处理背压？我没有找到很好地解释这个问题的例子，特别是使用迭代器作为源代码。我使用Californium SR3作为reactor的版本，这是spring boot应用程序的一部分。
浏览 15提问于2018-12-21得票数 1
1回答
我对分布式流处理(Spark)很陌生。我读过一些教程/例子，其中介绍了背压是如何导致生产者对超载消费者的反应减缓的。给出的典型例子是吞食和分析tweet。当流量突然激增，以致消费者无法处理负载时，他们会施加背压，而生产者则以较低的速度作出反应。
我没有真正看到的是，在实践中使用了哪些方法来处理由于整个管道容量较低而无法立即处理的大量实时数据？对于某些问题，只需删除数据就可
浏览 1提问于2018-04-08得票数 1
2回答
我有一个文件处理工作，目前使用带有手动管理背压的akka参与者来处理处理管道，但我从未能够在输入文件读取阶段成功地管理背压。此作业接受一个输入文件，并根据每行开头的ID号对行进行分组，然后，一旦它用新的ID号击中一行，就会通过消息将分组行推送给处理参与者，然后继续使用新的ID号，直到到达文件的末尾为止。这似乎是使用文件作为接收器的Akka流的一个很好的用例，但我仍然不确定有三件事：
1)如何逐行读取
浏览 6提问于2016-04-15得票数 5
回答已采纳
为什么在RxJava 2.0中引入了Flowable？什么时候我应该更喜欢使用Flowable而不是Observable？
浏览 0提问于2016-12-03得票数 33
回答已采纳
1回答
(HTTP上的背压)
、、、、
我想找到一些资源或例子，它展示了如何构建一个端到端、完全背压的REST服务+客户端。我的意思是，我希望看到，如果REST客户机实现了反应性流(无论是在Akka、JS还是其他类型的)，我将拥有(并且能够“可视化”)在构建的整个REST服务器中处理背压，例如使用Akka-Http。我正在搜索类似于以下谈话的内容(但我找不到幻灯片或视频来证实)：
我对大多数示例表示怀疑的是，我可以找到很多情况，REST服务(服务器)在后端使用Akka Http和Akka流，但我不确定如果客户端正在实现反应性流
浏览 3提问于2015-05-18得票数 5
回答已采纳
嗨，我正在阅读rxjava2，它基本上是用于异步操作的。我发现它有一个运营商的概念，而AsyncTask在安卓系统中却没有。
否则rxjava2和AsyncTask有什么区别？
浏览 1提问于2017-10-23得票数 7
回答已采纳
我正在寻找一种可以限制当前正在处理的数据量的选项。
用例:我正在从Kafka数据流中读取并处理该数据，我希望限制正在传输的消息的数量。这样做的原因是第三方应用程序的吞吐量。一般来说，这不是问题，但在背压的情况下，由于这些失败，经常会出现失败和应用程序重启。
浏览 0提问于2021-05-23得票数 0
我是反应性编程的新手，我正在尝试使用rxjava 2创建一个简单的背压感知消息处理。
subscribe(val -> Another_Time_Consuming_Task(val));现在对于小型操作，我没有看到任何与背压相关的问题但对于大的溪流，我不知道它将如何表现。
在BackpressureStrategy.
浏览 4提问于2017-05-12得票数 7
回答已采纳
我正在使用Flink 1.10，我有一个简单的flink应用程序，Operator BackPresureMap High我会问，考虑到上述的背压状况，瓶颈在哪一部分
浏览 1提问于2021-06-24得票数 0
回答已采纳
3回答
其用途是定期从设备中访问此服务，获取数据并将其缓存在设备内存中。由于设备不需要立即提供数据，所以我采用这种方式进行设计。Device: puts a request in queue (SQS)
Service: polls messages from SQS, process the requests and publish简而言之，我只能每秒处理部分传入请求(假设有200个请求，占实际TPS的20% )。这会导致在请求队列中产生反压力。通过互联网阅读，我发现处理背<
浏览 0提问于2021-07-19得票数 9
回答已采纳
在处理SQS事件流时，如果Lambda函数没有足够的保留并发，则该函数将被限制，并且可以通过SQS重新驱动策略重试未处理的事件/消息。我从来不喜欢这种限制，因为未处理的消息在经过任意次数的重试/消息可见性超时后最终会在DLQ上结束。我到处寻找，但找不到任何关于背压如何通过MSK实现到Lambda的细节。有没有人对MSK主题消费者如何处理Lambda节流有任何见解？
非常感谢！
浏览 13提问于2021-01-10得票数 1
我有一个带有本地db (room)的应用程序和一个使用retrofit 2和rxjava从数据库中获取所有“事件”的服务。当我发送大量的POSTs (即1500+)时，应用程序会抛出一个OutOfMemoryException。我认为这是因为每次客户端发送新帖子时都会启动一个新线程。有办法阻止retrofit/ rxJava创建这么多线程吗？还是等待服务器响应更好？throws Exception {
return eventDatabase.eventDao().delete(event
浏览 1提问于2018-03-15得票数 3
回答已采纳
我是RxJava新手，我试图实现来自RabbitMQ队列的可观察到的消息，该队列支持无损的背压。我已经从Spring中创建了一个可观察的。这可以在同步环境(例如)中很好地处理背压，但是一旦引入多个线程，背压就会从窗口中消失--正如您所期望的那样。container.start();
}我不知道如
浏览 1提问于2016-07-01得票数 3
回答已采纳
如果套接字没有断开，如果没有错误，套接字连接或数据流发生了什么？
另一方面，(服务器端，数据发送方)似乎是连续地流数据，而客户端(nodejs应用程序)已经停止接收数据。
浏览 2提问于2019-05-09得票数 0
回答已采纳
我只想通过缓冲来自Observable的最新排放来处理背压。
Observer完成处理1并开始处理4 (排放2和3被删除)。这似乎是在可观察的Rx中处理进度的常见情况，因为您通常只关心使用最新的进度信息更新UI。然而，我一直未能想出如何</
浏览 2提问于2015-08-04得票数 6
回答已采纳
1回答
在转换流中实现背压
、、、
我在读这些文档：Readable.pipe(Transformable).pipe(Writable);
}
但是，由于它说可以操作转换流的传入和传出highWaterMark --我如何更改传入/传出数据的highW
浏览 1提问于2019-07-31得票数 2
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号