project-reactor 相关问题

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

WebFlux Flux.cache() 缓存发出的数据存储多长时间

上下文：我有一个有限的 Flux，它是 Rest API 调用的来源，并且该通量位于对我的 Spring Boot 应用程序进行的主 REST API 调用的范围内，该应用程序返回 Mono 并响应。我愿意...

spring spring-webflux project-reactor

回答 1 投票 0

如何批量处理助焊剂并并行处理每个批次

我的数据库中有 5,000,000 个实体。我通过反应式驱动程序（r2dbc）连接到数据库。接下来，我想将其拆分为 100,000 个实体，将它们拆分为 1,000 个实体的捆绑包，然后

java spring-boot project-reactor r2dbc

回答 1 投票 0

如果 Flux 为空，如何传递 Consumer/Runnable？

我有一个 Flux 元素，我想记录一条消息，以防它不包含任何元素。我尝试了这个，但它没有按预期工作。该异常没有被我的消费者“捕获”，而是

java project-reactor

回答 1 投票 0

如何将 Mono 变成真正的异步（非反应式！）方法调用？

我有一个方法 @服务公共类我的服务{ 公共 Mono processData() { ... // 非常长的反应操作 } } 在正常的程序流程中，我调用这个方法

java asynchronous spring-webflux project-reactor

回答 2 投票 0

关闭reactor netty HttpClient的正确方法

Reactor netty HttpClient 没有关闭或关闭句柄的方法。 HttpClient释放资源的正确方法是什么？根据文档当我使用 HttpC 创建 HttpClient 时...

java project-reactor reactor-netty

回答 1 投票 0

Project Reactor 中的默认调度程序是什么？

Project Reactor 中是否有“默认”调度程序？哪一个？我所说的“默认”是指当链没有调用 subscribeOn() 或publishOn() 时使用的默认值。

spring-webflux project-reactor reactor

回答 2 投票 0

在 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

project-reactor 相关问题

最新问题