Reactor Pattern Side Effect 비동기로 값 설정하기 질문

Question

기존 httpClient를 사용하던 시스템에 Webclient를 도입하면서 Reactor 패턴을 사용해보고 있습니다.근데 야매로 배워서 그런지 Side Effect 관련 개념이 부족해서 나름대로 해보는데 원하는 퍼포먼스가 나오지 않아 도움을 주실 수 있는 분을 찾고있습니다.Flux로 반환된 결과물을 하나씩 돌면서 Mono로 반환되는 API의 결과값을 받아 값을 설정해주어야 합니다.원본 코드는 회사 코드라 예제 코드로 흐름을 나타내면 이렇습니다.import reactor.core.publisher.Flux import reactor.core.publisher.Mono import reactor.core.scheduler.Schedulers data class Notification( val uid: String, val status: String?, ) data class Status( val status: String ) fun getStatusOfNotification(uid: String): Mono { return Mono.just(Status("Approved")) } fun getNotiList(): Flux { return Flux.fromIterable( listOf( Notification("1", null), Notification("2", null), Notification("3", null), ) ).map { uid -> getStatusOfNotification(uid.uid).map { s -> Notification(uid.uid, s.status) }.toFuture() }.publishOn(Schedulers.boundedElastic()).map { it.get() } } fun main() { val notiList = getNotiList().collectList().block() println(notiList) }값을 설정하지 못하다가 CompletableFuture를 도입해서 일단 동작은 하도록 만들었는데 생각보다 퍼포먼스가 나오지 않아서 잘못된 방법으로 진행하는 게 아닌가 싶습니다.Reactor 패턴을 잘 아시는 분은 답변 주시면 감사드리겠습니다.

adduci · Answer

리액터가 비동기이긴 하지만 처리 시간이 오래걸리지 않고 처리량이 작을 경우엔 오히려 비동기 처리 오버헤드 비용이 더 커서 더 느릴수있어요눈에 보이는 성능 관련 문제점은 마지막 체인에서 get메소드를 호출하는 부분이네요리액터쓰는데 블로킹 메소드 호출하면 안좋습니다

Reactor Pattern Side Effect 비동기로 값 설정하기 질문

1개의 답변

#webclient 목록