spring-webflux 相关问题

Spring Framework 5包含一个新的spring-webflux模块。该模块包含对被动HTTP和WebSocket客户端以及被动服务器Web应用程序的支持,包括REST,HTML浏览器和WebSocket样式交互.WebFlux可以在Servlet容器上运行,支持Servlet 3.1非阻塞IO API以及其他异步运行时,如Netty和Undertow。

Resilience4j 和 Reactor Retry 不一起工作时以每秒 10 个请求分发 100 个请求

我正在调用远程服务,并且不想超过 10 RPS,因此我配置了 Resilience4j Rate Limiter 并添加了 retryWhen 来处理 RequestNotPermission 错误并在允许时重试。 该项目...

回答 1 投票 0

Spring Boot ReactiveCircuitBreaker 配置不起作用

我在基于 Spring Boot Webflux 构建的反应式 Web 服务中使用断路器实现。我在 pom.xml 中使用以下依赖项: org.springframework.bo...

回答 2 投票 0

如何在BFF架构Spring Webflux中获取JWT令牌

我已经使用 TokenRelay 过滤器通过 Spring Webflux 实现了前端后端(BFF)架构。我的前端使用 cookie 作为身份验证机制与 BFF 进行通信,而 BFF...

回答 1 投票 0

当为不受限制的端点发送授权标头时,Springboot webflux 抛出 401

我有一个受 spring security oauth2 保护的 springboot webflux 应用程序。我的应用程序中既有受限制的端点,也有不受限制的端点。通过授权时应用程序抛出 401...

回答 3 投票 0

使用repeatWhen()和takeUntil()重复订阅Mono

我想了解重复订阅Mono并延迟1秒并根据某个条件停止订阅的效果,我有这行代码 Mono.just(UUID.rando...

回答 1 投票 0

需要帮助启动非 HTTP 请求的跟踪上下文

我们正在使用队列中的消息,立即在服务中启动进程(该服务中有大量日志),并使用 HTTP Rest 客户端调用多个下游。 我们能够

回答 1 投票 0

MYSQL R2DBC 的 Spring Data 多主机设置

我正在尝试从 Spring R2DBC 访问只读副本数据库。我的连接字符串如下所示 春天: r2dbc: url: r2dbc:mysql://db-master-dev-pvt.xyz***.com:3306,db-replica-dev-pvt.x...

回答 3 投票 0

反应堆中的map与flatMap

我找到了很多关于RxJava的答案,但我想了解它在Reactor中是如何工作的。 我目前的理解很模糊,我倾向于认为 map 是同步的,而 flatMap 是

回答 3 投票 0

如何正确读取Flux<DataBuffer>并将其转换为单个inputStream

我正在为我的 spring-boot 应用程序使用 WebClient 和自定义 BodyExtractor 类 WebClient webLCient = WebClient.create(); webClient.get() .uri(url, 参数) .accept(MediaType.APPLICATION.XML...

回答 6 投票 0

WebClient 请求中的 timeout() 和 HttpClient 中的 timeout 的区别

我试图调用一个服务,并想为其设置超时。我找到了两种方法可以做到这一点。 通过在HttpClient中全局设置读写超时然后使用它

回答 2 投票 0

Spring Webflux + Spring Security - 预授权不起作用(使用 Kotlin)

这是我的代码: 安全配置 @配置 @EnableWebFluxSecurity @EnableReactiveMethodSecurity 内部类 WebAuthorizationConfig( private val userDetailsManager: ReactiveUserDetailsMa...

回答 1 投票 0

Spring Webflux PreAuthorize 不起作用(使用 Kotlin)

这是我的代码: 安全配置 @配置 @EnableWebFluxSecurity @EnableReactiveMethodSecurity 内部类 WebAuthorizationConfig( private val userDetailsManager: ReactiveUserDetailsMa...

回答 1 投票 0

Spring Cloud Gateway安全配置错误

我尝试使用 Spring Security 运行应用程序,但出现以下错误,我不知道为什么。 我正在关注此指南视频 - https://www.youtube.com/watch?v=rbKzR6QWKLI&t=486s&ab_ch...

回答 1 投票 0

Spring 安全错误

我尝试使用 Spring Security 运行应用程序,但出现以下错误,我不知道为什么。 我正在关注此指南视频 - https://www.youtube.com/watch?v=rbKzR6QWKLI&t=486s&ab_ch...

回答 1 投票 0

无法在 Angular 中订阅 WebFlux 流

我编写了一个通过 WebFlux(Spring boot)的 Flux 生成流的服务器。提供流的方法 公共 Flux getStream() { Flux 初始数据 = Flux.jus...

回答 1 投票 0

基于 Kotlin 协程的 Spring EL 评估失败

给定一个这样的接口和实现类。 接口 MyBean{ 挂起乐趣 挂起 isEnabled(name:String): Boolean } @Service(“myBean”) @NoArg // 我创建了一个注释...

回答 1 投票 0

Spring Webflux 和 @Cacheable - 缓存 Mono / Flux 类型结果的正确方法

我正在学习 Spring WebFlux,在编写示例应用程序期间,我发现了与响应式类型(Mono/Flux)与 Spring Cache 相结合相关的问题。 考虑以下代码片段(在 Kotl 中...

回答 4 投票 0

Mono.just 和非反应式弹簧靴

我最近开始在一个新项目中使用 Spring Boot,该项目具有以下代码(简化): @RestController @RequestMapping(“/用户”) 公共类 MyController { @Autowire...

回答 1 投票 0

针对即时 HTTP 请求,使用 Webflux 和 Spring Security 进行 OAuth2 客户端登录的预期数量是多少?

目前,我们正在身份提供商处监控大量客户端登录,我想确定一下我们对 Spring Security 的期望。 我们的设置如下 @配置(

回答 1 投票 0

Flux groupBy 和每个新数据部分的新traceId

我想像这样实现反应式kafka消费者: https://projectreactor.io/docs/kafka/release/reference/[6.8。具有基于分区的排序的并发处理 ][1] 调度器 调度器 =

回答 1 投票 0

最新问题
© www.soinside.com 2019 - 2024. All rights reserved.