DI → 3

Dependency Injection이란 2개의 오브젝트가 있고 하나의 오브젝트가 다른 오브젝트를 의존하고 있는데 항상 제 3의 오브젝트가 그 으존 관계를 설정해주는 구조로 동작하는 것을 말한다. 그래서 3이다.

동기 비동기

• A,B 쓰레드가 동시에 작업을 시작하면 동기이다.
• 주로 여기서 동기 얘기가 많이 나오는데 어떤 A라는 메소드를 요청했을 때 리턴 시점과 그 결과를 전달받는 시점이 일치하면 동기
• 동기, 비동기와 블로킹 논블로킹은 관점이 아예 다르다. 이것이 거론될 수 있는 시점은 내가 직접 제어하지 못하는 대상을 어떻게 상대할 것인지를 설명할 때 거론된다.
  • 예를 들어 어떤 메서드를 호출해서 어떤 것을 가져와야 하는데 제 3의 존재로 인풋을 받는다 → I/O
  • 나 말고 다른 쓰레드에게 결과를 확인받고 종료하는걸 확인하고 넘어가야 하는 상황 등 → 멀티쓰레드 동기화

@Async

• 스프링에서는 비동기 요청의 응답을 핸들링하기 위한 클래스가 별도로 존재합니다.

  • void

  • Future<T>

    • 비동기 요청 결과를 가져올 수 있는 기본적인 채널 인터페이스를 제공하는 것
    • Future 인스턴스로 자신이 받을 타입을 감싸서 반환해야합니다.
    • java.concurrent.Future

  • ListenableFuture<T>

    

    • addCallback()을 통해 응답이 전달되었을 때 수행하는 콜백 함수를 작성한다.
    • 비동기에서는 다른 스레드에서 다른 스택 트레이스로 동작합니다. 즉 예외가 발생해도 바로 던져지지 않죠. 이때는 콜백을 이용해서 예외를 적절하게 처리해야 합니다.

  • CompletableFuture<T>

    

    • 자바 8에서 추가됐다.

  • 여기서 @Async 어노테이션을 사용하는건 상관없지만 잘 생각하고 사용해야 합니다.

    • 여기서 사용되는 스레드들은 기본 TaskExecutor를 통해 사용한다. 이건 쓰레드 풀이 아니다. 쓰레드를 쓰고 버리기 때문에 자원 낭비가 심하다.
    • 이런 경우 @Async(”myExecutor”) 혹은 Executor, ExecutorService, TaskExecutor 타입의 빈을 등록하면 해당 스레드 풀을 사용하도록 해준다.

• @Async 메서드에서 스레드 생성 동작

  

  • 정답은 3번이다. 주의해야할 점은 자바, 스프링 모두 코어 풀사이즈를 오버하면 큐부터 채운다. 그리고 다 채우고도 감당이 안되면 맥시멈 풀사이즈를 늘린다.
  • 10개 호출은 스레드에, 나머지 40개는 큐에 들어간다.

Servlet 3.0+ 비동기 서블릿

• 무엇인가를 기다리느라 서블릿 요청 처리를 완료하지 못하는 경우를 위해서 등장했습니다.

  

  

  • 서블릿에서 AsyncContext를 생성해 서블릿 응답(response) 처리를 합니다. 하지만 비동기 요청에 응답을 받기 전에 메서드를 종료하고 서블릿 스레드를 반납하는 방식을 통해 가용 스레드 개수를 유지하는 방식입니다.
  • 어디에서는 AsyncContext를 이용해서 응답을 넣어주게 되면 클라이언트에 응답 결과를 보내게 됩니다.

비동기 스프링 @MVC

• 위에서 말한 Servlet 3.0+ 비동기 요청 처리 기반의 @MVC입니다. 아래는 리턴 타입 종류입니다.

  • Callable<T>

    • 함수형 인터페이스의 콜백 객체를 생성해 넣는 방식

  • WebAsyncTask<T>

    • 타임아웃이 필요하고 예외 발생이 필요한 경우 사용하면 됩니다.

  • DeferredResult<T>

    

    • 웹 응답(ResponseBody, ViewName)을 어떻게 만들어 낼 것이냐? 이런 값들을 넣어줄 수 있는 핸들러다.
    • 임의의 쓰레드에서 리턴 값 설정이 가능해서 위에서 말한 응답값에 넣어주면 된다.
    • deferredResult를 만들고 빠져나가면 그대로 풀에 반환된다. 그리고 응답을 넣어주는 건 새로운 스레드가 처리한다.

  • @Async + ListenableFuture<T> + DeferredResult<T>

    

    • DeferrendResult 생성
    • @Async가 붙은 myService.async() 비동기 메서드 실행한다. 그러면 ListenableFuture가 돌아온다. 이건 결과가 오면 콜백 오브젝트를 호출하는 방식으로 처리한다.
    • 콜백을 람다식으로 정의하면서 요기서 DeferredResult의 값을 사용하도록 해주면 된다.
    • 이렇게 리턴하면 비동기 작업이 끝나기 전에 컨트롤러 메서드는 종료되면서 이걸 물고 있는 서블릿 스레드는 먼저 반환된다. 그리고 DeferredResult 응답이 완료되면 그걸 받아서 클라이언트에게 응답한다.

• 스프링이 위처럼 쓰는걸 알고 ListenableFuture<T> 을 만들어서 위 과정을 생략할 수 있다.

  

  • 두 가지 이상인 경우는 방법이 없다. 비동기 작업 결과를 어떻게 다음 비동기 작업의 인자로 넘길까. 이 땐 앞선 콜백 + DeferredResult 방식으로 돌아가야 합니다. 이는 콜백 헬을 야기한다. 이는 ListenableFuture에서 피할수는 없다.

    

• 비동기 작업의 결합은 CompletableFuture<T>를 사용하면 해결 가능하다.

  

  • CompletionStage의 조합을 통해 메서드 체이닝 방식으로 벗어날 수 있다.

    • COmpletabelFuture 결과를 받고 thenCompose()를 통해 다시 비동기 작업을 이어간다.

    • 람다식과 메서드 레퍼런스를 통해 좀더 간결하게 만들 수 있다.

      

비동기 논블로킹 API 호출