Spring WebFlux webclient NonBlocking 호출 질문

Question

안녕하세요.Spring WebFlux webclient를 이용하여 NonBlocking 공부 중 이해가 안되는 부분이 있어 질문 올려봅니다.먼저 아래와 같이 NonBlocking형식으로 API를 호출하였습니다.@PostMapping("/nonBlocking/webcline02") public Mono> NonBlockingWebClient02() { log.trace("Call nonBlocking webcline02."); WebClient webClient = WebClient.create("http://localhost:8080"); final StopWatch stopWatch = new StopWatch(); stopWatch.start(); Mono responseEntityMono = null; for(int i = 0; i < 3; i++) { responseData.setErrorMsg("http://localhost:18080/nonBlocking - Call nonBlocking webcline02(" + i + ")"); webClient.post() .uri("/apiTest") .bodyValue(responseData) .retrieve() .bodyToMono(ResponseData.class) .subscribe(response -> log.info("body : {}", response)); } stopWatch.stop(); log.info("Total Second : {}", stopWatch.getTotalTimeSeconds()); return Mono.fromSupplier(() -> ResponseEntity.status(HttpStatus.OK).body(responseData)); } for loop를 이용하여 3번 호출하도록 의도했습니다.특정 상황에 따라 값이 변하면서 n번의 외부 호출을 수행하는 경우를 가정하였습니다. 이를 받는 응답 Server에서는 아래와 같이 요청받은 값을 출력해주었습니다.@PostMapping("/apiTest") public ResponseEntity apiTest(@RequestBody HashMap paramMap) throws InterruptedException { log.trace("Call Post apiTest."); String errorMsg = paramMap.get("errorMsg").toString(); log.info("errorMsg : {}", errorMsg); responseData.setErrorMsg("http://localhost:8080/apiTest - Post Call apiTest."); Thread.sleep(2000); return ResponseEntity.status(HttpStatus.OK).body(responseData); } 이에 저는 순서에 상관없이 아래 Log내용이 출력되어야 한다고 생각했습니다. errorMsg : http://localhost:18080/nonBlocking - Call nonBlocking webcline02(0) errorMsg : http://localhost:18080/nonBlocking - Call nonBlocking webcline02(1) errorMsg : http://localhost:18080/nonBlocking - Call nonBlocking webcline02(2) 하지만 아래와 같이 요청 시 전달한 i값이 전부 출력되지 않음을 확인하였습니다.errorMsg : http://localhost:18080/nonBlocking - Call nonBlocking webcline02(1) errorMsg : http://localhost:18080/nonBlocking - Call nonBlocking webcline02(2) errorMsg : http://localhost:18080/nonBlocking - Call nonBlocking webcline02(2) NonBlocking 작성이 잘못 되었다고 subscribe를 사용하지 말라.NonBlocking에서 for loop를 사용하지 말라는 조언을 받기는 하였습니다만 관련된 내용을 찾지 못하였습니다.혹여 조언을 얻을 수 있을까 싶어 글 올려봅니다.--- 추가아래와 같이 for loop문을 Flux.range로 수정해보았지만 같은 현상을 확인하였습니다.Flux.range(0,3) .flatMap(t -> webClient.post() .uri("/apiTest") .bodyValue(responseData.setErrorMsg("http://localhost:18080/nonBlocking - Call nonBlocking webcline04(" + t.toString() + ")")) .retrieve() .bodyToMono(ResponseData.class)) .subscribe(response -> log.info("body : {}" ,response.getBody())); 감사합니다.

성질급한두더지 · Accepted Answer

responseData를 클래스 변수나 static으로 선언이 된게 아닌가 생각이 드네요. 공유가능한 변수를 webclient의 비동기 스레드에서 동기화 없이 참조를 하게되서 기대했던 것과 다른 출력 결과가 나타난 것으로 추측됩니다.그리고 비동기 Nonblocking Api를 사용하신다면 for문으로 호출해도 꼭 요청했던 순서 그대로 response가 처리된다고 보장할 수 없습니다.

위리윗 · Answer

성질급한두더지 먼저 조언 감사합니다.말씀 들어보니 제가 사소하게 여겨 전체 내용을 담지 않아 발생하였을 수 있겠다 라는 생각이 들긴합니다.ResponseData의 경우 class단에서 등록된 Bean에서 꺼내오도록 하였습니다.ApplicationContext responseDataAC &#61; new AnnotationConfigApplicationContext(ResponseData.class); ResponseData responseData &#61; responseDataAC.getBean(ResponseData.class);아... 위 코드를 참조하면서도 이부분이 문제가 될거라곤 전혀 생각을 안했습니다.매 호출 시 ResponseData 객체를 새로 생성하여 처리하니 요청되는 Server에서 모든 i값을 받는 것을 확인하였습니다. subscribe(...)가 호출 되어야 요청을 받는 Server의 API가 호출되니깐...의도한대로 각 i값이 ResponseData 객체에 매번 담긴 뒤 subscribe(...)를 호출하기에 해당 Server로 각 i값이 담긴 별개의 ResponseData객체가 전달된다고 생각하였습니다.해당 부분에 대한 개념이 많이 부족했습니다. 찾아보아야겠네요.도움을 주셔 정말 감사합니다.-추가로 NonBlocking이니 loog순서 그대로 호출되지 않음은 인지하고 있었으며 i값이 0, 1, 2 값을 각각 가진 상태로 로그 출력을 예상한다는 질문을 드리고자 하였었습니다.문장구사가 조금 부족했던 것 같습니다. 다시 한번 감사드립니다.

Spring WebFlux webclient NonBlocking 호출 질문

2개의 답변

#webclient 목록