[Spring Boot 시작 과정] 3. Bean Initialization과 Event System

public interface BeanPostProcessor {
    //빈 객체가 생성되고 의존성 주입이 완료된 후 @PostConstruct나 afterPropertiesSet이 호출되기 직전에 실행된다.
    @Nullable
    default Object postProcessBeforeInitialization(Object bean, String beanName)
            throws BeansException {
        return bean;
    }

    //초기화 메서드(@PostConstruct등)가 실행된 직후에 실행된다. 주로 프록시 객체로 감싸거나(AOP) 최종 검증을 할 때 사용한다.
    @Nullable
    default Object postProcessAfterInitialization(Object bean, String beanName)
            throws BeansException {
        return bean;
    }
}

public interface BeanPostProcessor {
    //빈 객체가 생성되고 의존성 주입이 완료된 후 @PostConstruct나 afterPropertiesSet이 호출되기 직전에 실행된다.
    @Nullable
    default Object postProcessBeforeInitialization(Object bean, String beanName)
            throws BeansException {
        return bean;
    }

    //초기화 메서드(@PostConstruct등)가 실행된 직후에 실행된다. 주로 프록시 객체로 감싸거나(AOP) 최종 검증을 할 때 사용한다.
    @Nullable
    default Object postProcessAfterInitialization(Object bean, String beanName)
            throws BeansException {
        return bean;
    }
}

@Component
public class MyService implements InitializingBean {

    @PostConstruct
    public void postConstruct() {
        // @PostConstruct가 먼저 실행됨
        System.out.println("@PostConstruct executed");
    }

    @Override
    public void afterPropertiesSet() throws Exception {
        // InitializingBean.afterPropertiesSet()이 나중에 실행됨
        System.out.println("afterPropertiesSet executed");
    }
}

@Component
public class MyService implements InitializingBean {

    @PostConstruct
    public void postConstruct() {
        // @PostConstruct가 먼저 실행됨
        System.out.println("@PostConstruct executed");
    }

    @Override
    public void afterPropertiesSet() throws Exception {
        // InitializingBean.afterPropertiesSet()이 나중에 실행됨
        System.out.println("afterPropertiesSet executed");
    }
}

@Component
public class RouteConfigurationLogger implements SmartInitializingSingleton {

    private final ListableBeanFactory beanFactory;

    public RouteConfigurationLogger(ListableBeanFactory beanFactory) {
        this.beanFactory = beanFactory;
    }

    @Override
    public void afterSingletonsInstantiated() {
        // 모든 빈이 이미 다 생성되었으므로 안전하게 모든 컨트롤러를 조회할 수 있다.
        Map<String, Object> controllers = beanFactory.getBeansWithAnnotation(RestController.class);
        
        System.out.println(">>> [최종 확인] 현재 등록된 모든 컨트롤러 수: " + controllers.size());
        controllers.forEach((name, bean) -> {
            // 상세 로직 처리...
        });
    }
}

@Component
public class RouteConfigurationLogger implements SmartInitializingSingleton {

    private final ListableBeanFactory beanFactory;

    public RouteConfigurationLogger(ListableBeanFactory beanFactory) {
        this.beanFactory = beanFactory;
    }

    @Override
    public void afterSingletonsInstantiated() {
        // 모든 빈이 이미 다 생성되었으므로 안전하게 모든 컨트롤러를 조회할 수 있다.
        Map<String, Object> controllers = beanFactory.getBeansWithAnnotation(RestController.class);
        
        System.out.println(">>> [최종 확인] 현재 등록된 모든 컨트롤러 수: " + controllers.size());
        controllers.forEach((name, bean) -> {
            // 상세 로직 처리...
        });
    }
}

// 개별 Bean이 생성될 때마다 BeanPostProcessor가 동작
public class EventListenerMethodProcessor implements BeanPostProcessor {

