一个简单的观察者模式

使用 JDK 自带的 观察者模式

被观察者类，需要继承 Observable 类

import java.util.Observable;

/**
 * Created by sean on 2017/11/23 9:28.
 * 这是一个继承了Observable的观察者模式，改类为被观察者
 */
public class LoginWithJDK extends Observable {

	public static void main(String[] args) {
		LoginWithJDK loginWithJDK = new LoginWithJDK();
	    ObserverWithJDK(loginWithJDK);

		loginWithJDK.loginSuccess();

	}

	public void loginSuccess(){
		System.out.println("登录成功，通知观察者...");

		//下面两个为父类的方法
		setChanged();
		notifyObservers();
	}
}
​

观察者类，需要先实现 Observer 接口，并重写 update()方法

import java.util.Observable;
import java.util.Observer;

/**
 * Created by sean on 2017/11/23 9:31.
 * 改类为观察者类，当被观察者发生变化时调用update方法
 */
public class ObserverWithJDK implements Observer{

	public ObserverWithJDK(LoginWithJDK loginWithJDK){
		loginWithJDK.addObserver(this);
	}

	@Override
	public void update(Observable o, Object arg) {
		System.out.println("被观察者的方法被触发");
	}
}
​

接口 Observer 的源码

​

public interface ObserverInterface {

	void onSuccess(Object object);
}
​

public class ObserverOriginal implements ObserverInterface{

	public ObserverOriginal(LoginOriginal loginOriginal){
		loginOriginal.addObject(this);
	}

	@Override
	public void onSuccess(Object object) {
		System.out.println("登录成功，通知观察者...");
	}
}
​

public class LoginOriginal{

	private List<ObserverInterface> loginInterfaces = new ArrayList<>();

	public void addObject(ObserverInterface addObject){
		loginInterfaces.add(addObject);
	}

	private void loginSuccess(){
		for (ObserverInterface loginInterface : loginInterfaces) {
			loginInterface.onSuccess(this);
		}
	}

	public static void main(String[] args) {
		LoginOriginal loginOriginal = new LoginOriginal();
		new ObserverOriginal(loginOriginal);
		loginOriginal.loginSuccess();
	}
}
​