return ResponseEntity.status(statusCode); return executeResult;
} 因此，我们理解这是一个背压问题
浏览 19提问于2021-08-15得票数 0
if (v % 2 == 0) { } ...} .lift(new MyOperator())我遇到了以下问题：
背压发生，因此doSomething(n)无法处理即将到来的
浏览 0提问于2018-02-22得票数 0
回答已采纳
1回答
假设我在数据库里有一百万行记录。然后，我使用可流动(而不是可观察)读取记录，然后用缓慢的加密写入文件(写入要比读取慢得多)。如果是，是否使用“反应拉力”是防止这种异常的唯一方法，如果我也不想使用像节流这样的操作符，等等。
浏览 0提问于2017-09-05得票数 0
回答已采纳
当我想要使用TriggerOnce时，我如何为我的工作配置背压？ 在spark 2.4中，我有一个用例，回填一些数据，然后启动流。因此，我使用max、maxOffsetsPerTrigger和maxFilesPerTrigger来控制我的spark可以处理多少数据。这就是我配置背压的方式。
浏览 21提问于2021-03-24得票数 4
在2.x上，Observable类型不再支持背压。如果您的事件来源可以减缓，您应该使用具有适当背压策略的Flowable。这将防止MissingBackPressureException如per @akarnokd答复：
“有一些用例.，人们不想丢失数据。我同意，但在这种情况下，应该对每个用例使用适当的背压策略。“当时的项目管理决定在可观察类型的基础上增加反压力，理论上应该能够同时处理有限度的和无限制的使用
浏览 6提问于2017-03-27得票数 0
回答已采纳
我扩展了AbstractOnSubscribe以创建自己的OnSubscribe，以便与我命名为的Observable.create(OnSubscribe<T>)一起使用，它基本上读取一个InputStream问题是，我也需要这样做，因为InputStream是另一个Observable的一部分。(new OnSubscribeInputStreamToLines(is)));
问题是，这并不是真正有效的，因为它将为每个inputStream创建一个可观察的。有一种方法可以方便地将我的OnSubscribeInputStrea
浏览 4提问于2015-09-15得票数 1
我正在寻找一种可以限制当前正在处理的数据量的选项。
用例:我正在从Kafka数据流中读取并处理该数据，我希望限制正在传输的消息的数量。这样做的原因是第三方应用程序的吞吐量。一般来说，这不是问题，但在背压的情况下，由于这些失败，经常会出现失败和应用程序重启。
浏览 0提问于2021-05-23得票数 0
1回答
我们有，其中使用了诸如Mongodb、Postgresql等反应性数据库。这些数据库确实有各自的响应驱动程序。我们所说的反应性是否意味着，如果我们有10万条记录，我们将不会同时加载所有10万条记录，而我们将以小批的方式获取数据。
浏览 5提问于2021-12-24得票数 0
基本问题:与WebClient相比，弹簧反应堆RestTemplate是如何实现非阻塞的？在将请求发送到外部服务(例如)之后，它不需要阻塞某个地方吗？HTTP本质上是同步的，对吗？
浏览 0提问于2018-08-15得票数 5
我正在尝试使用spring的RestTemplate将文件下载的结果直接流式传输到另一篇文章中 ResponseEntity<InputStreamResource> downloadResponse= downloadResponse.getBody();
...sun.net.www.protocol.htt
浏览 0提问于2017-01-25得票数 10
我正在建立一个使用RxJS的交易机器人。为此，我必须将报价器数据从套接字连接转换为每x秒发出的指示灯。const subscribeObservable = Observable.fromEventPattern(h => bittrex.websockets.subscribe(['USDT-BTC'], h))
cons
浏览 4提问于2018-02-04得票数 0
api是这样的(实际上，|是管道)：然而，BlackBox实际上是一个require('child_process').spawn的包装器，所以实际上如下所示：
inputStream | BlackBox.Writable -> proc.stdin -> proc.stdout -> BlackBox.Readable | outputStream我可以很容易地用streams1来完成这个任务，但是我想了解streams2
浏览 0提问于2013-07-02得票数 1
回答已采纳
我们有一个用例，客户端错误地发送了10000个请求，对于每个请求，我们必须立即发送一个ID，然后使用多个DB调用/rest调用丰富数据，最后返回到Kafka主题。由于处理过多，整个系统都出现了故障，包括带下划线的系统，以及Kakfa，我们还将发布到MQ，后者再次进行进一步处理。要求是控制客户端可以发送的请求数量，我们认为控制它可以根据每天或每小时将阈值存储在DB中，并在达到阈值后开始拒绝，但这需要计算和DB命中。我们正在寻找一种背压技术，如春天，网络流量等。
它是Java 11
浏览 0提问于2021-08-26得票数 0
回答已采纳
1回答
MQTT通配符订阅、背压和QOS
、、、、
这是一个更一般的问题，但是在不同的客户端或协议版本，甚至服务器版本中，可能会有不同的处理方式。如果背压是通过确认施加的，这与通配符主题有什么关系？"这是否意味着背压也是在每个主题的基础上处理，还是在通配符订阅的基础上进行维护？所以我做了一些HiveMQ和
浏览 8提问于2020-07-23得票数 2
如果没有MQ架构，如下所示--有一个共享DB，工作人员在DB中查找下一个url来处理、处理和更新DB。如果有10万个这样的urls，100个这样的站点呢？我应否同时在讯息队列中放置10万个物件？或者应该有某种背压--我把100个urls放在队列中，等待所有的urls都被处理，然后再放下100个等等？
或者，也许这样的用例不适合消息队列？
浏览 3提问于2015-04-04得票数 1
回答已采纳
这与Windows 2011服务器和Exchange 2010有关。15004：和15006，除第一行外，与上面的消息相同：
Microsoft Exchange传输拒绝邮件提交，因为可用磁盘空间已降至低于配置阈值。
浏览 0提问于2015-08-07得票数 2
$ResponseEntityResponseExtractor.extractData(RestTemplate.java:884) ~[stonjar.jar:4.0.3] at org.springframework.web.client.Res
浏览 22提问于2019-02-02得票数 3
回答已采纳
1回答
FlowGraph { b => k2 ~> merge merge ~> f ~> ioHandlerSink这就是我连接publisher和sinkIOHandler actor处理消息的速度非常慢，所以我如何才能拥有多个IOHandlers，并且我应该能够分发任务。我也想保持背压，这样就不用火了，也忘了用路由器了。
浏览 1提问于2014-11-19得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
