检测通量数据的结尾错误
当前使用Angular 5和Spring 5 webflux查看SSE.基本应用程序正常运行，但是在研究错误处理时，我们注意到在角度应用程序中，EventSource在弹簧关闭连接(由于到达Flux数据流的末尾)与发生错误(例如，在传输过程中终止应用程序). 我们基于调查的示例如下. https://thepracticaldeveloper. com/2017/11/04/full-
..
spring-webflux相关内容
Spring 5 Reactive中的HTTP响应异常处理
我正在使用带有WebFlux响应式启动程序的Spring Boot 2和Spring 5开发一些响应式微服务。 我面临以下问题：我想处理所有问题我从调用另一个REST服务收到的HTTP状态，并在收到一些错误的HTTP状态时引发异常。例如，当我调用一个端点并收到404 HTTP状态时，我想抛出一个异常，并在某些ExceptionHandler类中处理该异常，就像在Spring 4中使用 @的方
..
WebExceptionHandler：如何用Spring Webflux编写正文
我想通过添加WebExceptionHandler来处理api的异常。 我可以更改状态代码，但是当我想更改响应的正文时会卡住：例如添加异常消息或自定义对象。 有人有人吗？ 我如何添加我的WebExceptionHandler： HttpHandler httpHandler = WebHttpHandlerBuilder.webHandler（toHttpHandler（ro
..
如何在Postman中查看Spring 5 Reactive API的响应？
我的应用程序中有下一个端点： @GetMapping（value =“ / users”） public Mono users（）{ Flux flux = Flux.just（new User（“ id”））; 返回ServerResponse.ok（） .contentType（APPLICATION_JSON） .body（flu
..
Webflux PostgreSQL
我应该如何在Webflux中实现postgresql？ 我想使用 ReactiveCrudRepository 来实现它，但是JPA不起作用...我想要存储用户以及SSH公钥和私钥。我已经读过MongoDB事务不如postgresql可靠（如果我错了，请纠正我）。那就是为什么我要使用postgresql。 但是在webflux中使用Postgresql的最佳方法是什么？我想使用JPA存
..
如何重试Spring WebClient根据响应重试操作?
我一直在学习spring webflux，并被困在其中. 我已经使用WebClient从Spring应用程序请求了REST API.我想根据响应重试该请求.可以说，如果响应的属性为status: 'not-ready'，那么我需要一秒钟后重试相同的操作. 我尝试了以下方法，但不确定如何实现 public Flux makeHttpRequest(int page) {
..
Spring Boot v2.0.0.M2 Webflux和执行器
我无法使Actuator与Spring Boot v2.0.0.M2和Netty一起使用. build.gradle中使用了以下依赖项: compile "org.springframework.boot:spring-boot-starter-actuator" compile "org.springframework.boot:spring-boot-starter-da
..
如何通过Jetty而不是Netty使用Spring WebClient?
根据文档，可以将Spring Reactive WebClient与其他服务器(如Netty)一起使用: WebClient通过HTTP客户端库提供了更高级别的API.经过 默认情况下，它使用Reactor Netty，但是可以用其他插件插入 ClientHttpConnector. 但是，我无法找到一种方法来做到这一点.如果我像这样简单地将依赖从Netty更改为Jetty: c
..
Spring Boot WebFlux Reactive MongoDB:如何在每个请求上切换数据库?
我正在使用Spring WebFlux和Reactive MongoDB进行SaaS项目. 它必须是一个MultiTenant应用程序，每个租户都必须使用自己的数据库. 目前，我只是将Reactive MongoDB依赖项添加到pom.xml: org.springframework.boot
..
Webflux multipart/form-data，启用csrf，带有和不带有文件上传功能，都将获得无效的CSRF令牌
在禁用csrf的情况下，我可以上传文件，但是我需要将其启用. 仅当表单enctype为multipart/form-data，即带有403的“无效CSRF令牌"时，才会出现此问题. 通常，即使对于没有文件上传的表单，我都将enctype设置为multipart/form-data时，也会遇到相同的错误. 使用此依赖项: org.sy
..
如何启用Spring Reactive Web MVC来处理多部分文件?
我正在尝试在Spring Boot 2.0应用程序中使用新的反应式Web-mvc实现.我正在尝试定义一个消耗多部分文件的方法，但未能成功使它起作用:(-我总是会收到415错误. 一方面，我有一个包含以下请求映射的控制器: @RequestMapping(method = RequestMethod.POST, path = "/myPath/{param}/{param2}", con
..
Spring Webflux API的自定义身份验证
我正在为Angular 5应用程序创建API.我想使用JWT进行身份验证. 我想使用Spring Security提供的功能，以便我可以轻松地使用角色. 我设法禁用基本身份验证.但是当使用http.authorizeExchange().anyExchange().authenticated();时，仍然会出现登录提示. 我只想输入403而不是提示.因此，用"thing"(是否是过滤器?
..
如何创建数据类实现特定于Spring Secuirty的UserDetails
我正在尝试将一些spring-webflux示例代码迁移到Kotlin. 目前，我想转换 Spring Data Mongo 样本到Kotlin.有一个User，原始的Data Mongo版本看起来是: @Data @ToString @Builder @NoArgsConstructor @AllArgsConstructor @Document class User impleme
..
无法在Kotlin中将'subscribe'或'subscribeWith'与'ReactorNettyWebSocketClient'一起使用
下面的Kotlin代码成功连接到Spring WebFlux服务器，发送一条消息并打印通过返回的流发送的每条消息. fun main(args: Array) { val uri = URI("ws://localhost:8080/myservice") val client = ReactorNettyWebSocketClient() val
..
Spring WebFlux Webclient接收应用程序/八位字节流文件作为Mono
我正在Kotlin中制作一个小型Spring WebFlux应用程序的原型.该应用程序需要从远程REST端点获取tar存档，并将其本地存储在磁盘上.听起来很简单. 我首先创建了一个集成测试，该启动测试将使用提供tar存档的模拟REST终结点启动spring服务器和其他WebFlux服务器. 测试应该如下: 1)应用:获取mock-server/archive 2)模拟服务器
..
如何转换Reactor Flux< String>到InputStream
鉴于我的Flux大小未知，如何将其转换为其他库期望的InputStream? 例如，使用WebClient，我可以使用这种方法来实现 WebClient.get('example.com').exchange.flatMap { it.bodyToMono(InputStreamResource::class.java) }.map { it.inputStream }
..
Spring Webflux bean验证不起作用
我正在尝试在Webflux中使用bean验证.这是我到目前为止的内容: @PostMapping("contact") fun create(@RequestBody @Valid contact: Mono) : Mono { return contact.flatMap { contactRepository.save(it) }
..
WebFlux功能:如何检测空的Flux并返回404?
我具有以下简化的处理程序功能(Spring WebFlux和使用Kotlin的功能性API).但是，我需要一个提示，当通量为空时，如何检测空的通量，然后对404使用noContent(). fun findByLastname(request: ServerRequest): Mono { val lastnameOpt = request.query
..
使用Spring数据MongoDB和Kotlin更新对象不起作用
我有以下请求处理程序 fun x(req: ServerRequest) = req.toMono() .flatMap { ... val oldest = myRepository.findOldest(...) // this is the object I want to modify ... val v= an
..
如何在Spring WebFlux中记录请求和响应正文
我想在带有Kotlin的Spring WebFlux上的REST API中集中记录请求和响应.到目前为止，我已经尝试过这种方法 @Bean fun apiRouter() = router { (accept(MediaType.APPLICATION_JSON) and "/api").nest { "/user".nest { GET("/
..