project-reactor 相关问题

Reactor是一个基础库，用于构建JVM上的反应式快速数据应用程序。它提供了Java，Groovy和其他JVM语言的抽象，使构建事件和数据驱动的应用程序更容易。它也非常快。

将 Flux 拆分为分组 Flux，重播或缓存每个分组 Flux，然后合并

我有一个天气消息流，每条消息都包含一个站点 ID 和一堆与天气相关的参数。每 5 分钟就会从三到四个不同的站点收到新消息。我...

reactive-programming project-reactor

回答 1 投票 0

项目reactor或spring webflux如何正确获取serverwebexchange对象？

我正在尝试构建类似 threadlocal 的东西，但适用于 webflux。我的问题是上下文或 serverwebexchange 对象如何从一个类传递到另一个类（过滤器、控制器、服务...

java spring-boot multithreading spring-webflux project-reactor

回答 1 投票 0

在 Spring Reactor 中获取上下文的引用

我正在使用Spring项目reactorreactor-core 3.1.8.RELEASE。我正在为我的微服务实现一个日志框架来拥有 JSON 审核日志，因此使用上下文来存储某些字段，例如 userID，

spring project-reactor

回答 2 投票 0

如何在 WebFlux 中访问用于 Spring Data 审计的 http 标头

我正在尝试利用http标头来审核我的Spring存储库，如此处所述https://docs.spring.io/spring-data/commons/docs/current/reference/html/#auditing.reactive -审计意识但是

spring-boot spring-data spring-webflux project-reactor

回答 2 投票 0

如何向 Spring 状态机外部配置添加反应防护？

我正在一个使用 Spring 状态机版本 3.2.1 的反应式 Java 项目中工作。我创建了一个像这样的反应式守卫：公共 ReactiveGuard bookingIdGuard(){

java spring spring-boot project-reactor spring-statemachine

回答 1 投票 0

通过检查返回 mono 的数据库中的值来确保唯一 id

spring-boot spring-webflux project-reactor reactive

回答 1 投票 0

HTTPClient 推荐

我创建了一个 Webclient 定制器，它使用自定义 ConnectionProvider 创建 HTTPClient @豆 WebClientCustomizer webClientCustomizer(CustomizedWebClientProperties 属性) {

spring-webflux project-reactor spring-webclient reactor-netty

回答 1 投票 0

使用 Spring boot + WebFlux 进行全局错误处理

在 Spring boot Rest 控制器中使用反应式编程时，我们如何全局处理异常？我认为 @ControllerAdvice 不会工作，因为我已经尝试过这个但它不成功......

spring-boot exception spring-webflux project-reactor

回答 4 投票 0

不使用block()/blockFirst()/blockLast()将mono转换为java对象

我想在不使用block()/blockFirst()/blockLast()的情况下将mono转换为object java。请告诉我转换的方法。

spring project-reactor

回答 3 投票 0

spring webflux 中的 then、thenEmpty、thenMany 和 flatMapMany 是什么？

不太明白spring webflux中Flux或Mono上的then、thenEmpty、thenMany和flatMapMany的用法和区别。

spring project-reactor spring-webflux

回答 2 投票 0

使用WebClient发送具有不同输入值的POST请求的最佳方式

我正在尝试使用 WebClient 通过在 POST 请求中以 JSON 字符串形式发送整数值来进行 API 调用。我有超过 100K 个值要发送请求。

java spring-boot spring-webflux reactive-programming project-reactor

回答 1 投票 0

下沉。在订阅者数量第一次达到 0 后，许多默默地变得毫无用处

如果我创建一个 Sinks.Many 实例： Sinks.Many sink = Sinks.many().multicast().onBackPressureBuffer(); 然后在另一个线程（T1）中，我订阅它的 Flux：新线程(() -> { ...

java multithreading concurrency spring-webflux project-reactor

回答 1 投票 0

为 Spring WebClient 配置每个请求的超时？

我知道 Spring 5 webflux 如何在 Webclient 上设置超时，但这会为所有请求全局配置超时。我正在寻找一种根据每个请求配置超时的方法。 IE。

spring spring-boot spring-webflux project-reactor

回答 2 投票 0

Spring Boot Reactive：向控制器添加 @Validate 注解会导致相关测试失败

我目前正在 Sprig Boot(2) 反应式项目中工作。所有 CRUD 端点和测试都工作正常。然后我决定在创建待办事项时添加验证，为此我添加了注释...

spring spring-mvc spring-webflux project-reactor

回答 1 投票 0

如何使用Reactor的StepVerifier来验证Mono是否为空？

我正在使用 StepVerifier 来测试值： @测试公共无效测试材料（）{ 事物事物=新事物(); Mono 结果 = Mono.just(thing); StepVerifier.create(结果).consumeNextW...

java unit-testing reactive-programming project-reactor

回答 3 投票 0

在反应流运算符（项目反应器）中使用“try catch”是错误的吗？

我正在使用项目reactor探索反应流，并且我有一个用例，如果在处理当前事件期间发生错误（例如，deseriali...

java spring-webflux reactive-programming project-reactor reactive-streams

回答 1 投票 0

将流转换为单声道

如何使用流限制从流中重新调用 Mono？需要从流中获取列表并检查大小元素 var peopleResult = Persons.getSomething().stream().limit(1).toList(); 我想添加列表到单声道。

java java-stream project-reactor

回答 1 投票 0

当flatMap返回一个空的Mono时如何调用switchIfEmpty？

我的标题听起来很混乱，所以让我用一些命令式伪代码来解释我想要做什么 Mono func() { Mono myThing = getMyThing(); 如果 myThing 不是 em...

java spring-webflux project-reactor

回答 2 投票 0

如何结合Mono和Flux来创建一个对象？

我想创建一个对象，该对象由一个Mono和一个Flux组成。假设有 2 个服务 getPersonalInfo 和 getFriendsInfo。 Person 需要这两种服务来创建对象。拉链...

java spring-webflux project-reactor reactor reactive-streams

回答 2 投票 0

Java 响应式应用程序的性能分析

JVM 有一套很棒的工具来查找应用程序中的热点。通过启用 JMX 并与 JProfiler / VisualVm 连接，我们可以很快找到工作流程中花费最多时间的方法。

java project-reactor

回答 1 投票 0

project-reactor 相关问题

最新问题