10得票2回答
在Spring Webflux中,抛出异常和使用Mono.error()有什么区别?

我正在开发一个Spring WebFlux项目,我想了解抛出异常与使用Mono.error()的区别。 如果有一个如下所示的验证类: public class NameValidator { public static boolean isValid(String name) {...

8得票3回答
如何使用R2dbc从Postgresql提取jsonb并在Spring webflux中使用

我的想法有点超过我的实际能力,因为我只是一个新手程序员。但我想构建一个响应式的Spring WebFlux应用程序,向React前端暴露JSON端点。 问题出现在我决定使用Postgres中的jsonb格式上,因为我认为我可能会一直使用JSON从数据库到前端层。 当我尝试使用反应式R2db...

7得票1回答
当控制器返回EmitterProcessor而不是Flux时,WebTestClient在单元测试中会阻塞

我正在处理一个使用Spring WebFlux框架的项目。我们有一个Controller,您可以订阅特定对象的更新。此Controller返回一个EmitterProcessor,客户端可以订阅它。当EmitterProcessor上发布了一些内容时,已订阅的客户端会收到通知。 实际应用中这...

9得票3回答
Spring 5在其反应式特性中支持Java 9 Flow API吗?

在Spring 5.0.0.RC4参考文档中,它说道: 支持任何实现Reactive Streams Publisher的类型,包括Publisher或Flow.Publisher。 https://docs.spring.io/spring/docs/5.0.0.RC4/spring...

9得票2回答
如何在WebFlux中使用ReactiveSecurityContextHolder获取当前用户?

通常在使用Spring Boot时,获取当前登录用户的常用方法是使用: SecurityContextHolder.getContext(); 在使用Java中的反应式编程和 Mono 时,此方法不起作用,因为它们不属于同一线程。建议使用: ReactiveSecurityContex...

7得票2回答
Spring,Webflux:当使用WebTestClient执行请求时,ServerHttpRequest对象的getRemoteAddress方法返回null。

我有一个控制器 @RestController public class NameController { @Autowired private NameService nameService; @GetMapping("/name") public Mo...

10得票1回答
反应式 Redis(Lettuce)总是发布到单个线程

我正在使用Spring Webflux(带有spring-reactor-netty)2.1.0.RC1和Lettuce 5.1.1.RELEASE。 当我使用Reactive Lettuce API调用任何Redis操作时,执行始终切换到相同的单个线程(lettuce-nioEventLo...

9得票1回答
我可以在Spring WebFlux上实现WebSecurityConfigurerAdapter吗?

我目前正在使用Spring的WebFlux,并想要实现Spring Security。我发现我的WebSecurityConfigurerAdapter http规则无法生效,我认为这是因为HttpSecurity更改没有效果。我来解释一下: 我选择实现WebSecurityConfigur...

14得票3回答
如何在反应式流中包含if-else语句

我有一个Spring Webflux响应式服务,它接收DTO并将其插入到多个表中。 有时我们需要根据传入的DTO跳过插入到某些表中。 这是要求: 创建新客户端 如果DTO中存在客户推荐,则创建新客户推荐。 如果DTO中存在客户次要联系人,则创建客户次要联系人 如果DTO中存在客户电话,则...

25得票5回答
如何使用Webflux提供静态内容?

我正在学习WebFlux,并且想知道如何在使用WebFlux的微服务中提供静态内容,但我找不到相关信息。