spring webclient 동적(block) 통신 질문입니다.

Question

spring 5 가 되면서 spring에서 get, post 호출할때 resttemplate보단 webclient를 권장하는 분위기고webclient는 동기, 비동기 모두 사용이 가능하다하여 webflux, webclient를 활용한 restful api 서버를 구축중입니다.서버에서 클라이언트로부터 호출을 받으면 다른 api로 get, post요청을 하여 값을 받아와 이 값을 한번 더 다른 api서버에 요청하는 작업이 있습니다.이럴때 resttemplate처럼 동기통신으로 처리할 수 없나요? api 레퍼런스엔 관련 내용이 전혀 없고block을 사용하여 값 출력한 예제는 있어도테스트에선 잘 돌아가도 스프링 부트를 돌려 요청하면 다음과 같은 에러가 뜹니다.java.lang.IllegalStateException: block()/blockFirst()/blockLast() are blocking, which is not supported in thread reactor-http-nio-3 at reactor.core.publisher.BlockingSingleSubscriber.blockingGet(BlockingSingleSubscriber.java:83) Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException: Error has been observed at the following site(s): |_ checkpoint ⇢ HTTP GET &#34;/speed&#34; [ExceptionHandlingWebHandler] 분명 blcok을 사용하여 restemplate처럼 동기 처리가 가능하다고 하였는데어떻게 하면 될까요? 이틀동안 api 문서와, 정리글, 관련 글들 모조리 찾아봐도 해결이 안되어서 질문남깁니다.그냥 이런 방식은 reactive web이 아닌 일반 웹 서버로 구축해야할까요?? -----추가 연습으로 간단하게 기능 테스트 중에 있어서 일단 controller에서 get 요청 받아service에서 처리하도록 했습니다.&#64;GetMapping(&#34;/test&#34;) public String testSpeed(){ String uri &#61; basicService.doservice (); return uri; } 비동기로 mono로 받아 리턴하는것까진 했다가 리턴받은 uri를 바탕으로 한번더 get요청을 해야하기 때문에수정하였습니다. public String doservice(){ WebClient webClient &#61; WebClient.builder() .baseUrl(POST_SESSION_URL) .defaultHeader(HttpHeaders.CONTENT_TYPE, &#34;application/x-www-form-urlencoded&#34;) .build(); LinkedMultiValueMap map &#61; new LinkedMultiValueMap(); map.add (&#34;apikey&#34;, API_KEY); ClientResponse req &#61; (ClientResponse) webClient .post () .header(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE) .acceptCharset(Charset.forName(&#34;UTF-8&#34;)) .body (BodyInserters.fromFormData (map)).exchange ().block (); return req.headers ().asHttpHeaders ().getLocation ().toString (); } 와 같이 post 전송하여 header에 있는 Location uri를 받아와서 다시 한번 webclient.get을 사용하려고 합니다.

컴포지트 · Answer

blocking 사용 방법은 아래 참고하시길.https://junebuug.github.io/2019-02-11/resttemplate-vs-webclient어떻게 코딩했는지 알 수 없는 관계로 이 가이드대로 했는지 한번 확인하시길.

LichKing · Answer

webflux 에서 block 되면 안되는 스레드에서 blocking 호출을 하면 예외를 발생합니다.별도 스레드를 만들어서 block 을 호출하시거나 blocking 하지 않는 방법으로 코드를 작성하셔야합니다.webflux 이용하는거같은데 저런 경우 (저의 경험을 빗대어보면) 사고를 좀 바꿔서해보면 대부분 non-blocking 으로 코드를 작성할수 있던 경우가 있더라고요. 정 방법없으면 위에 말씀드린대로 별도 스레드 만들어서 호출해야하고요.

밤과라임 · Answer

&#64;컴포지트 , LichKing 답변감사합니다. 알려주신 링크도 참고하여 작업을 하였는데도블로킹에러가 떠서 애를 먹는 중 한편으로는 reactive web에선 block을 쓸 수 없나? 라는의문도 품고 있습니다.혹시 수정하여 추가한 소스부분에서 수정할 부분이 있다면 조언 부탁드립니다.

LichKing · Answer

리턴타입이 String 이네요?이거 웹플럭스 맞아요? 아님 spring mvc 에서 WebClient만 쓰려고하시는거에요?

밤과라임 · Answer

@LichKinguri가지고 다시한번 webclient.post()를 사용해야해서 string으로 리턴받는 코드를 먼저 작성했습니다.Mono 타입으로 리턴받는 것은 테스트에서도, 실제 컨트롤러에서도 동작되는 것을 확인했습니다.그때는 저렇게 block을 사용한게 아닌Mono req = webClient .post () .header(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE) .acceptCharset(Charset.forName("UTF-8")) .body (BodyInserters.fromFormData (map)).exchange (); Mono location = req.map (clientResponse ->{ URI uri = clientResponse.headers ().asHttpHeaders ().getLocation (); return String.valueOf (uri); }); 처럼 해서 돌렸고요. 그런데 이렇게 받아서는 다시한번 post요청 하는 method를 타도록 할 수 없어서 1차원적으로접근을 하려던 중입니다.다시한번 webclient를 사용하는 getLive()라는 메소드가 있다고 할 시map의 람다에서도밖에서도 getLive(uri) 메소드가 실행되지 않았습니다.

밤과라임 · Answer

테스트에선 저 getLive 메소드 실행이 안되었는데실제 스프링 실행중에선 호출이 되네요.test는 단일이기에 blcok 사용이 되고, 실행중에선 blocking 에러가 뜬 것과 같이차이가 있었나 봅니다.답변들 감사합니다.

밤과라임 · Answer

&#64;LichKing 검색하던 중 예제 소스들 중에 테스트가 아닌 곳에서 blcok을 한 후 mono나 flux가 아닌 단순 String값을 리턴하는 소스가 있던데 말씀하신대로 스레드를 할당하여 하는게 아닌 기본적으로 사용이 가능한건가요? https://pkgonan.github.io/2019/06/webflux-asynchronous-non-blocking-io-tuning 이곳의 as-is소스입니다.

LichKing · Answer

웹플럭스(리액터) 구현을 저도 잘 알고있는게 아니어서 저것만보고 저게 도네마네는 잘 모르겠네요.다만 예외를 발생시키는 코드가 아래 코드인데요.if (Schedulers.isInNonBlockingThread()) { throw new IllegalStateException(&#34;block()/blockFirst()/blockLast() are blocking, which is not supported in thread &#34; &#43; Thread.currentThread().getName()); }현재 실행중인 스레드가 NonBlocking 스레드이면 예외를 발생시킵니다. NonBlocking 스레드가 뭔지를 보려면 좀 더 파봐야할거같네요.

밤과라임 · Answer

&#64; LichKing 감사합니다. 좀 더 생각해봐야겠네요.일단 map으로 값 찾아서 내부에서 처리하는 식으로 작업하고 있습니다.

spring webclient 동적(block) 통신 질문입니다.

9개의 답변

#webclient 목록