问题标签 [spring-reactive]

我向现有应用程序添加了一个异步端点spring-mvc：

我想创建一个将记录请求正文有效负载的全局拦截器/过滤器。但是我怎样才能访问它呢？

我尝试添加 a HandlerInterceptorAdapter，但有效负载始终为空：

可能负载尚未出现在请求中，或者已被读取。那么在这种异步情况下如何访问正文？

我想知道为什么 Spring reactor 中 Flux.generate 中的状态供应商类型是可调用的而不是供应商？是因为防止阻塞吗？

如何在 Spring Cloud Stream 中实现反应式消息处理？我阅读了有关 Spring Cloud Function 的信息，并且我应该将它们用于响应式处理，因此我创建了示例一：

后来我开始思考上面的函数和带有@StreamListener的类和Reactor类型的使用有什么区别：

此外，在 Spring Webflux 中，我了解 netty 处理请求处理的线程很少（在事件循环中运行）。但是，我找不到 Spring Cloud Stream 中线程模型如何工作的文档。

尝试实现反应式弹簧安全性。

Pom 依赖项，

网络安全配置，

不知道为什么会出现 typenotpresentexception 错误，

我们正在使用带有 RabbitMQ 的 Spring Cloud Reactive Streams。

Spring Reactive Stream 似乎在将消息从队列中拉出后立即确认消息。因此，在消息处理期间发生的任何错误未处理异常都需要在应用程序中处理（这与可以抛出未处理异常并且消息将被拒绝的非反应性流不同，从而将其发送到死信队列）。

当消息在传输中时，我们应该如何处理应用程序中的突然关闭？

例如：

• 应用程序从队列中拉出消息
• 应用程序将消息标记为已确认
• 应用程序开始消息处理
• 应用程序在消息处理完成之前关闭

发生这种情况时，消息似乎完全丢失了，因为它不在队列中，但应用程序已停止。我们如何才能恢复这些消息？

我正在从 RSocket-Java 连接到 Spring Boot RSocket 应用程序。在服务器中我有@MessageMapping。如何访问服务器上的 RSocket Payload。

我正在尝试响应式安全性，未经身份验证的呼叫不会发送到身份验证管理器。

Web身份验证管理器，

在这里，我已经在 Securityconfig 中注册了我的 WebAuthentication 管理器。但是，未经身份验证的调用仍然不会转到 WebAuthenticationManager。

当受保护的 URL 被命中时，它应该会转到 AuthenticationManager。例如，

http://localhost:8080/api/v1/user。

不确定，为什么电话不会转到 AuthManager。

在非反应式中，我们有 OncePerRequestFilter 并且正在那里处理身份验证。不确定，如何为反应式实现相同的。

我正在尝试保存一组类别。保存所有类别后，将产品类别设置为它。然后返回产品。到目前为止，我已经成功地做到了这一点。

我如何在不依赖于保存后退回产品block()？我似乎找不到学习这些东西的来源。谁能指点我的好材料。

我是 Spring Reactive 编程的新手，我正在开发一个返回 Flux 的 REST 端点。例如：

示例代码中的每个数据源（dataSource 和 dataSource2）都实现了一个如下所示的接口：

此代码工作正常，因为它按预期返回 Flux，但正如您所见，该代码仅引用 MyRequest 列表中的第一个元素。我需要做的是为 MyRequest 列表中的每个元素构造 Flux.merge。谁能指出我正确的方向？

我在将对象发布到多个方法时遇到问题。下面给出了我的代码的简化版本。

我希望每个方法只调用一次。但是getC被调用了两次。这里有什么问题？程序输出如下

org.example.reactive.MonoTest - 在 getA 中

org.example.reactive.MonoTest - 在 getC 中

org.example.reactive.MonoTest - 在 getC 中

org.example.reactive.MonoTest - 在 getB 中

org.example.reactive.MonoTest - 在 getD 中

org.example.reactive.MonoTest - 在 getE 内

org.example.reactive.MonoTest - onCompleted 内部

编辑

好吧，我可以通过缓存来解决它，如下所示。