    @Override
    public Object postProcessAfterInitialization(Object bean, String beanName) {
        // Bean에서 @EventListener 어노테이션이 붙은 메서드 스캔
        // 즉 @EventListener 어노테이션이 붙은 메서드를 가진 클래스는 Bean 이어야 함.
        // Bean이 아니면 @EventListener는 동작하지 않음.
        Method[] methods = bean.getClass().getDeclaredMethods();

        for (Method method : methods) {
            if (method.isAnnotationPresent(EventListener.class)) {
                // ApplicationEventMulticaster에 리스너 등록
                registerEventListener(bean, method);
            }
        }
        return bean;
    }
}

// 개별 Bean이 생성될 때마다 BeanPostProcessor가 동작
public class EventListenerMethodProcessor implements BeanPostProcessor {

    @Override
    public Object postProcessAfterInitialization(Object bean, String beanName) {
        // Bean에서 @EventListener 어노테이션이 붙은 메서드 스캔
        // 즉 @EventListener 어노테이션이 붙은 메서드를 가진 클래스는 Bean 이어야 함.
        // Bean이 아니면 @EventListener는 동작하지 않음.
        Method[] methods = bean.getClass().getDeclaredMethods();

        for (Method method : methods) {
            if (method.isAnnotationPresent(EventListener.class)) {
                // ApplicationEventMulticaster에 리스너 등록
                registerEventListener(bean, method);
            }
        }
        return bean;
    }
}

// Spring이 내부적으로 생성하는 ApplicationListener 래퍼
public class ApplicationListenerMethodAdapter implements ApplicationListener<ApplicationEvent> {

    private final Object targetBean;
    private final Method targetMethod;
    private final Class<?> eventType;  // 파라미터에서 추출한 이벤트 타입

    // @EventListener 메서드가 포함된 Bean과 method 정보를 설정한다.
    public ApplicationListenerMethodAdapter(Object bean, Method method) {
        this.targetBean = bean;
        this.targetMethod = method;
        // 메서드 파라미터에서 이벤트 타입 추출
        this.eventType = method.getParameterTypes()[0];
    }
    
    ...
    ...

    // ApplicationEventMulticaster의 1차 필터(발행된 Event 타입과 파라미터 Event 타입이 맞는..) 통과시 호출
    @Override
    public void onApplicationEvent(ApplicationEvent event) {
		    if (isDefaultExecution()) {
            processEvent(event);
        }
    }
    
    ...
    ...
    
    public void processEvent(ApplicationEvent event) {
        // 발행된 이벤트가 메서드 파라미터와 일치하는지 확인하고 인자 리스트 생성
    		Object[] args = resolveArguments(event);
    		// @EventListener(condition="...") 등의 조건이 있다면 체크
    		// 여기서 2차 필터 동작
		    if (shouldHandle(event, args)) {
		        // 실제 Bean의 @EventListener 메서드 호출
            Object result = doInvoke(args);
            if (result != null) {
                // 메서드 반환값이 있다면 그 반환값을 다시 새로운 이벤트로 발행 (Chaning)
                handleResult(result);
            }
            else {
                logger.trace("No result object given - no result to handle");
            }
        }
    }
    
    ...
    ...
    
    @Nullable
    protected Object[] resolveArguments(ApplicationEvent event) {
        // 현재 발행된 이벤트를 기반으로 파라미터에 정의된 이벤트 타입을 가져온다.
        ResolvableType declaredEventType = getResolvableType(event);
    		if (declaredEventType == null) {
            return null;
        }
        // @EventListener 메서드에 파라미터가 없다면 인자를 넘길 필요가 없으므로 빈 배열 반환
        if (this.method.getParameterCount() == 0) {
            return new Object[0];
        }
        // 메서드에 선언된 파라미터의 Class 타입을 가져옴
        Class<?> declaredEventClass = declaredEventType.toClass();
        // 메서드 파라미터가 ApplicationEvent를 상속받지 않았고 (즉, 일반 DTO나 String과 같은.)
        // 메서드 파라미터가 PayloadApplicationEvent(내용을 담고 있는 이벤트)라면
        if (!ApplicationEvent.class.isAssignableFrom(declaredEventClass) &&
            event instanceof PayloadApplicationEvent<?> payloadEvent) {
            // 발행된 이벤트에서 실제 데이터(payload)를 꺼낸다.
            Object payload = payloadEvent.getPayload();
            // 꺼낸 payload 타입이 메서드 파라미터 타입과 일치하는지 확인한다.
            if (declaredEventClass.isInstance(payload)) {
                // 일치한다면 이벤트객체가 아닌 데이터(payload)를 인자로 결정한다.
                return new Object[] {payload};
            }
        }
        return new Object[] {event};
    }
}

