问题标签 [webflux]

我有一个客户端，它使用 webClient 将批次发送到第三方 API 以翻译一些文本。它看起来像这样：

因此，随着每个批次的返回结果被添加到构建器将用于构建响应的映射中。现在，我有一个服务需要异步调用同一个客户端，因此我想我应该从我的客户端返回一个 Mono，以便服务可以解包结果（该服务将调用另一个需要并行发生的 API，但如果我的客户阻塞它并不完全是异步的）。有没有办法让我的客户返回 Mono 和服务来解包结果，而无需推送任何填充地图的代码并构建对服务的最终响应？

当使用 spring security web 时，我们可以使用 antMathcers

使用 webflux 时，我们使用

问题是，我们可以有蚂蚁图案的第一种方法 "/admin/**/test"

但是第二种方式，上面的方法会出错。

如何在 webflux 环境中实现上述 uri 模式？

我正在尝试了解反应式编程以及事件循环的工作原理。只要我能理解新的 HTTP 请求何时发送到应用程序，该请求就会拆分为事件。每个事件都由这个事件循环处理，并且为每个事件注册一个回调。此事件完成后，将结果返回给请求。但是有多少线程处理这个请求以及这个事件循环中有多少线程。

我最近将我的应用程序从 webmvc 切换到 webflux，并尝试配置它

并尝试添加@CrossOrigin到我的控制器。

但我仍然没有得到跨域响应标头。

有人知道修复吗？

我正在尝试迁移使用 spring 状态机的应用程序以使用 webflux。我正在使用

获取手头的状态机（由 stringId 标识）。但这不能再在反应器线程中完成，因为 getStateMachine 是阻塞的。那么如何在反应式环境中获得正确的状态机呢？

我有一个 Spring WebFlux 项目，事实证明我需要在查询参数中允许一个斜线用于几个 API 调用。在 Spring MVC 中，您将使用 HttpServletRequest 来处理该用例，如下例所示：

SpringBoot中的@PathVariable，URL中带有斜杠

您将如何使用 WebFlux 做到这一点？我在网上找不到任何关于这方面的好文章。

我有一个 webflux 应用程序，需要在我的身份验证日志中包含 sleuth 上下文（从 DefaultWebFilterChain 移动到 SecurityWebFilterChain）。

我试图在我的安全链中手动添加：

但我得到一个错误：

我还检查了这个属性：

但我认为只会影响 DefaultWebFilterChain 的顺序，不会影响 SecurityWebFilterChain。以及如何从 DefaultWebFilterChain 中删除过滤器以避免过滤两次？

有任何想法吗？谢谢！

我想编写第一个程序webFlux和ReactiveMongoRepository. 我有存储库：

我的服务：

其余的服务本身：

现在，当我想测试服务并通过邮递员保存或查找每个人时，我收到一个错误：

也就是按照我的理解，请求甚至没有到达函数，而是立即抛出错误，这里哪里有错误呢？

我正在使用 Webflux 创建一个带有 Netty 的 TCP 服务器。在从 ChannelInboundHandlerAdapter 扩展的处理程序中，我toFuture().get()用来阻止 MongoDB 数据库操作并获取数据，但是当我调用 时channelHandlerContext.writeAndFlux(data)，我得到java.io.IOException: Connection reset by peer .

TCP服务器的channelRead中处理数据库操作的正确方法是什么？

如果我打电话block()，没有数据返回。如果我打电话.toFuture().get()，我会得到例外。

TPC 服务器的创建方式如下：

我刚开始学习 webFlux。我刚开始学习 webplus，我对问题很感兴趣。将 completableFuture 与 CRUD 操作一起使用是否有意义？

也就是说，假设我有RestService：

为处理请求提供这样的服务是否有意义？

personServiceImpl：

或者只是没有 Future 的常规调用会更好？

如果您能帮助我了解 Future 在这里是否有意义，我会很高兴。