1. @Async(비동기)

Spring에서 비동기(Asynchronous) 처리를 지원하기 위해 사용된다. 내부적으로는 TaskExecutor를 활용하여 메서드를 별도의 스레드에서 실행된다.

 

@Async 어노테이션 내부 동작

1. 프록시(Proxy) 기반 동작

• Spring AOP를 이용하여 프록시 객체가 생성된다.
• @Async가 적용된 메서드를 호출 시 프록시 객체가 대신 실행하고, 실제 메서드는 별도의 스레드에서 실행된다.
• 같은 클래스 내에서 this.asyncMethod()로 직접 호출하면 프록시를 거치지 않아 비동기로 실행되지 않는다.

2. TaskExecutor를 활용한 비동기 실행

• @Async는 TaskExecutor(스레드 풀)을 이용하여 실행된다.
• SimpleAsyncTaskExecutor를 사용하지만, @EnableAsync와 함께 AsyncConfigurer를 설정하면 커스텀 Executor를 지정할 수 있다.

3.리턴 타입 처리(Future, CompletableFuture)

• void : 단순 비동기 실행
• Future<T> : 결과를 Future.get()으로 가져올 수 있음
• CompletableFuture<T> : thenApply(), thenAccept() 등의 체이닝 기능

예제 코드

@EnableAsync // Spring 비동기 기능 활성화
@Configuration
public class AsyncConfig {
    @Bean
    public Executor ossTaskExecutor(){
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(5);
        executor.setMaxPoolSize(10);
        executor.setQueueCapacity(100);
        executor.setThreadNamePrefix("OSS-Async-");
        executor.initialize();
        return executor;
    }
}

@Service
public class AsyncService {

    @Async
    public void asyncMethod(){
        System.out.println("Thread: " + Thread.currentThread().getName());
    }
}

@Component
@RequiredArgsConstructor
public class TestRunner implements CommandLineRunner {
    private final AsyncService asyncService;

    @Override
    public void run(String... args) throws Exception {
        asyncService.asyncMethod();
        System.out.println("Main Thread: " + Thread.currentThread().getName());
    }
}

 

• 출력 결과 

Main Thread: main
Thread: OSS-Async-1

 

---

@Async 사용 시 주의할 점 

1. 같은 클래스 내에서 호출하면 동작하지 않음 

• this.asyncMethod()로 직접 호출하면 프록시를 거치지 않아서 동기적으로 실행

2. 비동기 메서드는 public이어야 함

• Spring AOP의 기본 프록시 방식이 CGLIB 또는 JDK Dynamic Proxy이므로 private 또는 protected 메서드는 프록시 적용이 되지 않음.

3. 예외처리

• @Async 메서드에서 예외가 발생하면 기본적으로 로깅만 되고 호출한 쪽으로 전파되지 않음
• CompletableFuture를 사용하여 예외를 처리할 수 있음

--AsyncService.java
@Service
@RequiredArgsConstructor
public class AsyncService {

    private final Executor ossTaskExecutor;
    
    @Async
    public CompletableFuture<String> asyncMethodByCompletableFuture(){
        CompletableFuture<String> future = CompletableFuture.supplyAsync(()->{
            String ThreadNm = Thread.currentThread().getName();
            System.out.println("CompletableFutire Thread: " + ThreadNm);
            return ThreadNm;
        }, ossTaskExecutor);//ForkJoinPool이 아닌 ossTaskExecutor(ThreadPoolTaskExecutor)로 실행시키기 위함
        return future;
    }
}    

--TestRunner.java > run method
asyncService.asyncMethodByCompletableFuture()
	.exceptionally(ex ->{
        System.out.println("Exception = " + ex.getMessage());
        return "Exception";
	});

 

---

CGLIB, JDK Dynamic Proxy

1. 최적의 성능과 유연성을 위해

• 인터페이스 기반 설계를 선호하는 경우 → JDK Dynamic Proxy 사용
• 인터페이스 없이도 AOP를 적용하고 싶은 경우 → CGLIB 사용
• Spring은 인터페이스 기반 설계를 권장하지만, 인터페이스가 없는 경우에도 AOP를 적용할 수 있도록 CGLIB을 지원.

2. Spring Boot의 @Configuration에서 CGLIB을 기본적으로 사용하는 이유

• @Configuration이 있는 클래스는 Spring의 빈 팩토리를 통해 빈을 관리해야 하는데, JDK Proxy는 인터페이스를 강제하므로 유연성이 떨어짐. 따라서 CGLIB을 사용하여 프록시 객체를 생성하면 빈 관리가 용이해짐.