// Spring이 내부적으로 생성하는 ApplicationListener 래퍼
public class ApplicationListenerMethodAdapter implements ApplicationListener<ApplicationEvent> {

    private final Object targetBean;
    private final Method targetMethod;
    private final Class<?> eventType;  // 파라미터에서 추출한 이벤트 타입

    // @EventListener 메서드가 포함된 Bean과 method 정보를 설정한다.
    public ApplicationListenerMethodAdapter(Object bean, Method method) {
        this.targetBean = bean;
        this.targetMethod = method;
        // 메서드 파라미터에서 이벤트 타입 추출
        this.eventType = method.getParameterTypes()[0];
    }
    
    ...
    ...

    // ApplicationEventMulticaster의 1차 필터(발행된 Event 타입과 파라미터 Event 타입이 맞는..) 통과시 호출
    @Override
    public void onApplicationEvent(ApplicationEvent event) {
		    if (isDefaultExecution()) {
            processEvent(event);
        }
    }
    
    ...
    ...
    
    public void processEvent(ApplicationEvent event) {
        // 발행된 이벤트가 메서드 파라미터와 일치하는지 확인하고 인자 리스트 생성
    		Object[] args = resolveArguments(event);
    		// @EventListener(condition="...") 등의 조건이 있다면 체크
    		// 여기서 2차 필터 동작
		    if (shouldHandle(event, args)) {
		        // 실제 Bean의 @EventListener 메서드 호출
            Object result = doInvoke(args);
            if (result != null) {
                // 메서드 반환값이 있다면 그 반환값을 다시 새로운 이벤트로 발행 (Chaning)
                handleResult(result);
            }
            else {
                logger.trace("No result object given - no result to handle");
            }
        }
    }
    
    ...
    ...
    
    @Nullable
    protected Object[] resolveArguments(ApplicationEvent event) {
        // 현재 발행된 이벤트를 기반으로 파라미터에 정의된 이벤트 타입을 가져온다.
        ResolvableType declaredEventType = getResolvableType(event);
    		if (declaredEventType == null) {
            return null;
        }
        // @EventListener 메서드에 파라미터가 없다면 인자를 넘길 필요가 없으므로 빈 배열 반환
        if (this.method.getParameterCount() == 0) {
            return new Object[0];
        }
        // 메서드에 선언된 파라미터의 Class 타입을 가져옴
        Class<?> declaredEventClass = declaredEventType.toClass();
        // 메서드 파라미터가 ApplicationEvent를 상속받지 않았고 (즉, 일반 DTO나 String과 같은.)
        // 메서드 파라미터가 PayloadApplicationEvent(내용을 담고 있는 이벤트)라면
        if (!ApplicationEvent.class.isAssignableFrom(declaredEventClass) &&
            event instanceof PayloadApplicationEvent<?> payloadEvent) {
            // 발행된 이벤트에서 실제 데이터(payload)를 꺼낸다.
            Object payload = payloadEvent.getPayload();
            // 꺼낸 payload 타입이 메서드 파라미터 타입과 일치하는지 확인한다.
            if (declaredEventClass.isInstance(payload)) {
                // 일치한다면 이벤트객체가 아닌 데이터(payload)를 인자로 결정한다.
                return new Object[] {payload};
            }
        }
        return new Object[] {event};
    }
}

