9. IoC 컨테이너 8부 : ApplicationEventPublisher

이벤트 프로그래밍에 필요한 인터페이스 제공. 옵저버 패턴 구현체

 

ApplicationContext extends ApplicationEventPublisher

• publishEvent(ApplicationEvent event)

 

[event 처리 과정]

SpringBootApplication이 구동 -> AppRunner가 실행이 되면서 -> event 발생!

-> 발생한 event를 등록되어있는 빈 중에서 MyEvent가 받아서 처리.

 

 

이벤트 발생 시키는 방법 - ApplicationEventPublisher.publishEvent();

@Component
public class AppRunner implements ApplicationRunner {

    @Autowired
    ApplicationContext applicationContext;

    @Override
    public void run(ApplicationArguments args) throws Exception {
        applicationContext.publishEvent(new MyEvent(this,100));
    }
}

ApplicationContext 가 ApplicationEventPublisher를 상속받기 때문에, publishEvent(ApplicationEvent event) 를 사용할수 있다.

 

 

 

이벤트 만들기

• ApplicationEvent 상속
• 스프링 4.2 부터는 이 클래스를 상속받지 않아도 이벤트로 사용할 수 있다.

public class MyEvent extends ApplicationEvent {
    private  int data;

    public MyEvent(Object source) {
        super(source);
    }

    public MyEvent(Object source, int data) {
        super(source);
        this.data = data;
    }

    public int getData() {
        return data;
    }
}

아래 코드와 같이 이벤트는 *POJO 스타일로 만들 수 있다. 원래는 ApplicationEvent를 상속받아 만들어야 했지만 Spring 4.2부터는 클래스를 상속받지 않아도 이벤트로 사용할 수 있다.

*POJO ? 스프링 코드가 노출이 되지 않는것. 이런 코드가 테스트 하기 편하고, 유지보수 하기가 편해진다.

