project-reactor 相关问题

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

在 Reactor switchIfEmpty 上抛出异常之前从数据库读取消息

我们正在使用 webflux，当找不到对象时我需要抛出错误。我们有一个错误代码 ENTITY_NOT_FOUND，我们需要抛出一个 MyException() 以及错误代码的消息，那......

generics spring-webflux project-reactor

回答 1 投票 0

如何强制 Reactor 在非守护线程上运行 subscribe() 代码？

这是这个问题的后续，而这个问题又是这个问题的后续为了使这些消费者产生任何影响并产生标准输出的任何输出，您不能像我一样运行此代码...

java project-reactor

回答 1 投票 0

不支持 spring boot webclient 阻塞

以下功能：公共 ScoringResponse 搜索（SearchRequest searchRequest）{ 返回 webClient.post() .bodyValue(搜索请求) 。取回（） .onStatus(

java spring-boot spring-webflux project-reactor spring-webclient

回答 1 投票 0

如何在 Project Reactor 中捕获异常？

https://httpbin.org/status/404 返回 404 错误。总是。我如何捕获它以及为什么我的尝试失败了？这是代码。我实际上将代码片段包装在 Junit 测试中（如下所示：@Test{/*

java project-reactor

回答 1 投票 0

Flux.switchIfEmpty - 如果第一个 Flux 完成时没有切换怎么办？

我有以下场景，有两个端点（我们称之为 A 和 B）返回一些值，我需要处理这些值并将其报告给第三个端点（我们称之为 C）。价值观可以...

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

回答 1 投票 0

StepVerifier 的“记录”功能如何工作？

为什么这个测试失败？导入 org.junit.jupiter.api.Test; 导入 org.springframework.security.core.GrantedAuthority; 导入 org.springframework.security.core.authority.SimpleGrantedAuthority; 小鬼...

java spring-webflux project-reactor

回答 1 投票 0

Project Reactor Mono.block() 和 Mono.subscribe() 有什么区别

我找不到使用 Mono.block() 和 Mono.subscribe() 的区别对我来说，当使用这两种方法时，代码的行为完全相同。但它不应该。对于 Mono.block() 我的期望是......

spring-webflux project-reactor

回答 1 投票 0

如何检查单声道是否为空？

如何检查函数的结果是否为空并根据它执行不同的操作？我的方法返回 Mono，例如： // 迭代超过 5 个项目... .flatMap { 项目 ->

kotlin project-reactor

回答 1 投票 0

在 HandlerFilterFunction 中读取请求正文，如果有效则传递给下一个处理程序

用例是使用请求正文验证 JWT 中的数据。 JWT 子包含 { "sub": "{\"data\": {\"street\": \"Street 1\", \"landmark\": \"

spring-boot spring-webflux project-reactor

回答 1 投票 0

尝试使用 create 方法创建字符串流（Flux），但它不起作用

我正在尝试通过多次查询某些API端点来创建Flux。我收到的有效负载有一个变量，指示数据是否已用完，这意味着在此 JSON 有效负载中存在已完成

spring-boot project-reactor flux

回答 1 投票 0

Reactor StepVerifier 测试因 blockFirst() 失败

这是检查数据库中重复名称的代码公共Mono validateDuplicateName（字符串名称）抛出RuntimeException { Flux customerFlux = customerRepository.

project-reactor

回答 2 投票 0

Reactor groupBy：取消 GroupedFlux 后剩余的项目会怎样？

我需要按高基数的键对无限通量进行分组。例如：组密钥是域 url 对一个域的调用应该严格按顺序进行（下一个调用发生在前一个域完成之后）

project-reactor

回答 2 投票 0

如何在Reactor Netty中实现CORS？

如您所知，CORS 标准包括最初发送 OPTIONS 请求来检查有效性，我决定在处理程序中释放 OPTIONS 请求的处理，但是出现了问题...

java project-reactor reactor-netty

回答 2 投票 0

1 分钟后使用 webclient 进行同步调用时 Spring Cloud Gateway 应用程序挂起

Spring云网关版本：4.1.0 我们正在使用 Spring Cloud Gateway 框架开发 API 网关应用程序。该应用程序有几个作为全局实现的前置过滤器和后置过滤器

spring-boot spring-cloud project-reactor spring-cloud-gateway spring-webclient

回答 1 投票 0

将 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

project-reactor 相关问题

最新问题