该模式定义了一个一对多的关系，一个被观察对象与一群观察对象存在依赖关系，一旦这个被观察对象有什么风吹草动，其他的观察者就都能收到通知。其实本质是被观察对象通知所有观察者对象。
软件系统很多时候需要这样的情况，一旦发生故障，就通知对应的系统或模块，使之能够及时处理。
观察者类图结构
- 抽象主题 Subject：提供添加和减少观察者方法和通知观察者方法；
- 具体主题 ConcreteSubject：对抽象主题的实现，包含一个观察者的集合[这里是接口哦，我们是针对接口编程的]，用以操作与观察者之间的互动；
- 抽象观察者 Observer：提供被主题调用的方法，一旦主题变动，就调用这个方法；
- 具体观察者 ConcreteObserver：对抽象观察者的抽象调用方法进行实现。
有了上面的类图，很快就把代码切出来：
public interface Subject {
public void attach(Observer observer);
public void detach(Observer observer);
public void notifyObservers();
}
以上就是抽象主题的基本代码，大抵上可以完成任务了
public interface Observer {
public void update();
}
抽象观察者，这里简化，只有一个公开方法被主题调用
接下来把具体的主题构造出来，如下所示
import java.util.ArrayList;
import java.util.List;
public class ConcreteSubject implements Subject{
//装载所有观察者的容器
private List<Observer> observers=null;
//构造方法里面初始化容器
public ConcreteSubject() {
observers=new ArrayList<Observer>();
}
@Override
public void attach(Observer observer) {
if(!observers.contains(observer)){
observers.add(observer);
}
}
@Override
public void detach(Observer observer) {
if(observers.contains(observer)){
observers.remove(observer);
}
}
@Override
public void notifyObservers() {
for(Observer observer:observers){
observer.update();
}
}
}
其主要任务就是绑定和解绑观察者，以及有事通知观察者，当然可以对观察者进行分类，根据分类再进行通知。
最后是具体的观察者，主要工作代码如下
public class ConcreteObserver implements Observer{
private String name;
public ConcreteObserver(String name) {
this.name=name;
}
@Override
public void update() {
System.out.println(this.name+"被调用了，在时间："+new Date());
}
}
运行下来看看
public class Client {
public static void main(String[] args) {
Observer o1=new ConcreteObserver("张三");
Observer o2=new ConcreteObserver("李四");
Subject subject=new ConcreteSubject();
subject.attach(o1);
subject.attach(o2);
subject.notifyObservers();
subject.detach(o2);
subject.notifyObservers();
}
}
非常完美的实现了主题通知观察者。需要注意的是，在具体主题里面的集合容器最好不要使得外界可以修改，以及线程安全方面需要考虑。
另外一种方式把主题作为抽象类，然后关联到抽象观察者，而具体主题负责把状态改变后，调用抽象的通知方法；
来段代码实际情况看看；
import java.util.ArrayList;
import java.util.List;
public abstract class AbstractSubject {
// 装载所有观察者的容器
private List<Observer> observers = null;
// 构造方法里面初始化容器
public AbstractSubject() {
observers = new ArrayList<Observer>();
}
public void attach(Observer observer) {
if (!observers.contains(observer)) {
observers.add(observer);
}
}
public void detach(Observer observer) {
if (observers.contains(observer)) {
observers.remove(observer);
}
}
public void notifyObservers() {
for (Observer observer : observers) {
observer.update();
}
}
//具体主题务必实现这个方法
protected String state;
public abstract void change(String newState);
}
这个抽象主题比较能干，把子类要做到事多包揽了，子类的工作就轻松多了，来看下
public class ConcreteSubject2 extends AbstractSubject{
@Override
public void change(String newState) {
this.state=newState;
System.out.println("当前主题状态修改为"+this.state);
notifyObservers();
}
}
具体主题就实现了一个方法，顿时轻松，观察者和上面一样，来看下客户端怎么使用
public class Client {
public static void main(String[] args) {
Observer o1=new ConcreteObserver("张三");
Observer o2=new ConcreteObserver("李四");
// Subject subject=new ConcreteSubject();
// subject.attach(o1);
// subject.attach(o2);
// subject.notifyObservers();
// subject.detach(o2);
// subject.notifyObservers();
AbstractSubject subject=new ConcreteSubject2();
subject.attach(o1);
subject.attach(o2);
subject.change("A");
subject.detach(o2);
subject.change("B");
}
}
JDK 自带了观察者模式的一些基本类，可以使用，但最好还是自己造一个更方便，里面的源码可以借鉴看看，考虑的很详细。
网友评论