Observer

한 객체의 상태가 바뀌면 그 객체에 의존하는 다른 객체들에게 연락이 가고 자동으로 내용이 갱신된다.
일대다(One-to-Many) 의존성을 정의한다.

external-content duckduckgo [출처 : 위키피디아]

하나의 주제 객체와 주제 객체에 의존하고있는 옵저버 인터페이스. 옵저버 인터페이스를 구현한 여러개의 옵저버 객체로 구성된다.

observerPattern observer2

자바 내장 옵저버

내장 Observable는 JAVA9 이후로 Deprecated되었다.

java.util.Observer 인터페이스와 java.util.Observable클래스를 사용할 수 있다.
push/pull방식 모두 사용 가능.

java.util.Observer 인터페이스를 구현하고 java.util.Observable객체의 addObserver()메소드를 호출하면 옵저버 목록에 추가되고 deleteObserver()를 호출하면 옵저버 목록에서 제거된다.

연락돌리는 방법
java.util.Observable를 상속받는 주제 클래스에서 setChanged()메소드를 호출해서 객체의 상태가 바뀌었다는 것을 알린 후 notifyObserver(Object arg) (push방식) 또는 notifyObservers()메소드를 호출하면 된다.
옵저버 객체가 연락을 받는 방법
update(Observable o, Object arg)메소드를 구현하기만 하면된다.
Observable o = 연락을 보내는 주제 객체가 인자로 전달 Object arg = notifyObservers(Object arg) 메소드에서 인자로 전달된 데이터 객체가 넘어온다.

package case1;

import java.util.Observable;

//감시의 대상
public class PlayController extends Observable{
	
	private boolean bPlay; //실행 여부
	
	public PlayController() {
		
	}
	
	//데이터를 전달 받아 플래그 값을 변경하고,
	//새로운 데이터가 들어왔음을 알린다.
	public void setFlag(boolean bPlay) {
		this.bPlay = bPlay;
		setChanged();
		notifyObservers();
		//Observerable 안에 모두 구현되어있기 때문에 메서도 호출만 해주면 된다.
	}
	
	//실행여부 플래그 값 반환
	public boolean getFlag() {
		return bPlay;
	}
}

package case1;

import java.util.Observable;
import java.util.Observer; //The type Observer is deprecated since version 9


public class MyClassA implements Observer{
	
	Observable observable; //등록될 Observable
	private boolean bPlay; //실행여부
	
	public MyClassA(Observable o) {
		this.observable = o;
		Observable.addObserver(this);	//옵저버에 현재 클래스 등록
	}
	
	@Override
	public void update(Observable o, Object arg) {
		if (o instanceof PlayController) {
			PlayController myControl = (PlayController)o;
			this.bPlay = myControl.getFlag();
			myActControl();
		}
		
	}
	
	public void myActControl() {
		if(bPlay) {
			System.out.println("MyClassA : 동작을 시작합니다");
		}else {
			System.out.println("MyClassA : 동작을 정지합니다");
		}
	}

}

package case1;

import java.util.Observable;
import java.util.Observer; //The type Observer is deprecated since version 9


public class MyClassB implements Observer{
	
	Observable observable; //등록될 Observable
	private boolean bPlay; //실행여부
	
	public MyClassB(Observable o) {
		this.observable = o;
		Observable.addObserver(this);	//옵저버에 현재 클래스 등록
	}
	
	@Override
	public void update(Observable o, Object arg) {
		if (o instanceof PlayController) {
			PlayController myControl = (PlayController)o;
			this.bPlay = myControl.getFlag();
			myActControl();
		}
		
	}
	
	public void myActControl() {
		if(bPlay) {
			System.out.println("MyClassB : 동작을 시작합니다");
		}else {
			System.out.println("MyClassB : 동작을 정지합니다");
			observable.deleteObserver(this); //옵저버를 삭제 (이후 옵저버 연락을 받지 못하게된다.)
		}
	}

}

package case1;

public class TestPattern {

	public static void main(String[] args) {
		
		PlayController controller = new PlayController();

		MyClassA a = new MyClassA(controller);
		MyClassB b = new MyClassB(controller);
		
		System.out.println("-----모든 클래스 일시 정지---");
		controller.setFlag(false);
		
		System.out.println();
		System.out.println("-----모든 클래스 다시 시작---");
		controller.setFlag(true);
		
		System.out.println();
	}

}

자바 내장 옵저버 패턴의 단점과 한계

Observable은 클래스다.
- Observable이 클래스기 떄문에 서브클래스를 만들어야 한다. 이미 다른 수퍼클래스를 확장하고 있는 클래스에 Observable의 기능을 추가할 수 없기 때문이다. ➜ 재사용성에 제약이 생긴다.
Observable 클래스의 핵심 메소드를 외부에서 호출할 수 없다.
- Observable 의 setChanged()메소드가 protected로 선언되어 있다. Observable 의 서브클래스에서만 setChanged()를 호출할 수 있다. 직접 어떤 클래스를 만들고, Observable 의 서브클래스를 인스턴스 변수로 사용하는 방법도 쓸 수 없다. ➜ 디자인은 상속보다는 구성을 사용한다는 디자인 원칙에도 위배된다.

내장 Observable는 JAVA9 이후로 Deprecated되었다.

옵저버 패턴 직접 구현

package case2.step1;

public interface Observer {
	public void update(boolean play);
}

package case2.step1;


public class MyClassA implements Observer{
	
	private boolean bPlay; //실행여부
	
	@Override
	public void update(boolean play) {
		this.bPlay = play;
		myActControl();
	}
	
	public void myActControl() {
		if(bPlay) {
			System.out.println("MyClassA : 동작을 시작합니다");
		}else {
			System.out.println("MyClassA : 동작을 정지합니다");
		}
	}
}

