问题标签 [webflux]

通过控制器下载文件后，服​​务出现错误。文件里有122行，但是只读到108，有没有人遇到过这样的问题？

调试变量

109线

文件解析器代码

我已经为用 spring-boot 编写的微服务添加了 swagger 支持。 我得到以下错误

这是我项目的 gradle 文件！

我正在尝试从 restTemplate 迁移到 webClient。

一切都很好，直到我使用ClientHttpRequestFactory.

我在这里粘贴旧代码和新代码。

------带有restTemplate的旧代码-----

------带有webClient的新代码-----

当我运行项目时，我得到了这个异常：

Caused by: java.lang.ClassCastException: class org.apache.hc.client5.http.impl.io.PoolingHttpClientConnectionManager cannot be cast to class org.apache.hc.client5.http.nio.AsyncClientConnectionManager (org.apache.hc.client5.http.impl.io.PoolingHttpClientConnectionManager and org.apache.hc.client5.http.nio.AsyncClientConnectionManager are in unnamed module of loader 'app')

我正在使用 WebFlux，我想使用 AOP 登录，如下所示：

在上面的代码中，我想记录用户名，但是没有记录。如何订阅Mono或Flux不返回该方法？

注意：有时我想对订阅数据做不同的事情，例如将数据保存在数据库中。

我希望通过授权过程应该允许少数提到的端点，并且对于其余端点应该进行 x509 检查。

如何实现一种机制，首先如果端点在安全匹配器中匹配它应该通过，如果不是那么它通过其他授权机制？

基本上是授权条件的 OR 机制

我有以下代码，并且一直收到 404 not found 错误？任何建议将不胜感激！

我研究了似乎不是问题的相互冲突的依赖关系。我还确保我返回了正确的内容类型。

我不确定我做对的一件事是使用 Bean 和 Autowired 注释进行注释。我现在对那些人的所作所为知之甚少。

下面的路由器类

下面的控制器/处理程序类

测试班

build.gradle 依赖项

提前致谢！！！

我正在使用filterWhen()具有以下多个条件的 Mono，但不知道如何实现正确的方法。

当使用conditionA && conditionB 时，当conditionA（或conditionB）返回false 时是否立即返回？

同样当使用条件A || 条件B，当条件A（或条件B）返回true时是否立即返回？

这是我的代码中的以下流程：用户调用创建代理端点，包含代理名称和布尔字段->

路由器函数接收调用，传递给处理程序->

处理程序将请求正文转换为单声道，将该单声道传递给服务->

Service 将代理保存到 DB，在此过程中生成一个 ID，然后创建一个 Response 对象，其中包含包装在 Mono 中的 ID，将 Response 返回给 Handler。

这是我卡住的部分。保持反应式方法，我必须将代理保存到 Db 并在 Mono 的“doOnNext() 部分中创建 ID。但是，我无法返回从 DB 获取的 ID 以创建响应对象。

实现此目的的反应方式是什么？提前致谢！

以上是我的 spring 安全配置和 cors 配置。当超级管理员访问 /api/client/search 他得到成功响应。但是，当管理员尝试访问时，他会收到 Cors 错误，而不是访问被拒绝。

我在这里想念什么？

下面是异常堆栈跟踪，根据异常我的异常处理程序正在创建响应但浏览器显示 cors 错误而不是访问被拒绝，这非常奇怪。

同样的事情对于超级管理员来说工作正常

WireMock.stubFor(WireMock.any(WireMock.anyUrl()).willReturn(WireMock.aResponse().withHeader (HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_UTF8_VALUE) .withStatus(HttpStatus.OK_200) .withBody(getObjectFromJson("Slots.json" ））））；