// @EventListener 메서드 - 파라미터 타입으로 이벤트 매핑
@Component
public class MyEventListener {

 // ApplicationStartingEvent가 발행되면
 // ApplicationEventMulticaster --> handleStarting 메서드 처리용 ApplicationListenerMethodAdapter 호출
 // ApplicationListernerMethodAdapter에서 리플렉션으로 AplicationStartingEvent 객체와 함께 handleStarting을 호출
    @EventListener
    public void handleStarting(ApplicationStartingEvent event) {
        log.info("Application is starting...");
    }

// ApplicationReadyEvent가 발행되면
// ApplicationEventMulticaster --> handleReady 메서드 처리용 ApplicationListenerMethodAdapter 호출
// ApplicationListernerMethodAdapter에서 리플렉션으로 ApplicationReadyEvent 객체와 함께 handleReady를 호출
    @EventListener
    public void handleReady(ApplicationReadyEvent event) {
        log.info("Application is ready...");
    }

// ApplicationEvent가 발행되면
// ApplicationEventMulticaster --> handleAnyEvent 메서드 처리용 ApplicationListenerMethodAdapter 호출
// ApplicationListernerMethodAdapter에서 리플렉션으로 ApplicationEvent 객체와 함께 handleAnyEvent를 호출
// ApplicationEvent는 모든 ApplicationEvent 타입의 추상 클래스이므로 모든 ApplicationEvent 타입의 이벤트가 발생되면 호출
    @EventListener
    public void handleAnyEvent(ApplicationEvent event) {
        log.info("Any application event occurred: {}", event.getClass().getSimpleName());
    }
    
// Payload 기반 이벤트 처리 (POJO 방식)
// ApplicationEvent를 상속받지 않은 순수 객체(String, DTO 등)도 처리 가능하다.
// String 타입의 데이터를 포함한 이벤트가 발행되면
// 내부적으로 ApplicationListenerMethodAdapter의 resolveArguments가 payload를 추출합니다. (String 타입)
// ApplicationListernerMethodAdapter에서 리플렉션으로 String 데이터와 함께 handleStringPayload 호출.
    @EventListener
    public void handleStringPayload(String message) {
        log.info("문자열 페이로드 이벤트 수신: {}", message);
    }
    
// PayloadApplicationEvent 자체를 인자로 받는 경우
// 페이로드뿐만 아니라 이벤트의 부가 정보(타임스탬프 등)가 필요할 때 사용합니다.
    @EventListener
    public void handlePayloadEvent(PayloadApplicationEvent<MyCustomDto> event) {
        MyCustomDto dto = event.getPayload();
        log.info("PayloadApplicationEvent 래퍼를 통한 수신: {}, 발행시간: {}", 
                 dto.getName(), event.getTimestamp());
    }
}

// @EventListener 메서드 - 파라미터 타입으로 이벤트 매핑
@Component
public class MyEventListener {

