24 May 2020

[Java] Observer 패턴

Observer 패턴이란

옵저버 패턴은 객체의 상태 변화를 관찰하는 관찰자들,즉 옵저버들의 목록을 객체에 등록하여 상태 변화가 있을 때마다 메서드 등을 통해 객체가 직접 목록의 각 옵저버에게 통지하도록 하는 디자인 패턴이다.

주로 분산 이벤트 핸들링 시스템을 구현하는 데 사용된다.

uml-diagram-of-the-observer-pattern

구현

이 패턴의 핵심은 옵저버 또는 리스너라 불리는 하나 이상의 객체를 관찰 대상이 되는 객체에 등록한다.

그리고 각각의 옵저버들은 관찰 대상인 객체가 발생시키는 이벤트를 받아 처리한다.

Observer 패턴의 중요성

Observer 패턴은 매우 다양한 곳에서 활용 되는데 그중에서도 Reactive Programming에서 핵심 디자인 패턴으로 사용되고 있다. Reactive Programming이란 다음과 같다.

비동기적 데이터흐름을 처리하는 프로그래밍인데 모든 것을 비동기적인 데이터의 Stream으로 간주하고 Observer 디자인 패턴을 활용해서 이러한 비동기 이벤트를 처리하는 것을 말한다.

이외에도 많이 활용되고 있는 디자인 패턴이다.

옵저버 패턴 구현 예시

우리가 넷플릭스나 유튜브등에서 서비스를 신청하거나 해당 채널을 구독하게 되면

영상이나 영화가 추가 됬을때 구독자에게 알림이 간다. 그리고 우리는 전체목록을

조회할 수도 있으며 구독을 해지할 수도 있다. 이와같은 예시를 구현해보겠습니다.

인터페이스로 update함수를 구현하게 한다.

public interface Observer {
    public abstract void update();
}

구독의 대상이 되는 객체가 가져야할 공통함수를 추상클래스로 만든다.

public abstract class Observable {
    public List<Observer> list=new ArrayList<>();
    public void subscribe(Observer observer){
        list.add(observer);
    }
    public void disposable(Observer observer){
        list.remove(observer);
    }
    public void notifyObservers(){
        for(Observer o:list){
            o.update();
        }
    }
}

구독의 대상 구체 클래스 구현 -> 예시의 넷플릭스나 유튜브 채널이라 생각하자

영상이 추가될경우 구독자들에게 알림이 간다.

public class MovieStore extends Observable {
    private List<String> movies=new ArrayList<>();
    
    //새로운 영상이 추가되면 구독자들에게 통보
    public void add(String movie){
        movies.add(movie);
        notifyObservers();
    }
    
    public List<String> getMovieList(){
        return movies;
    }
}

구독자들은 Observer인터페이스를 받아 update함수를 Override한다.

구독자 Hong

public class Hong implements Observer {
    private MovieStore movieStore;

    public Hong(MovieStore movieStore){
        this.movieStore=movieStore;
    }

    @Override
    public void update() {
        System.out.println("Hong님 : "+"새로운 영화가 무비스토어에 들어왔습니다.");
    }

    public List<String> getMovieList(){
        return movieStore.getMovieList();
    }
}

구독자 Minsu

public class Minsu implements Observer{
    private MovieStore movieStore;

    public Minsu(MovieStore movieStore){
        this.movieStore=movieStore;
    }

    @Override
    public void update() {
        System.out.println("Minsu님 : "+"새로운 영화가 무비스토어에 들어왔습니다.");
    }

    public List<String> getMovieList(){
        for(String s:movieStore.getMovieList()){
            System.out.println(s);
        }
        return movieStore.getMovieList();
    }
}

메인클래스

public class Main {
    public static void main(String[] args){
        //영화를 판매하는 스토어
        MovieStore movieStore=new MovieStore();

        //새로운 영화가 들어올경우 알림을 받고싶은 사람들
        Hong hong=new Hong(movieStore);
        Minsu minsu=new Minsu(movieStore);

        //알림을 원하는 두 사람이 스토어에 구독 신청을 했다
        movieStore.subscribe(hong);
        movieStore.subscribe(minsu);

        movieStore.add("바람과 함께 사라지다");
        System.out.println("--------------------");
        movieStore.add("해리포터");
        System.out.println("--------------------");
        //민수가 알림을 받고 목록을 받아본다
        System.out.println("민수가 목록을 출력합니다");
        minsu.getMovieList();
    }
}

결과

Hong님 : 새로운 영화가 무비스토어에 들어왔습니다.
Minsu님 : 새로운 영화가 무비스토어에 들어왔습니다.
--------------------
Hong님 : 새로운 영화가 무비스토어에 들어왔습니다.
Minsu님 : 새로운 영화가 무비스토어에 들어왔습니다.
--------------------
민수가 목록을 출력합니다
바람과 함께 사라지다
해리포터

Tags:

0 comments