Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
反应式编程的优点/缺点
我不断研究和尝试使用 Reactor 和 RxJava 的响应式编码 我确实明白 与单线程执行相比 反应式编码可以更好地利用 CPU 在基于 Web 的应用程序中 反应式编程与命令式编程之间有具体的比较吗 与非反应式编程相比 使用反应式编程
Java
reactiveprogramming
microservices
RxJava2
projectreactor
在从 ReactiveMongoRepository 对象返回的 Mono 对象上执行 block() 时出现异常
我有一个服务将数据流式传输到第二个服务 该服务接收对象流并将它们保存到我的 MongoDB 中 在从流服务获取的 Flux 对象的订阅函数中 我使用 ReactiveMongoRepository 接口中的 save 方法 当我尝试使用块函
MongoDB
springboot
reactiveprogramming
projectreactor
Spring 网关:使用 Mono.fromCallable() 包装阻塞调用
场景 在我的 Spring 云网关中 我需要根据数据库中保存的一些数据修改请求 因此我正在实现一个网关过滤器 考虑以下实现 存储库接口 public interface MyReactiveRepository Mono
Java
Spring
projectreactor
Blocking
springcloudgateway
Spring Reactor onErrorContinue 不工作
As per 文档 https projectreactor io docs core release api reactor core publisher Flux html onErrorContinue java util funct
Java
SpringWebFlux
projectreactor
flux
Akka 或 Reactor [关闭]
Closed 这个问题是基于意见的 help closed questions 目前不接受答案 我正在启动一个新项目 基于java 我需要将其构建为模块化 分布式和弹性架构 因此 我希望业务流程能够相互通信 互操作 但又独立 我现在正在研究
Java
Spring
akka
reactor
projectreactor
从projectreactor使用Flux时生成和处理异常的正确方法是什么
我正在使用 io projectreactor 3 reactor core 3 2 6 RELEASE 我注意到错误处理方面存在一些差异 不幸的是 官方文档没有提供足够的细节来解决我的问题 我有以下 4 个片段 在某些情况下 异常将被忽略
Java
reactiveprogramming
projectreactor
Reactive Kafka:仅一次处理事务
最初通过 api 调用触发 1 Service A produces m1 to topic1 non transactional send 2 Service B consumes topic1 and does some process
ApacheKafka
springKafka
projectreactor
reactivekafka
使用 Spring Reactor 时为什么要使用断路器和隔板?
请帮助我找到断路器和隔板模式在 Spring Reactor 应用程序中有用的原因 由于 Reactor 中的操作将是非阻塞的 并且这两种模式旨在节省对资源 主要是线程 的潜在影响 因此在什么情况下我可以使 Spring Reactor 应
projectreactor
circuitbreaker
resilience4j
如何用StepVerifier验证提供的Mono没有完成?
With StepVerifier很容易检查是否提供Mono已完成 仅通过expectComplete 中的方法StepVerifier 但是如果需要检查相反的情况该怎么办 我尝试使用这种方法 Test public void neverM
projectreactor
如何在 Project Reactor 中实现轮询逻辑?
我有一个方法发送请求以获取作业状态并返回状态 如下所示 Mono
Spring
projectreactor
从 EmitterProcessor 移动到 Sinks.many()
已经使用有一段时间了create an EmitterProcessor内置sink如下 EmitterProcessor
projectreactor
Reactor 和 Webflux 中的 Mono 链超时算子到底测量了什么?
我正在使用 Spring Webflux 并试图理解 Monos 链的超时概念 例如 有一系列 Mono 调用 myService firstOperation then myService secondOperation then myS
Java
Spring
reactiveprogramming
SpringWebFlux
projectreactor
使用 Project Reactor 和 DirectoryStream 列出目录内容
我想将 DirectoryStream 与 Project Reactor 一起使用来列出目录中的所有文件 我的尝试是 Path myDir Paths get C Users r dacanal Documents Reply EDA l
projectreactor
flux
directorystream
从 3 个不同的单声道创建实体
我是反应式编程的新手 我看到可以压缩两个单声道来生成结果 Mono
Java
Spring
projectreactor
如何在Reactor中进行分页?
我向第三方 Web 服务重复发出分页 WebClient 请求 我现在的实现有效但正在阻塞 到目前为止我的实现 var elementsPerPage 10 Flux generate gt 0 pageIndex emitter gt B
Java
Spring
SpringWebFlux
projectreactor
springwebclient
如何使用Reactor(Spring WebClient)进行重复调用?
我使用 Reactor Spring5 WebClient 作为我的反应式编程 API 我有 2 个 REST 端点要调用 第一个结果将作为第二个结果的参数 对于第二个 API 它将返回带有 hasMore 值的结果 如果这个值是true
Spring
SpringWebFlux
projectreactor
spring amqp中使用spring webclient的正确方法
我有以下用于使用来自rabbitmq的消息的spring amqp应用程序的技术堆栈 Spring boot 2 2 6 RELEASE Reactor Netty 0 9 12 RELEASE Reactor Core 3 3 10 RE
rabbitmq
projectreactor
springamqp
springwebclient
reactornetty
在 Project Reactor 中处理数据的最佳方法
在项目反应器中处理数据的最佳方法是什么 使用平面地图 public Mono
Java
SpringWebFlux
reactiveprogramming
projectreactor
如何从 Http 集成流程创建 Spring Reactor Flux?
我有一个与此非常相似的问题如何从 ActiveMQ 队列创建 Spring Reactor Flux 唯一的区别是消息来自 Http 端点而不是 JMS 队列 问题是消息通道由于某种原因没有被填充 或者它没有被 Flux from 拾取 日
Java
Spring
springintegration
reactiveprogramming
projectreactor
使用 IntelliJ IDEA 调试 Spring WebFlux / Reactor 应用程序
我正在使用 IntelliJ IDEA 创建 Spring WebFlux Reactor 应用程序 IDEA的调试器显示了许多无用的行 例如MonoDefer MonoFlatMap等 有没有办法轻松跟踪堆栈 不幸的是 在异步世界中 堆栈
Spring
intellijidea
projectreactor
«
1
2
3
4
5
»