async 썸네일형 리스트형 Spring Event 사용하기 사용자의 포인트 로직을 설계하고 개발하는 과정에서, 도장판을 생성하는 요청, 회원 가입하는 요청 등 특정 기능이 성공적으로 완료되면 포인트가 적립되는 2 가지의 동작을 해야 하는 경우가 발생했다. 2 가지의 동작을 하나의 메서드에서 구현하게 되면, 도장판 생성 기능과 포인트 적립 기능이 강한 결합(Tight Coupling)이 된다. 이는 로직을 관리하기가 어렵고, 특정 기능에 문제가 발생하였을 때, 해당 문제를 처리하는 로직 역시 섞이게 되어 가독성이 떨어지고 유지보수 측면에서 좋지 않다고 생각했다. ✨ 문제 코드 @Service @RequiredArgsConstructor public class StampBoardService { private final StampBoardRepository stam.. 더보기 [Spring] Reactive Web (4) CompletableFuture Java 8에서 부터 사용 가능하다. 비동기 작업 결과 Future -> 비동기 작업의 결과를 담고 있는 Object ListenableFuture -> Callback 구조로 결과 처리 CompletableFuture -> 다양한 비동기 작업을 간단하게 수행할 수 있다. Future, CompletionStage를 구현하고 있다. CompletionStage -> 완료한 결과에 의존적으로 다른 작업을 실행할 수 있는 기능을 제공한다. 별도의 스레드 풀을 가질 수 있다. 리스트의 모든 값이 완료될 때까지 기다리거나 하나의 값만 완료되길 기다릴지 선택할 수 있다. 람다 표현식, 파이프 라인닝을 활용해 Callback Hell 개선 제공 메서드 CompletableFuture.. 더보기 [Spring] Reactive Web (3) Callback Hell 개선 | 코드 future.addCallback(data -> { ListenableFuture future2 = asyncRestTemplate.getForEntity( Service2Uri, String.class, data.getBody() ); future2.addCallback(data2 -> { ListenableFuture future3 = myServiceV2.work(data.getBody()); future3.addCallback( data3 -> dr.setResult(data3), ex -> dr.setErrorResult(ex) ); }, ex -> { dr.setErrorResult(ex); }); }, ex -> { dr.setErrorResult(ex.. 더보기 [Spring] Reactive Web (2) Spring 비동기 기술 Client 요청의 응답이 될 떄까지 커넥션을 물고 있는다. 클라이언트로부터 요청을 받은 후 실제 작업은 Work Thread Poll에 위임하고 Servlet Thread는 Pool에 반환 한 후, 다음 요청이 들어올 경우 해당 Servlet Thread를 바로 사용할 수 있도록 한다. 한계점 하나의 요청에 대한 작업을 수행하면서, 외부의 서비스들을 호출하는 작업이 많이 있는 경우, Servlet Thread는 바로 사용이 가능하지만, Work Thread는 I/O 작업으로 인한 Block 상태이기 때문에 결국 대기한다. * Thread Pool Hell Pool안에 있는 Thread에 대한 사용 요청이 급격하게 증가해 추가적인 요청이 들어올 때, 사용 가능한 스레드가 없어 사.. 더보기 [Spring] Reactive Web (1) Servlet 비동기 기술 @Async 어노테이션을 사용하여 비동기 로직을 실행한다. @EnableAsync 어노테이션을 사용하여 활성화한다. @Async : ThreadPoolTaskExecutor / ExcutorService가 존재하지 않으면 기본 설정에 따른다. * ThreadPoolTaskExecutor 설정하기 | 코드 @Bean ThreadPoolTaskExecutor tp() { ThreadPoolTaskExecutor te = new ThreadPoolTaskExecutor(); // 처음 스레드 요청이 들어오면 스레드 10개 생성 -> 11번 째 요청 시 대기 큐에 저장 -> 대기 큐가 200개로 꽉 참 -> maxPoolSize까지 스레드 풀을 늘린다. te.setCorePoolSiz.. 더보기 [Java] 비동기 기술 비동기 현재 작업하던 스레드가 아닌 새로운 스레드를 만들어 해당 스레드에서 작업을 수행하는 것 -> 병렬적으로 테스크를 수행한다. 요청을 보낸 후 결과가 도달하지 않아도 다음 작업을 수행한다. 스레드를 새로 만들고 폐기하는 것은 많은 비용이 소모된다. -> 그만큼 CPU를 더 사용하므로 -> 스레드 풀을 사용해서 스레드를 미리 만들어두고 사용한다. -> 스레드 사용 후에 스레드 풀로 반환 | 코드 // 1. 비동기 확인 ExecutorService es = Executors.newCachedThreadPool(); es.execute(() -> { try { System.out.println(Thread.currentThread().getName()); Thread.sleep(2000); System.o.. 더보기 이전 1 다음
