spring-webflux 相关问题

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

Spring Boot 2.0.0.M7 Spring 云网关(Finchley.M5)和 netflix eureka 集成不起作用

我正在尝试访问 application.yml 中定义的 /get API 或端点,但收到 404 not found 获取/获取 HTTP/1.1 接受: */* 接受编码:gzip、deflate 连接:保持活动状态 主持人:

回答 1 投票 0

flatMap 中的单声道超时 - 在“flatMap”中的 20000 毫秒内没有观察到任何项目或终端信号(并且未配置后备)

我正在使用 Spring WebFlux 发出 POST 请求,但收到以下错误: java.util.concurrent.TimeoutException: 没有观察到任何项目或 'flatMap 中 20000ms 内的终端信号...

回答 1 投票 0

ReactiveFeignClient 错误:类具有合约默认未使用的注释 [ReactiveFeignClient]

我正在构建一个微服务,它使用另一个微服务中定义的 Reactive Feign Client 来获取一些数据。我添加了 feign 客户端的配置,启用了响应式 feign

回答 1 投票 0

使用 spring webflux 的非阻塞 REST API

我需要使仪表板非阻塞 REST API 具有以下详细信息: 客户资料——来自第 3 方 API 客户帐户——来自另一个第 3 方 API 顾客受益

回答 1 投票 0

SpringBoot3 SpringWebflux 和 GraphQL 抛出 No ContextAccessor for contextType: classreactor.util.context.Context

我正在使用SpringBoot3(3.1.5)。我的应用程序是基于路径(Maven)上的 spring-boot-starter-webflux 和 spring-boot-starter-graphql 的反应式应用程序。当我调用 GraphQL(GraphiQL 或 Postman)时,我得到一个

回答 1 投票 0

Spring Webflux:嵌套 Flatmap 替代品

我有一个场景,第二个单声道依赖于第一个单声道,而 ThridMono 调用依赖于第二个单声道输出。 我编写的代码如下。 首先Mono.flatMap{ val secondaryMono = callWebservice(

回答 2 投票 0

创建类路径资源中定义的名称为“connectionFactory”的bean时出错[org/springframework/boot/autoconfigure/r2dbc/

我有一个关于喷射玻璃的简单项目。这是您使用 MongoDB 的地方,它配置为 ReplicaSet。我不使用自动配置,而是使用配置文件来配置操作...

回答 1 投票 0

Spring Web客户端在日志中添加自定义消息

webclient/Flux 新手。我一直在尝试记录 webclient 请求/响应标头和正文。通过 netty 窃听,我可以打印标题和正文。但无论如何我想要一个...

回答 1 投票 0

在 springboot webflux 中确定传入请求的 HTTP 版本

我正在寻找一种在 spring webflux netty 服务器中查找传入请求的 HTTP 版本的方法 我在 ServerWebExchange 中找不到任何方法来获取此信息。 Spring servlet 有一些

回答 1 投票 0

当我受到阻塞库的限制时,将阻塞代码转换为反应式代码

我有一个自定义的 Kafka 库,出于商业原因我不得不使用它。我的用例是从 Kafka 读取每条记录并将其保存到存储库。我的存储库的条目是我编写的回调...

回答 1 投票 0

NoClassDefFoundError:BearerTokenServerAuthenticationEntryPoint

我在 .oauth2ResourceServer((oauth2) -> oauth2.jwt(Customizer.withDefa...

回答 1 投票 0

Mono.then() 与 .and() 并行化

我之前将实体保存到表中,如下所示: insertTableOne(foo).then(insertTableTwo(foo)).then(Mono.just(foo)); 团队成员建议使用 .and() 来并行插入: 插入表格O...

回答 1 投票 0

使用 WebFlux OAuth2 进行社交登录

我正在开发一个 Spring Boot 微服务项目,该项目使用 oauth2,遵循使用 Keycloak 进行身份验证的 YouTube 教程。我没有使用 Keycloak,而是选择配置 Google OA...

回答 1 投票 0

在webflux中创建bean时如何访问spring websession

我在我的应用程序中使用keycloak,并尝试通过在执行时发送两个必需的参数client_session_state和client_session_host来动态配置反向通道注销URL...

回答 1 投票 0

如何修改 Spring WebFlux 过滤器中的请求正文?

我有一个使用 WebFlux 的 Spring Boot 应用程序,并且我正在尝试修改 WebFilter 中的请求正文。具体来说,每个传入请求都包含一个名为 user 的标头,并且所有 POST 请求...

回答 1 投票 0

如何使用 DriverConfigLoader 增加 Cassandra Java 驱动程序中的默认超时?

关于 Spring Webflux Reactive Cassandra 应用程序的小问题。 在使用 Webflux 和反应式 Cassandra 设置 Spring Boot 2.6.4 时,我使用该应用程序在 Cassandra 中插入一些数据

回答 3 投票 0

Kotlin 协程 + opentelemetry 失去上下文并获得 NPE

我试图了解如何使用 spring webflux 和 opentelemetry 与 kotlin 协程一起使用。 当我尝试在协程中执行一些日志时,我在 kotlin.coroutines.jvm.internal 上收到 NPE。

回答 1 投票 0

使用 Spring Reactive Redis pub/sub 时如何取消订阅(断开与频道的连接)?

我目前正在春季使用 Reactive Redis pub/sub,我想取消订阅 如果我在使用时遇到某些情况(例如套接字断开),您知道如何取消我的订阅吗

回答 1 投票 0

Webflux WebCient 的时间成本

我有一个 Spring Boot 服务,它使用 WebClient 调用另一个外部服务。外部服务的平均延迟约为 15 ms(通过 Datadog 测量)。但是当外部API是c...

回答 1 投票 0

即使存在客户端 40X 或 50X 错误,如何让 Http 客户端接口返回 ResponseEntity

给出一个简单的方法,例如 @GetExchange("/foo") Mono>> getFoos(); 在 FooInterface 中,有一个“标准”WebClient 支持它。 工厂我...

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.