package case2.step1;


public class MyClassB implements Observer{
	
	private boolean bPlay; //실행여부
	
	@Override
	public void update(boolean play) {
		this.bPlay = play;
		myActControl();
	}
	
	public void myActControl() {
		if(bPlay) {
			System.out.println("MyClassB : 동작을 시작합니다");
		}else {
			System.out.println("MyClassB : 동작을 정지합니다");
		}
	}

}

package case2.step1;

public interface Publisher {
	
	public void addObserver(Observer o);
	public void deleteObserver(Observer o);
	public void notifyObservers();

}

package case2.step1;

import java.util.ArrayList;
import java.util.List;


//감시의 대상
public class PlayController implements Publisher{
	
	private List<Observer> observers = new ArrayList<>();
	private boolean play;

	@Override
	public void addObserver(Observer observer) {
		observers.add(observer);
		
	}

	@Override
	public void deleteObserver(Observer observer) {
		int index = observers.indexOf(observer);
		observers.remove(index);
		
	}

	@Override
	public void notifyObservers() {
		for(Observer observer : observers) {
			observer.update(play);
		}
		
	}
	
	public void setFlag(boolean play) {
		this.play = play;
		notifyObservers();
	}
	
	public boolean getFlag() {
		return play;
	}
	
}

package case2.step1;

public class TestPattern {

	public static void main(String[] args) {
		
		PlayController pager = new PlayController();
		Observer ob1 = new MyClassA();
		Observer ob2 = new MyClassB();

		//옵저버 등록
		pager.addObserver(ob1);
		pager.addObserver(ob2);
		
		//메시지 등록
		pager.setFlag(false);
		
		//옵저버 해지
		pager.deleteObserver(ob2);

		System.out.println("---------------");
		//메시지 등록
		pager.setFlag(true);
	}

}

좀더 약한 연결로 구현

package case2.step2;

public interface Observer {
	public void update(boolean play);
}

package case2.step2;


public class MyClassA implements Observer{
	
	Publisher observable; //등록될 Observable
	private boolean bPlay; //실행여부
	
	//생성될 때 직접 자기 자신을 옵저버에 등록한다.
	public MyClassA(Publisher o) {
		this.observable = o;
		observable.addObserver(this);
	}
	
	@Override
	public void update(boolean play) {
		this.bPlay = play;
		myActControl();
	}
	
	public void myActControl() {
		if(bPlay) {
			System.out.println("MyClassA : 동작을 시작합니다");
		}else {
			System.out.println("MyClassA : 동작을 정지합니다");
		}
	}
}

package case2.step2;


public class MyClassB implements Observer{
	
	Publisher observable; //등록될 Observable
	private boolean bPlay; //실행여부
	
	//생성될 때 직접 자기 자신을 옵저버에 등록한다.
	public MyClassB(Publisher o) {
		this.observable = o;
		observable.addObserver(this);
	}
	
	
	@Override
	public void update(boolean play) {
		this.bPlay = play;
		myActControl();
	}
	
	public void myActControl() {
		if(bPlay) {
			System.out.println("MyClassB : 동작을 시작합니다");
		}else {
			System.out.println("MyClassB : 동작을 정지합니다");
			observable.deleteObserver(this); //옵저버를 삭제 (이후 옵저버 연락을 받지 못하게된다.)
		}
	}

}

package case2.step2;

public interface Publisher {
	
	public void addObserver(Observer o);
	public void deleteObserver(Observer o);
	public void notifyObservers();

}

package case2.step2;

import java.util.ArrayList;
import java.util.List;


//감시의 대상
public class PlayController implements Publisher{
	
	private List<Observer> observers = new ArrayList<>();
	private boolean play;

	@Override
	public void addObserver(Observer observer) {
		observers.add(observer);
		
	}

	@Override
	public void deleteObserver(Observer observer) {
		int index = observers.indexOf(observer);
		observers.remove(index);
		
	}

	@Override
	public void notifyObservers() {
		for (int i =0; i<observers.size(); i++) {
			observers.get(i).update(play);
		}
		
	}
	
	public void setFlag(boolean play) {
		this.play = play;
		notifyObservers();
	}
	
	public boolean getFlag() {
		return play;
	}
	
}

package case2.step2;

public class TestPattern {

	public static void main(String[] args) {
		
		PlayController controller = new PlayController();
		Observer ob1 = new MyClassA(controller);
		Observer ob2 = new MyClassB(controller);

		System.out.println("------모든 클래스 일시정지---------");
		
		//메시지 등록
		controller.setFlag(false);
		

		System.out.println("-----모든 클래스 다시시작----------");
		//메시지 등록
		controller.setFlag(true);
	}

}


//실행결과
/*
------모든 클래스 일시정지---------
MyClassA : 동작을 정지합니다
MyClassB : 동작을 정지합니다
-----모든 클래스 다시시작----------
MyClassA : 동작을 시작합니다


*/

옵저버 패턴이 사용되는 곳

Android의 View나 Button등의 위젯의 각종 이벤트를 받을 때 쓰인다.

버튼은 항상 클릭이라는 이벤트가 있으며 이 이벤트는 OnClickListener라는 인터페이스로 구성되어있다. 즉 버튼이라는 객체가 Publisher가 되고 OnClickListener가 Observer가 된다고 볼 수 있다.
버튼에서 상태가 변경(클릭 될 경우)된다면 OnClickListener로 알려준다.

Button b = (Button)findViewById(xx);
b.setOnClickListener(new OnClickListener() {
	@Override
	public void onClick(...) {
	//Action
	}
});

reference

인프런 강의 : 디자인패턴withJAVA

디자인패턴5 Observer