Springboot webClient 10000개 비동기 처리

Question

webclient의 bodyToFlux 를 이용하여 비동기로 처리하였고 요청 성공,실패 를 synchronized 한 List에 각각 담아주었습니다. 이 후 Test를 위해 만든 API(2초 슬립) 에 for문을 10,000번 돌려서 요청을 하였습니다.1만번을 비동기로 돌고 완료되는것을 기다리기 위해 CountDownLatch 을 사용하였습니다.실행결과 1만번을 요청할동안 기다렸지만, 1600회 정도만 성공하였고, 그외에는 시도는 실패하였습니다.실패원인은 timeOut 이라고 로그에 남았습니다. 그래서 혹시 webclient의 TimeOut 설정을 혹여나 더 늘려봤지만 여전히 같은 결과가 나왔습니다.1000회로 변경하고 다시 시도를 하였을때는 1000회 모두 성공을 하였습니다.어떤점이 문제였을까요?

심모 · Answer

에러로그를 다시확인해보니 처음 5개는 해당 에러가 발생하였고,Connection refused: no further information: localhost/127.0.0.1:8080; nested exception is io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: no further information: localhost/127.0.0.1:8080 그 이후에는 아래에러가 발생하였습니다. Pending acquire queue has reached its maximum size of 1000; nested exception is reactor.netty.internal.shaded.reactor.pool.PoolAcquirePendingLimitException: Pending acquire queue has reached its maximum size of 1000에러로그를 봤을 때, 테스트로만든 api서버에 과부하로 보면 될까요?

박종복 · Answer

https://stackoverflow.com/questions/68640474/facing-issue-webclientrequestexception-pending-acquire-queue-has-reached-its-m

Springboot webClient 10000개 비동기 처리

2개의 답변

#webclient 목록