 // ApplicationStartingEvent가 발행되면
 // ApplicationEventMulticaster --> handleStarting 메서드 처리용 ApplicationListenerMethodAdapter 호출
 // ApplicationListernerMethodAdapter에서 리플렉션으로 AplicationStartingEvent 객체와 함께 handleStarting을 호출
    @EventListener
    public void handleStarting(ApplicationStartingEvent event) {
        log.info("Application is starting...");
    }

// ApplicationReadyEvent가 발행되면
// ApplicationEventMulticaster --> handleReady 메서드 처리용 ApplicationListenerMethodAdapter 호출
// ApplicationListernerMethodAdapter에서 리플렉션으로 ApplicationReadyEvent 객체와 함께 handleReady를 호출
    @EventListener
    public void handleReady(ApplicationReadyEvent event) {
        log.info("Application is ready...");
    }

// ApplicationEvent가 발행되면
// ApplicationEventMulticaster --> handleAnyEvent 메서드 처리용 ApplicationListenerMethodAdapter 호출
// ApplicationListernerMethodAdapter에서 리플렉션으로 ApplicationEvent 객체와 함께 handleAnyEvent를 호출
// ApplicationEvent는 모든 ApplicationEvent 타입의 추상 클래스이므로 모든 ApplicationEvent 타입의 이벤트가 발생되면 호출
    @EventListener
    public void handleAnyEvent(ApplicationEvent event) {
        log.info("Any application event occurred: {}", event.getClass().getSimpleName());
    }
    
// Payload 기반 이벤트 처리 (POJO 방식)
// ApplicationEvent를 상속받지 않은 순수 객체(String, DTO 등)도 처리 가능하다.
// String 타입의 데이터를 포함한 이벤트가 발행되면
// 내부적으로 ApplicationListenerMethodAdapter의 resolveArguments가 payload를 추출합니다. (String 타입)
// ApplicationListernerMethodAdapter에서 리플렉션으로 String 데이터와 함께 handleStringPayload 호출.
    @EventListener
    public void handleStringPayload(String message) {
        log.info("문자열 페이로드 이벤트 수신: {}", message);
    }
    
// PayloadApplicationEvent 자체를 인자로 받는 경우
// 페이로드뿐만 아니라 이벤트의 부가 정보(타임스탬프 등)가 필요할 때 사용합니다.
    @EventListener
    public void handlePayloadEvent(PayloadApplicationEvent<MyCustomDto> event) {
        MyCustomDto dto = event.getPayload();
        log.info("PayloadApplicationEvent 래퍼를 통한 수신: {}, 발행시간: {}", 
                 dto.getName(), event.getTimestamp());
    }
}

// 샘플 이벤트 리스너 구현 예시
@Component
@Slf4j
public class StartupEventListener {

    //아래 이벤트는 호출되지 않는다.
    //@Component로 Bean을 등록하는데 Bean이 생성되는 10단계 (ApplicationContext Refresh)
    //과정에서 이 Bean이 생성되는데 ApplicationStartingEvent는 이 Bean이 생성되기
    //이전에 발행되는 이벤트이기 때문이다.
    @EventListener
    public void handleApplicationStarting(ApplicationStartingEvent event) {
        // 가장 먼저 발생하는 이벤트
        // 로깅 시스템 초기화, 기본 설정 등
        log.info("Application starting...");
    }

    //아래 이벤트 메서드는 호출되지 않는다.
    //@Component로 Bean을 등록하는데 Bean이 생성되는 10단계 (ApplicationContext Refresh)
    //과정에서 이 Bean이 생성되는데 ApplicationEnvironmentPreparedEvent는 이 Bean이 생성되기
    //이전에 발행되는 이벤트이기 때문이다.
    @EventListener
    public void handleEnvironmentPrepared(ApplicationEnvironmentPreparedEvent event) {
        // Environment가 준비되어 프로퍼티 접근 가능
        ConfigurableEnvironment env = event.getEnvironment();
        String profile = String.join(",", env.getActiveProfiles());
        log.info("Active profiles: {}", profile);
    }

    // 아래 이벤트는 이 Bean이 생성된 이벤트이므로 호출된다.
    @EventListener
    public void handleApplicationReady(ApplicationReadyEvent event) {
        // 애플리케이션이 완전히 준비됨
        // 외부 시스템 연결, 헬스 체크 등록 등
        log.info("Application ready to serve requests");
    }
}

// 샘플 이벤트 리스너 구현 예시
@Component
@Slf4j
public class StartupEventListener {

    //아래 이벤트는 호출되지 않는다.
    //@Component로 Bean을 등록하는데 Bean이 생성되는 10단계 (ApplicationContext Refresh)
    //과정에서 이 Bean이 생성되는데 ApplicationStartingEvent는 이 Bean이 생성되기
    //이전에 발행되는 이벤트이기 때문이다.
    @EventListener
    public void handleApplicationStarting(ApplicationStartingEvent event) {
        // 가장 먼저 발생하는 이벤트
        // 로깅 시스템 초기화, 기본 설정 등
        log.info("Application starting...");
    }

