118得票14回答
数据缓冲区限制异常:超过了WebFlux错误缓冲最大字节数的限制。

在发送文件时,我会收到一个字节数组。但是使用webflux接收数组时总是出现问题。抛出的错误如下:org.springframework.core.io.buffer.DataBufferLimitException: Exceeded limit on max bytes to buffer...

97得票19回答
如何记录Spring 5 WebClient调用

我正在尝试使用Spring 5 WebClient记录请求。您知道我该如何实现吗? (我正在使用Spring 5和Spring Boot 2) 目前代码如下:try { return webClient.get().uri(url, urlParams).exchange().fl...

77得票2回答
Spring MVC(异步)与Spring WebFlux的区别

我正在尝试了解Spring WebFlux。到目前为止,我发现它具有以下特点:核心是反应式的;没有Servlet API;没有每个请求一个线程;支持HTTP 2、服务器推送和application/stream+json。 但是Spring MVC中的异步调用与之有何区别?我的意思是,在Sp...

71得票9回答
如何自定义SpringWebFlux WebClient的JSON反序列化?

我将使用 spring-webflux WebClient(生成版本为20170502.221452-172)来访问一个Web应用程序,该应用程序生成以如下格式的Entry对象流(application/stream+json): final WebClient producerClient...

64得票4回答
Mono.defer()是什么意思?

我在一些Spring webflux代码中遇到了Mono.defer()。 我在文档中查找了这个方法,但不理解其中的解释: "创建一个Mono提供程序,该程序将为每个下游订阅者提供目标Mono" 请给我一个解释和一个例子。有没有一个包含Reactor示例代码(单元测试)的地方可以供我参考...

64得票2回答
Mono switchIfEmpty() 总是被调用

我有两种方法。 主要方法:@PostMapping("/login") public Mono<ResponseEntity<ApiResponseLogin>> loginUser(@RequestBody final LoginUser logi...

63得票2回答
使用Spring HATEOAS与Spring WebFlux函数式Web框架(reactor-netty)

我们能否在 RouterFunction 上使用 Spring 的 HATEOAS?我想我们可以指定资源,但相应的 linkto(Controller.class) 相当于什么呢?还是说是否有相当于指定链接并使用 RouterFunction 组合的等价方法?

60得票3回答
map vs flatMap in reactor

我已经找到了很多关于RxJava的答案,但我想了解它在Reactor中是如何工作的。 我的当前理解非常模糊,我倾向于认为map是同步的,而flatMap是异步的,但我真的无法理解它。 这里有一个例子: files.flatMap { it -> Mono.just(Path...

60得票17回答
Spring Boot 2.0禁用默认安全性

我希望使用Spring Security来进行JWT身份验证。但是它自带了默认的身份验证方式。我尝试禁用它,但是旧的做法 - 通过application.properties禁用 - 在2.0中已被废弃。 这是我尝试过的方法: @Configuration public class Sta...

59得票12回答
如何在Spring WebFlux中记录请求和响应体

我希望在使用Kotlin的Spring WebFlux REST API中拥有请求和响应的集中式日志记录。到目前为止,我尝试了以下方法:@Bean fun apiRouter() = router { (accept(MediaType.APPLICATION_JSON) and "/...