java实现观察者（Observer）模式

观察者模式：

 

将观察者与被观察着的对象分离，在模块之间进行区分，提高了程序的重用性、可维护性。

 

用代码实现时，观察者与被观察者之间的关系不能是直接调用，而应该是一种 注册 与 回调 的形式。

观察者实现一个接口，被观察者保存注册过的观察者的信息，当发生变化时，通过多态回调观察者的接口方法。

 

package Test;

 

import java.util.HashSet;

public class ObserverTry { public static void main(String[] args){  Index i = new Index("数据指数",150);  Observer o1 = new AObserver();  Observer o2 = new BObserver();  i.addObserver(o1);  //注册观察者  i.addObserver(o2);  System.out.println(" Count Up! ");  i.setCount(180);  o1.remove(i);  //观察者o1取消观察  System.out.println(" Count Down! ");  i.setCount(120); }}

interface Observer{ public void update(Index i); //更新index public void remove(Index i); //撤销注册}

class AObserver implements Observer{ public void update(Index i){  System.out.println("A  Name： " + i.getName() + "  Count： " + i.getCount()); } public void remove(Index i){  i.getObservers().remove(this); }}

class BObserver implements Observer{ public void update(Index i){  System.out.println("B  Name： " + i.getName() + "  Count： " + i.getCount()); } public void remove(Index i){  i.getObservers().remove(this); }}

class Index{ private String name; private int count; private HashSet<Observer> observers; //保存所有的观察者  public Index(String name,int count){  this.name = name;  this.count = count;  observers = new HashSet<Observer>(); }  public void addObserver(Observer ob){  observers.add(ob); //添加观察者 }  public void notifyObserver(){  for(Observer ob:observers){   ob.update(this); //回调所有观察者的update方法  } }  public String getName() {  return name; }

 public void setName(String name) {  this.name = name; }

 public int getCount() {  return count; }

 public void setCount(int count) {  this.count = count;  notifyObserver();  //当count改变时，通知观察者 }  public HashSet<Observer> getObservers() {  return observers; }

 public void setObservers(HashSet<Observer> observers) {  this.observers = observers; }}