!! (이런 코드가 SpringFramework 가 추구하는 철학(?)이다. (비침투성,  이 코드에는 스프링패키지가 전혀 들어가있지 않다.)

public class MyEvent {
    private  int data;
    private Object source;

    public MyEvent(Object source) {
		this.source = source;
    }

    public MyEvent(Object source, int data) {
		this.source = source;
        this.data = data;
    }

	public Object getSource(){
    	return source;
    }
    
    public int getData() {
        return data;
    }
    
    public void setSource(Object source){
    	this.source = source;
    }
    
    public void setData(int data){
		this.data = data;
    }
}

 

이벤트 받아 오는 방법

@Component
public class MyEvenHandler implements ApplicationListener<MyEvent> {

    @Override
    public void onApplicationEvent(MyEvent event) {
        System.out.println("이벤트 받았다. 데이터는 " + event.getData());
    }
}

ApplicationListener<MyEvent> 를 구현하고, MyEvent event 를 인자로 받아와서 event의 메소드를 호출해 출력한다.

 

handler도 spring 4.2 이후에는 특정 인터페이스를 구현하지 않아도 된다.

@Component
public class MyEvenHandler { //스프링 4.2 이후부터는 구현 하지 않아도 됨!

	@EventListener //대신 빈으로는 등록해줘야함. 애노테이션 붙여야함.
    public void handle(MyEvent event) { //메소드 이름도 맘대로 가능.
        System.out.println("이벤트 받았다. 데이터는 " + event.getData());
    }
}

아래는 출력 결과이다.

이벤트 받았다. 데이터는 100

 

 

 

 

Handler가 여러 개 라면?

@Component
public class AnotherHandler {

    @EventListener
    public void handle(MyEvent myEvent){
        System.out.println(Thread.currentThread().toString());//Thread를 찍어보기 위한 코드
        System.out.println("Another " + myEvent.getData());
    }
}

MyEventHandler와 AnotherHandler 가 두개의 핸들러가 있고, 동시에 실행을 시키면??

어떤 쓰레드에서 찍히는지 출력을 해보았다.

Thread[main,5,main]
Another 100
Thread[main,5,main]
이벤트 받았다. 데이터는 100

  둘다 main 쓰레드에서 실행이 되었고, 동시에 실행이 되는건 아니다.

 

 

 

순서를 정하고 싶다면  @Order 를 사용

@Component
public class AnotherHandler {

    @EventListener
    @Order(Ordered.HIGHEST_PRECEDENCE) //가장 높은 우선순위 부여
    public void handle(MyEvent myEvent){
        System.out.println(Thread.currentThread().toString());//Thread를 찍어보기 위한 코드
        System.out.println("Another " + myEvent.getData());
    }
}

만약 우선순위보다 낮게 출력하려면 Ordered.HIGHEST_PRECEDENCE + 2 정도를 더해주면 늦게 출력된다.

 

 

 

비동기적으로 실핼하고 싶다면 @Async 를 사용

@Component
public class MyEvenHandler { 

	@EventListener 
    @Async //비동기적 실행
    public void handle(MyEvent event) { 
		System.out.println(Thread.currentThread().toString());
        System.out.println("이벤트 받았다. 데이터는 " + event.getData());
    }
}

@SpringBootApplication
@EnableAsync //반드시 @EnableAsync 와 함께 사용해야한다. 안그러면 적용이 안된다.
public class Demospring51Application {

    public static void main(String[] args) {
        SpringApplication.run(Demospring51Application.class, args);
    }
}

@EventListener 애노테이션이 붙은 메소드에 @Async 애노테이션을 붙여 비동기적으로 실행 시킨다는 것을 명시해야한다.

이때 @Order 애노테이션은 의미가 없어지게 된다.

@Async 를 활성화 시키려면, @SpringBootApplication 애노테이션이 붙은 클래스에 @EnableAsync를 붙여줘야만 한다.

Thread[task-1,5,main]
Thread[task-2,5,main]
Another 100
이벤트 받았다. 데이터는 100



 

 

 

스프링이 제공하는 기본 이벤트

ContextRefreshedEvent : ApplicationContext를 초기화 했거나, 리프래시 했을때 발생

ContextStartedEvent : ApplicationContext를 start()하여 라이프 사이클 빈들이 시작 신호를 받은 시점에 발생.

ContextStopedEvent : ApplicationContext를 stop()하여 라이프 사이클 빈들이 정지 신호를 받은 시점에 발생.

ContextClosedEvent : ApplicationContext를 close()하여 싱글톤 빈 소명되는 시점에 발생.

RequestHandledEvent : HTTP 요청을 처리했을 때 발생.

 

@Component
public class MyEvenHandler {//특정 인터페이스를 구현하지 않아도 된다.

    @EventListener
    @Async
    public void handle(MyEvent event) {
        System.out.println(Thread.currentThread().toString());
        System.out.println("이벤트 받았다. 데이터는 " + event.getData());
    }

    @EventListener
    @Async
    public void handle(ContextRefreshedEvent event) {
        System.out.println(Thread.currentThread().toString());
        System.out.println("ContextRefreshedEvent");
    }//ApplicationContext를 초기화 했거나 리프레시 했을때 발생

    @EventListener
    @Async
    public void handle(ContextClosedEvent event) {
        System.out.println(Thread.currentThread().toString());
        System.out.println("ContextClosedEvent");
    }//ApplicationContext를 close()하여 싱글톤 빈 소멸되는 시점에 발생.
}

 

2020-07-07 23:38:54.119  INFO 1467 --- [           main] o.s.s.concurrent.ThreadPoolTaskExecutor  : Initializing ExecutorService 'applicationTaskExecutor'
2020-07-07 23:38:54.253  INFO 1467 --- [           main] o.s.b.w.embedded.tomcat.TomcatWebServer  : Tomcat started on port(s): 8080 (http) with context path ''
Thread[task-1,5,main]
ContextRefreshedEvent
2020-07-07 23:38:54.267  INFO 1467 --- [           main] c.e.d.Demospring51Application            : Started Demospring51Application in 1.087 seconds (JVM running for 1.548)
Thread[task-3,5,main]
이벤트 받았다. 데이터는 100
Thread[task-2,5,main]
Another 100
Thread[task-4,5,main]
ContextClosedEvent
2020-07-07 23:38:59.537  INFO 1467 --- [extShutdownHook] o.s.s.concurrent.ThreadPoolTaskExecutor  : Shutting down ExecutorService 'applicationTaskExecutor'

 

 

[참조]  https://engkimbs.tistory.com/718