-
2 votesanswersviews
如何在路由器功能中允许CORS?
我正在使用Spring 5路由器功能构建一个Web应用程序休息控制器来映射请求 . @RestController public class AdminRest { public RouterFunction<ServerResponse> route() { return RouterFunctions .route(RequestPredicate... -
0 votesanswersviews
在Spring Boot反应式Web应用程序上启用SSL,并在控制台中对该打印进行http调用时出现异常噪音
在我创建了我的spring boot反应式Web应用程序以支持SSL之后,当我尝试对服务器进行http调用时,它会在控制台中的异常跟踪下面打印 . 作为应用程序所有者,我无法阻止任何人使用我的服务 . 但我应该能够防止在控制台中进行跟踪打印,尤其是在反应性Web应用程序中,IO操作成本很高 . 有什么想法防止这种情况? Edit 3 : 2018-10-01 14:11:18.440 ERROR ... -
1 votesanswersviews
Spring WebFlux反应式WebSocket阻止连接关闭
我正在为我的应用程序使用简单的聊天模块,使用Spring WebFlux和后端的ReactiveMongoRepository以及前面的Angular 4 . 我能够通过WebSocketSession接收数据,但在从db传输所有消息后,我想保持连接,以便我可以更新消息列表 . 任何人都可以告诉我如何实现这一点,或者我可能遵循错误的假设? Java Backend负责WebSocket,我的订阅者... -
2 votesanswersviews
Spring webflux控制器:消费POJO vs Mono?
在控制器中我可以写: fun update(@RequestBody myPojo: MyPojo): Mono<Void> 要么 fun update(@RequestBody myPojo: Mono<MyPojo>): Mono<Void> 有什么区别吗?身体解析会在不同的线程中完成吗?在第一种情况下,我将阻止主反应堆线程,直到 myPojo 被解析?... -
0 votesanswersviews
Spring Webflux路由器功能未被使用
我有以下配置 @Configuration @EnableWebFlux public class WebfluxConfig { @Bean RouterFunction<?> routerFunction(UserResource userResource) { return route(GET("/user"), r ->... -
0 votesanswersviews
使用“spring-boot-starter-parent”时如何在Maven中使用较低的Elastic搜索版本
我正在使用“spring-boot-starter-parent”和Webflux版本“2.0.0.BUILD-SNAPSHOT” . 我使用Elasticsearch作为数据源 . 所以我在pom.xml中包含了“spring-boot-starter-data-elasticsearch” . 默认情况下,这包括ES版本5.4.0 . 但我的Elasticsearch版本是2.3.1 . 我现... -
0 votesanswersviews
生成Spring REST Docs片段
我想为以下情况生成Spring REST Docs代码段: FluxExchangeResult<TestObject> result = this.webTestClient .get() .uri("/test") .accept(MediaType.TEXT_EVE... -
1 votesanswersviews
使用WebFlux WebTestClient和Kotlin键入干扰问题
我正在使用Spring Webflux和Kotlin为新应用程序构建原型 . Spring Webflux包含用于单元测试的WebTestClient . 根据文档,我应该能够像这样测试REST调用的结果: @Test fun getVersion_SingleResult_ContentTypeJson_StatusCodeOk_ContentEqualsVersion() { //g... -
1 votesanswersviews
如何在Spring webflux应用程序中使用Spring WebSessionIdResolver和Spring Security 5?
目前我遇到了新的Spring反应堆栈,并希望在Spring Session 2.0中使用反应功能 . 在传统的Servlet方法中,Spring Session提供 HttpSessionStrategy 来检测cookie或请求头中的会话 . 对于RESTful API,很容易使用 HeaderHttpSessionStrategy 来实现身份验证(默认情况下,名称为 X-AUTH-TOKEN ... -
4 votesanswersviews
将几个REST调用与Spring Webflux相结合
我试图用Spring Webflux做一些事情,但我真的对一些反应性概念感到困惑 . 我有一些使用表单身份验证保护的REST服务,在我可以调用我的业务REST服务之前,我必须调用通过Spring Security提供的“登录”URL,传递我的凭据并将返回的Cookie放到对其他REST服务的进一步调用中 . 下面是REST业务服务调用的片段.... @RequestMapping(value = ... -
11 votesanswersviews
带有MultipartFile的Spring Webflux 415
我目前正在尝试将文件从Angular 4前端上传到Spring Webflux控制器 . 控制器能够读取@RequestPart值但抛出415 UnsupportedMediaTypeStatusException . UploadController @PostMapping( consumes = MediaType.MULTIPART_FORM_DATA_VALUE ) public Mon... -
3 votesanswersviews
通过spring`WebClient`进行api调用的正确方法是什么,但忽略了结果?
通过spring WebClient 进行api调用的正确方法是什么,但忽略结果? ClientResponse 对象特别指出我必须对结果做些什么...... Docs: 注意:当通过WebClient exchange()方法授予对ClientResponse的访问权限时,必须始终使用body或toEntity方法之一来确保释放资源并避免HTTP连接池的潜在问题 . 如果没有预期的响应内容... -
0 votesanswersviews
Webclient响应处理程序(成功和错误)不会为空响应主体执行
使用OkHttp实现异步REST API客户端,工作得很好 . 试图出于好奇心将其转换为WebClient,观察奇怪的行为 . WebClient配置就是这样的: webClient = WebClient.builder() .defaultHeaders(headers -> headers.add(HttpHeaders.CONTENT_TYPE, org.sp... -
0 votesanswersviews
使用图像内容类型Sample请求Reactive Server响应
我正在开始一个新项目并采用spring webflux作为反应式休息框架 . 我有一个用例在后端返回验证码图像 . 我有一个示例代码,如下所示生成验证码图像并返回spring框架,但现在我不知道如何以反应方式返回图像 . 这是我在Spring MVC方式中的用例: @RequestMapping(value="/captcha/{id:.+}", produces = Medi... -
2 votesanswersviews
Spring WebFlux WebClient超时()和交换()
我有类似于以下示例的代码: Mono<ResponseEntity<String>> result = webClient .post() .body(Mono.just(command), MyCommand.class) .exchange() .timeout(calculateTimeout(command)) .flatMa... -
1 votesanswersviews
Spring-webflux,如何在@ExceptionHandler中获取请求作为参数
使用spring webflux和 @RestController 模型,我有 @RestControllerAdvice 和一些 @ExceptionHandler 方法 . 我想将原始请求作为参数获取,因为我想记录它并在我的响应中使用它 . 但是,我已经尝试了经典MVC模型中处理程序方法的所有可能类型,但没有一个被接受( HttpServletRequest , WebRequest 和 Se... -
3 votesanswersviews
Springboot v2.0.0.M6 WebClient进行多次重复的HTTP POST调用
我使用的是spring-boot版本2.0.0.M6 . 我需要从spring-boot应用程序发出异步HTTP调用说APP1到另一个应用程序(播放框架)说APP2 . 因此,如果我需要从APP1到APP2进行20次不同的异步调用,APP2会收到20个请求,其中很少是重复请求,这意味着这些重复请求替换了几个不同的请求 . 预期: api/v1/call/1 api/v1/call/2 api/v1... -
3 votesanswersviews
JDBC与Webflux - 如何分派到容器线程
我正在使用webflux进行一个小概念验证 . 在我的应用程序的一部分中,我想与数据库(通过JDBC)进行通信,该数据库阻塞并且不适合反应堆 . 然而,对于这个概念验证,我正在考虑以下技巧: 将专用线程池(让我们称之为 DBThreadPool )定义为 ExecutorService ,其中固定数量的线程等于JDBC连接池大小 . 在Reactor Scheduler中包装该池(名为 dbS... -
5 votesanswersviews
Reactor Mono vs CompletableFuture
刚开始探索反应堆项目及其抽象Mono和Flux,并希望了解与java 8准系统CompletableFuture的基本差异 . 这是一个简单的代码: public static void main(String[] args) throws Exception { Mono.fromCallable(() -> getData()) .map(s ->... -
5 votesanswersviews
Spring Boot Webflux / Netty - 检测关闭连接
我一直在使用webflux启动器( spring-boot-starter-webflux )使用spring-boot 2.0.0.RC1 . 我创建了一个简单的控制器,返回无限的通量 . 我希望发布者只有在有客户端(订阅者)时才能正常工作 . 假设我有一个像这样的控制器: @RestController public class Demo { @GetMapping(value ... -
2 votesanswersviews
Spring Reactive Web Applications POST请求正文丢失
我正在研究小型测试项目,以检查Spring Reactive Web Applications如何与MongoDB实际配合使用 . 我按照https://docs.spring.io/spring/docs/5.0.0.M4/spring-framework-reference/html/web-reactive.html的说明书进行操作 它表明我可以在控制器中处理POST请求,如: @PostM... -
1 votesanswersviews
WebFlux web和webflux启动器
我使用 webflux starter 创建了一个 Spring boot 2.0.0.M7 项目,因为我想使用所有异步和非阻塞功能 . 我添加了 server.servlet.context-path 但是如果我不添加Web启动器它也不起作用 . 如果我添加两个启动器,我可以解决非阻塞功能吗?我用Gatling执行了一些压力测试,我收到了相同的分数,删除了web启动器或添加它 . 对此有何帮助?... -
0 votesanswersviews
Spring WebFlux和Kotlin支持:如何进行集成测试?
https://docs.spring.io/spring-framework/docs/5.0.0.BUILD-SNAPSHOT/spring-framework-reference/kotlin.html#easy-testing-kotlin-and-junit-5显示了集成测试的代码示例 . 但是我不明白这一行: val application = Application(8181) 8... -
4 votesanswersviews
SpringBoot2 Webflux - WebTestClient返回“内容尚未可用”
我正在尝试编写一些测试并面对以下异常,当我尝试 post 一个字节数组体: 错误 java.lang.AssertionError: Status expected:<201> but was:<404> > POST /api/foo > WebTestClient-Request-Id: [1] > Content-Length: [246444] ... -
4 votesanswersviews
没有ReactiveCrudRepository的WebFlux和Kotlin corountines
我正在开发一个使用Kotlin,Spring Boot,Hibernate(所有最新版本)的项目,我想让它与Spring的WebFlux框架反应 . 问题是我不能使用 ReactiveCrudRepository 因为Web应用程序必须使用Oracle数据库,因此必须使用Hibernate . 所以我无法想出如何使用非阻塞访问Oracle SQL数据库(只有免费框架)的方法 . 我的问题是: 有可... -
0 votesanswersviews
哪个CoroutineScope用于Spring Boot WebFlux endpoints
在Spring Boot WebFlux应用程序中,我们有许多 endpoints (REST和GraphQL),它们返回 Mono 或 Flux 的某些内容 . 这些 endpoints 调用的代码都是非阻塞的,但是我们不想使用reactor,而是想使用Kotlin协程编写所有这些非阻塞代码 . 我们可以使用 kotlinx.coroutines.reactor.mono() 这样的方法将我们的... -
-1 votesanswersviews
在WebFlux中创建名为requestMappingHandlerMapping的bean时出错(没有Spring Boot)
我正在尝试将一个简单的项目从Spring MVC 5迁移到Spring WebFlux . 我尝试这样做而不会显着改变项目的结构 . 我想通过WebApplicationInitializer接口初始化,就像在Spring MVC中一样 . public class AppInitializer implements WebApplicationInitializer { @Overri... -
1 votesanswersviews
是否存在针对嵌入式数据存储的Spring Boot Data Reactive Starter?
通过开发小型演示应用程序,我正在学习使用Spring Boot的Spring WebFlux的绳索 . 如果我错了,请纠正我,但唯一的反应是Spring Boot Data Starters如下: 卡珊德拉 Couchbase MongoDB Redis 是否可以选择使用嵌入式NoSQL存储进行开发,就像通常使用H2进行JPA一样? -
4 votesanswersviews
如何在Spring Webflux / Reactor Netty Web应用程序中执行阻塞调用
在我的用例中,我有一个带有Reactor Netty的Spring Webflux微服务,我有以下依赖项: org.springframework.boot.spring-boot-starter-webflux (2.0.1.RELEASE) org.springframework.boot.spring-boot-starter-data-mongodb-reactive (2.0.1... -
1 votesanswersviews
spring-integration:如何从WebFlux集成流创建Spring Reactor Flux?
在How to create a Spring Reactor Flux from Http integration flow? artem-bilan mentioned in a comment中,将来可以使用webflux集成 . 从撰写评论的时间开始,WebFlux集成已经factored out to spring-integration-webflux . 我已尝试以下方法通过使用 W...