    //아래 이벤트 메서드는 호출되지 않는다.
    //@Component로 Bean을 등록하는데 Bean이 생성되는 10단계 (ApplicationContext Refresh)
    //과정에서 이 Bean이 생성되는데 ApplicationEnvironmentPreparedEvent는 이 Bean이 생성되기
    //이전에 발행되는 이벤트이기 때문이다.
    @EventListener
    public void handleEnvironmentPrepared(ApplicationEnvironmentPreparedEvent event) {
        // Environment가 준비되어 프로퍼티 접근 가능
        ConfigurableEnvironment env = event.getEnvironment();
        String profile = String.join(",", env.getActiveProfiles());
        log.info("Active profiles: {}", profile);
    }

    // 아래 이벤트는 이 Bean이 생성된 이벤트이므로 호출된다.
    @EventListener
    public void handleApplicationReady(ApplicationReadyEvent event) {
        // 애플리케이션이 완전히 준비됨
        // 외부 시스템 연결, 헬스 체크 등록 등
        log.info("Application ready to serve requests");
    }
}

@Component
public class OrderedEventListener {

    @EventListener
    @Order(Ordered.HIGHEST_PRECEDENCE)  // 가장 높은 우선순위
    public void handleFirst(ApplicationReadyEvent event) {
        log.info("First handler executed");
    }

    @EventListener
    @Order(Ordered.LOWEST_PRECEDENCE)   // 가장 낮은 우선순위
    public void handleLast(ApplicationReadyEvent event) {
        log.info("Last handler executed");
    }
}

@Component
public class OrderedEventListener {

    @EventListener
    @Order(Ordered.HIGHEST_PRECEDENCE)  // 가장 높은 우선순위
    public void handleFirst(ApplicationReadyEvent event) {
        log.info("First handler executed");
    }

    @EventListener
    @Order(Ordered.LOWEST_PRECEDENCE)   // 가장 낮은 우선순위
    public void handleLast(ApplicationReadyEvent event) {
        log.info("Last handler executed");
    }
}

@Component
public class ConditionalEventListener {

    /*
        activeProfiles에 'dev'가 포함된 경우에만 이벤트를 처리한다.
    */
    @EventListener(condition = "#event.environment.activeProfiles.contains('dev')")
    public void handleDevOnly(ApplicationEnvironmentPreparedEvent event) {
        log.info("This only runs in dev profile");
    }

    /*
        애플리케이션 시작에 5초(5000ms) 이상 소요된 경우에만 이벤트를 처리한다.
    */
    @EventListener(condition = "#event.timeTaken.toMillis() > 5000")
    public void handleSlowStartup(ApplicationStartedEvent event) {
        log.warn("Application took more than 5 seconds to start: {} ms",
                event.getTimeTaken().toMillis());
    }
}

@Component
public class ConditionalEventListener {

    /*
        activeProfiles에 'dev'가 포함된 경우에만 이벤트를 처리한다.
    */
    @EventListener(condition = "#event.environment.activeProfiles.contains('dev')")
    public void handleDevOnly(ApplicationEnvironmentPreparedEvent event) {
        log.info("This only runs in dev profile");
    }

    /*
        애플리케이션 시작에 5초(5000ms) 이상 소요된 경우에만 이벤트를 처리한다.
    */
    @EventListener(condition = "#event.timeTaken.toMillis() > 5000")
    public void handleSlowStartup(ApplicationStartedEvent event) {
        log.warn("Application took more than 5 seconds to start: {} ms",
                event.getTimeTaken().toMillis());
    }
}

@Component
public class CustomEventListener {

    //Application Bootstraping이 끝난 후 ApplicationReadyEvent를 받아서 처리할 수 있다.
    @EventListener
    @Async
    public void handleAsyncEvent(ApplicationReadyEvent event) {
        // 비동기 처리
    }

