[Design Pattern] 옵저버 패턴

옵저버 패턴

---

옵저버 패턴은 흔히 출판사-구독자의 관계로 설명된다.

예를 들어, A출판사에서 발행하는 신문기사가 아주 유용하다치자, A출판사에서 발행하는 신문을 받아볼려면 구독을 해야겠지?

그러면 정기적으로 A출판사가 발행하는 신문기사를 받아볼 수 있게 된다.

 

위의 내용에서 A출판사는 어떤 데이터의 갱신 또는 생성과 같은 이벤트가 발생하면 구독자에게 전달하는 객체.

구독자는 어떤 데이터의 갱신 또는 생성과 같은 이벤트가 발생했음을 A출판사로부터 알림받는 객체.

 

 

옵저버 패턴을 구현하는 방법은 여러 가지가 있지만, 일반적으로 Subject 인터페이스, Observer 인터페이스가 들어있는 클래스 디자인을 바탕으로 한다.

 

Entry 포인터를 잡고

public class Main {
 
    public static void main(String[] args) {
        System.out.println("Enter Text >");
 
        // 이벤트 발행 주체를 생성함 - stdin으로부터 문자열을 입력받음
        final EventSource evSrc = new EventSource();
 
        // 옵저버를 생성함
        final ResponseHandler respHandler = new ResponseHandler();
 
        // 옵저버가 발행 주체가 발행하는 이벤트를 구독하게 함
        evSrc.addObserver(respHandler);
 
        // 이벤트를 발행시키는 쓰레드 시작
        Thread thread = new Thread(evSrc);
        thread.start();
    }
}

 

A출판사에 해당하는 Subject 객체

public class EventSource extends Observable implements Runnable {
 
    @Override
    public void run() {
        try {
            final InputStreamReader isr = new InputStreamReader(System.in);
            final BufferedReader br = new BufferedReader(isr);
            while (true) {
                final String response = br.readLine();
                setChanged();
                notifyObservers(response);
            }
        }
        catch (IOException e) {
            e.printStackTrace();
        }
    }
}

 

구독자에 해당하는 Observer 객체

public class ResponseHandler implements Observer {
 
    private String resp;
 
    public void update (Observable obj, Object arg) {
        if (arg instanceof String) {
            resp = (String) arg;
            System.out.println("\nReceived Response: "+ resp );
        }
    }
}