问题标签 [webflux]

我在旧的弹簧船上有一个 LoggerInterceptor 方便的错误。在那里我可以这样做：

• 在处理程序执行后调用
• 在完成请求并生成视图后调用

现在尝试使用来自 WebFlux 的 WebFilter 作为网关。但是没有记录对 keycloak 服务器的请求。只有当我切换到调试级别时，我才会看到来自例如 Netty -Server 的输出。

@Slf4j 公共类 LoggingWebFilter 实现 WebFilter {

我用 MongoDB 做了一个简单的程序。

每次连接 Web 请求时都会出现一个线程。
问题是即使断开连接，线程也不会消失。

随着时间的推移，'boundedElastic' 消失了。
但是“nioEventLoopGroup”和“reactor-http-nio”仍然存在。

我很担心，希望能解决这些问题。

调试 > 线程：随着时间的推移，“有界弹性”被组织起来。

Mono.just(null) 不会编译。这是为什么？

在程序层面上，我明白了。没有要处理的东西的处理队列是没有意义的。有人可以用更多的技术深度为我表达这个吗？

我正在调用外部服务来获取externalId，如果该服务不起作用，我所需要的只是填充值null

我正在尝试使用 Spring WebFlux Webclient。试图在石英 cron 作业中创建一个简单的网络客户端

this.webClient = WebClient.create(this.queryUrl);

我确保 queryUrl 有效。

但是，我遇到以下错误：

跟踪代码，我发现 DefaultExchangeStrategiesBuilder 为空。

有谁知道缺少什么？这是一个简单的网络客户端。

谢谢。

我是 spring webflux 中反应式编程的新手。我有以下情况。

在尝试为我编写测试用例时Mono<List<MyClass>>遇到错误。

我收到 JSON 反序列化错误

在 REST 控制器中，我需要调用 REST 来获取一个值，该值将用作第二个 REST 调用的 URI 变量。

问题是 WebFlux REST 在单声道/通量上不可能调用块。

代码抛出

java.lang.IllegalStateException block()/blockFirst()/blockLast() 是阻塞的，线程reactor-http中不支持

我试图改变

.build(result.block().getValue()))

和

.build(result.share().block().getValue()))

但现在问题是result.share().block()无限期挂起。

我需要从 3 个 api 调用构造一个 JSON。

1. 调用 webclient1.get() -> response1
2. 使用 reponse1 像这样调用第二个 api： webclient2.getDetails(response1.getId())
3. 使用 reponse1 像这样调用第三个 api： webclient3.getDetails(response1.getId())

示例代码

我在管道中得到 null 不确定错误在哪里

我正在尝试制作可供多个服务使用的 couchbase 通用类。在定义类型时，我遇到了错误“创建名称为'couchbaseRepository'的bean时出错：init方法的调用失败；嵌套异常是org.springframework.data.mapping.MappingException：找不到类型类java.lang的PersistentEntity。对象！\r\n\tat "

正在使用的服务类

公共类 GlpCoreRepository 扩展 CommonRepository<User, String > {

}

通用类

} }

Couchbase 存储库

}

我尝试实现一个 springboot 应用程序，它允许我：

• 在 S3 上上传 mp3
• 提取元数据并将它们存储在 mongo DB 上。

如果我想从 mp3 中提取元数据，我必须提供 MultipartFile。很遗憾，我们无法发送 Flux。

在我的控制器中，我确实传递了 3 个参数：

现在我有点卡在我的服务层了。我想建立我的响应，存储数据并将文件发布到 S3。用于存储元数据，mp3agic。

我首先尝试将 byteBuffer 转换为 MultipartFile：

然后我调用应该允许我持久化元数据的代码的一部分称为

我返回了错误消息：