spring-webflux相关内容

Spring WebFlux文件上传:不支持的媒体类型415,支持分块上传

我在使用Spring的反应性框架处理文件上传时遇到了一些问题。我认为我正在遵循文档,但无法摆脱此415/Unsupported Media Type问题。 我的控制器如下所示(如下面的示例:https://docs.spring.io/spring/docs/current/spring-framework-reference/web-reactive.html#webflux-multip ..
发布时间:2022-08-22 14:17:19 Java开发

反应式REST API分页

面临向反应式REST API添加分页的问题。我认为有一种方法可以将Pageable/PageRequest字段添加到我的请求查询对象中,但它的工作方式与您将页面/大小定义为查询参数的方式不同。 只有一种可行的方法--将页面和大小显式定义为请求查询对象的单独字段,然后使用PageRequest.of()将其转换为PageRequest.of()对象。 问题:在使用Pageable对象作为 ..
发布时间:2022-08-10 16:35:19 其他开发

Resilience4j重试-记录来自客户端的重试尝试?

是否可以使用弹性4j记录客户端的重试尝试? 可能通过某种配置或设置。 目前,我正在使用基于Spring Boot Webflow批注的Resilience4j。 它工作得很好,这个项目很棒。 我们将服务器日志放在服务器端,以查看由于重试而进行了相同的http调用(我们记录时间、客户端IP、请求ID等)我可以拥有客户端日志吗? 我期望看到类似";Resilien ..
发布时间:2022-08-10 16:30:21 Java开发

Javax.validation.ValidationException:HV000183:使用WebTestClient时无法初始化javax.el.ExpressionFactory

我正在尝试编写一个与WebTestClient的集成测试,该测试将仅支持我正在使用WebTestClient测试的控制器发出请求。在开始测试时,我在控制台中得到以下信息: 14:33:50.435 [main] INFO org.hibernate.validator.internal.util.Version - HV000001: Hibernate Validator 6.0.9.Fi ..
发布时间:2022-07-12 09:47:52 其他开发

如何使用WebFlux和Netty HttpClient访问请求体

我需要使用Webflow的WebClient计算请求正文的某种摘要,并且必须将该摘要设置为一个HTTP标头。使用老的Spring MVCClientHttpRequestInterceptor很容易,因为请求主体是以字节数组的形式提供的。 ExchangeFilterFunction不提供对请求正文的访问。 主体作为json发送,而Spring使用Jackson来序列化Java对象,因 ..
发布时间:2022-07-12 09:20:12 其他开发

Schedulers.boundedElastic似乎使用相同的线程进行处理

根据我对API的理解,使用Schedulers.boundedElastic()或像Schedulers.newBoundedElastic(3,10,&Quot;MyThreadGroup&Quot;);或Schedulers.from Executor(Executor)这样的变体允许在多个线程中处理一个IO操作。 但是,使用以下示例代码的模拟似乎表明,有一个线程/相同的线程在平面映射中 ..
发布时间:2022-04-06 15:55:50 其他开发

使用MockServerRequest断言WebFlux ServerResponse

我想将路由器层和处理器层分开,所以我不想使用this question中建议的WebTestClient。我认为把WebTestClient扔在这个问题上不是正确的解决方案。 在我的例子中,我使用MockServerRequest,它只允许测试http状态代码和标头。无法断言响应的正文。 val request = MockServerRequest.builder() ..
发布时间:2022-04-06 15:51:48 其他开发

如何使用Spring Security Webflow定制OAuth2登录重定向终结点基本URI

Servlet堆栈(Web)中的Spring安全性允许您将OAuth2授权码授予流中的OAuth2登录重定向终结点基本URI定制为given here。我正在尝试用Spring WebFlux为反应式堆栈做同样的事情。The github issue here提到了Oauth2LoginSpec上的AuthizationRequestResolver和authationMatcher,它可以用来自 ..

Webflow:从流中对象添加订阅者上下文值

我有一个Webflow应用程序,我使用订阅者上下文来填充MDC值,以便它们可以向下传播。我已经实现了this project中的类来处理订阅者之间的MDC传输,设置了一个WebFilter来将请求ID添加到传入请求中,并且可以在日志中看到作为MDC的一部分的请求ID。 public Mono filter(ServerWebExchange exchange, WebFilter ..
发布时间:2022-04-06 15:45:28 其他开发

如何防止Mono被取消?

我正在尝试将某些内容实现为争用条件。此争用条件必须遵循以下情况: 同时启动两个HTTP调用。 返回成功完成的第一个调用的响应。 处理最后一个调用。(这里最重要的是,我不能丢弃最后一个呼叫,我确实需要处理它的结果:无论它的状态、成功或失败)。 此代码示例是我所实现的最接近的解决方案: Mono monoA = webClient.get() ..

Spring反应返回scanAvailable和Prefetch而不是Object

我有一个用Spring active开发的rest API,如下所示,当它返回响应时,它确实有scanAvailable和预取,而不是对象详细信息。对于findAllEmployee,getAllWorkerAddressDetailsByWorkerId下面使用的方法,我们有单独的API,它确实返回了正确的响应。当我将它们组合在一起时,我不确定哪里出了问题。 WorkerDTO.java ..
发布时间:2022-04-06 15:37:34 Java开发