webflux 에서 blocking call 처리 방법

Question

Q&A 에 다시 작성해서 올립니다!안녕하세요. 지금 webflux 관련해서 학습하고 있는데, 생각대로 안되는 부분이 있어서 질문드립니다.JPA blocking call 을 Reactor 로 래핑해서 비동기처리를 했을때, 실제로 webflux 의 워커 스레드가 바로 반환되는지 확인해보려고 하는데요,쿼리는 아래와 같고, 1초정도 걸리도록 sleep(1) 을 해놨습니다.interface FileRepository : JpaRepository { @Query( value = """ select * from file where sleep(1) = 0 limit 1 """, nativeQuery = true ) fun findOneAfterASecond(): File }서비스는 아래처럼 Mono 로 감싸서 컨트롤러에 바로 리턴하고 있습니다.fun findOneAfterASecond(): Mono { return Mono.fromCallable { fileRepository.findOneAfterASecond() } .map { it -> FileResponse.createFromFile(it) } .subscribeOn(Schedulers.boundedElastic()) }서버를 실행했을때 reactor-http-nio 라는 스레드가 10개 생겼고, 얘가 워커 스레드라고 생각하고 있습니다.우선 해당 api 로 요청 30개를 동시에 보내면 30개의 요청이 거의 동시에 처리되어 전체처리가 약 1초정도 걸리는걸 예상했습니다.근데, 실제 동작은 요청 10개씩 3번 나뉘어 처리되어 약 3초정도 걸렸습니다.스레드가 생성된걸 확인해보면, boundedElastic() 으로 30개의 스레드가 생성되었고, jpa 쿼리가 다른 스레드에서 처리되었지만, 그 동안에 워커 스레드가 반환되지않고 1초 blocking 되었습니다.혹시 제가 테스트한게 잘못되었을까요?

Devvy · Answer

reactor-http-nio 라는 스레드에서 JPA의 blocking method가 1초씩 걸렸기 때문이 아닐까요 ~? 그럼 초당 10개의 JPA blocking 메서드가 실행되니 총 30개의 요청은 3초가 걸리는 게 맞을 것 같습니다.소스를 정확히 분석해봐야하겠지만...

webflux 에서 blocking call 처리 방법

1개의 답변

#webflux 목록