58得票1回答
Spring Web-Flux中的反压机制

我是一个Spring Web-Flux的初学者。我编写了一个控制器,如下所示: @RestController public class FirstController { @GetMapping("/first") public Mono<String> ge...

56得票1回答
Spring WebFlux和Reactor的线程模型

目前正在使用 Spring 5.0.0.RC2、Reactor 3.1.0.M2 和 Spring Boot 2.0.0.M2 进行响应式编程实验。 想知道 WebFlux 和 Reactor 使用的并发和线程模型,以便正确编写应用程序并处理可变状态。 Reactor文档说明该库被认为是并发无...

54得票6回答
Spring 5 WebClient使用SSL

我正在尝试查找WebClient使用的示例。 我的目标是使用Spring 5 WebClient使用https和自签名证书查询REST服务。 有任何示例吗?

53得票1回答
我可以同时使用SpringMvc和Webflux吗?

我希望在一个项目中同时使用2种方法(响应式和标准)。 我试图将一个REST API端点迁移到响应式WebFlux,并在迁移其余端点之前测试性能。 但是它没有起作用。我为其添加了路由器和处理程序,但直到我从依赖项中删除 spring-boot-starter-web 并禁用@RestContr...

52得票14回答
Spring Webflux: Webclient:获取错误响应体

我正在使用Spring WebFlux中的WebClient,代码如下:WebClient.create() .post() .uri(url) .syncBody(body) .accept(Me...

52得票3回答
Java Spring WebFlux与RxJava的比较

我开始学习Java响应式编程,整个响应式范式对我来说是新的。 在我的学习过程中,我遇到了一些术语/库,例如Spring WebFlux、projectreactor和RxJava。我希望有人能解释一下它们之间的区别,并告诉我你在项目中使用的是哪一个,为什么做出这种选择。 我看到Spring...

51得票6回答
如何正确读取Flux<DataBuffer>并将其转换为单个inputStream

我正在使用 WebClient 和自定义的BodyExtractor类来开发我的Spring Boot应用程序。 WebClient webLCient = WebClient.create(); webClient.get() .uri(url, params) .accept...

51得票2回答
在多线程环境中正确使用Spring WebClient的方法

关于Spring Framework WebClient,我有一个问题。 在我的应用程序中,我需要执行许多类似的API调用,有时候我需要在调用中更改头部(身份验证令牌)。所以问题是,以下两个选项哪个更好: 为所有传入到MyService.class的请求创建一个WebClient,将其设...

49得票6回答
block()/blockFirst()/blockLast()会阻塞调用exchange()之后的bodyToMono()方法时出现错误。

我正在尝试使用Webflux将生成的文件流式传输到另一个位置,但是如果文件生成遇到错误,则API会返回成功,但会附带一个DTO来详细说明生成文件时发生的错误,而不是文件本身。由于使用了非常旧且设计不良的API,请原谅使用post和api设计。 api调用(exchange())的响应是Cli...

45得票2回答
Spring 5 WebFlux中@Controller和RouterFunction的区别

现在在Spring 5中有两种暴露HTTP端点的方式。通过使控制器类成为@Controller或@RestController@Controller@RestController @RequestMapping("persons") public class PersonController ...