    //Application이 시작된 직후 ApplicationStartedEvent를 받아서 처리할 수 있다.
    @EventListener
    @Order(Ordered.HIGHEST_PRECEDENCE)
    public void handleHighPriorityEvent(ApplicationStartedEvent event) {
        // 높은 우선순위로 처리
    }
}

@Component
public class CustomEventListener {

    //Application Bootstraping이 끝난 후 ApplicationReadyEvent를 받아서 처리할 수 있다.
    @EventListener
    @Async
    public void handleAsyncEvent(ApplicationReadyEvent event) {
        // 비동기 처리
    }

    //Application이 시작된 직후 ApplicationStartedEvent를 받아서 처리할 수 있다.
    @EventListener
    @Order(Ordered.HIGHEST_PRECEDENCE)
    public void handleHighPriorityEvent(ApplicationStartedEvent event) {
        // 높은 우선순위로 처리
    }
}

@Component
public class TypedEventListener implements ApplicationListener<ApplicationReadyEvent> {

    @Override
    public void onApplicationEvent(ApplicationReadyEvent event) {
        // 타입 안전한 이벤트 처리
        log.info("Application ready at: {}", event.getTimeTaken());
    }
}

@Component
public class TypedEventListener implements ApplicationListener<ApplicationReadyEvent> {

    @Override
    public void onApplicationEvent(ApplicationReadyEvent event) {
        // 타입 안전한 이벤트 처리
        log.info("Application ready at: {}", event.getTimeTaken());
    }
}

@Getter
public class TaskCompletionEvent {
    private final Long taskId;
    private final String userEmail;

    public TaskCompletionEvent( Long taskId, String userEmail ) {
        this.taskId = taskId;
        this.userEmail = userEmail;
    }
}

@Getter
public class TaskCompletionEvent {
    private final Long taskId;
    private final String userEmail;

    public TaskCompletionEvent( Long taskId, String userEmail ) {
        this.taskId = taskId;
        this.userEmail = userEmail;
    }
}

@Service
public class TaskService {
    // publisher에는 보통 ApplicationContext 구현체가 주입됩니다.
    // ApplicationContext 인터페이스는 ApplicationEventPublisher를 확장합니다.
    private final ApplicationEventPublisher publisher;

    public TaskService(ApplicationEventPublisher publisher) {
        this.publisher = publisher;
    }

    public void goTask(Long orderId, String email) {
        // task 처리 로직
        // task 처리가 완료 되면 TaskCompletionEvent 발행
        publisher.publishEvent(new TaskCompletionEvent(orderId, email));
    }
}

@Service
public class TaskService {
    // publisher에는 보통 ApplicationContext 구현체가 주입됩니다.
    // ApplicationContext 인터페이스는 ApplicationEventPublisher를 확장합니다.
    private final ApplicationEventPublisher publisher;

    public TaskService(ApplicationEventPublisher publisher) {
        this.publisher = publisher;
    }

    public void goTask(Long orderId, String email) {
        // task 처리 로직
        // task 처리가 완료 되면 TaskCompletionEvent 발행
        publisher.publishEvent(new TaskCompletionEvent(orderId, email));
    }
}

@Component
public class TaskEventListener {

    // TaskCompletionEvent 발생시 호출됩니다.
    @EventListener
    public void onTaskCompleted(TaskCompletionEvent event) {
        //task 완료 후 처리
        // 동기 처리 (기본)
        // 예: 이메일 큐 적재, 감사 로그 기록 등
    }
}

@Component
public class TaskEventListener {

    // TaskCompletionEvent 발생시 호출됩니다.
    @EventListener
    public void onTaskCompleted(TaskCompletionEvent event) {
        //task 완료 후 처리
        // 동기 처리 (기본)
        // 예: 이메일 큐 적재, 감사 로그 기록 등
    }
}