夜光 带你走进设计模式（二十一）

夜光序言：

你知道灵魂伴侣的意思吗？

就是，遇见她后，你飘荡的灵魂便找到了归宿。

失去她后，你的灵魂便失去了归宿，却不再会不安了。

正文：观察者模式

夜光：当对象间存在一对多关系时，则使用观察者模式（Observer Pattern）。

比如，当一个对象被修改时，则会自动通知它的依赖对象。

观察者模式属于行为型模式。

夜光： 

1、JAVA 中已经有了对观察者模式的支持类。

2、避免循环引用。

3、如果顺序执行，某一观察者错误会导致系统卡壳，一般采用异步方式。

夜光：实现

观察者模式使用三个类 Subject、Observer 和 Client。Subject 对象带有绑定观察者到 Client 对象和从 Client 对象解绑观察者的方法。我们创建 Subject 类、Observer 抽象类和扩展了抽象类 Observer 的实体类。

ObserverPatternDemo，我们的演示类使用 Subject 和实体类对象来演示观察者模式。

//步骤 1
//创建 Subject 类。//Subject.javaimport java.util.ArrayList;
import java.util.List;public class Subject {private List observers = new ArrayList();private int state;public int getState() {return state;}public void setState(int state) {this.state = state;notifyAllObservers();}public void attach(Observer observer){observers.add(observer);      }public void notifyAllObservers(){for (Observer observer : observers) {observer.update();}}  
}//步骤 2
//创建 Observer 类。//Observer.javapublic abstract class Observer {protected Subject subject;public abstract void update();
}//步骤 3
//创建实体观察者类。//BinaryObserver.javapublic class BinaryObserver extends Observer{public BinaryObserver(Subject subject){this.subject = subject;this.subject.attach(this);}@Overridepublic void update() {System.out.println( "Binary String: " + Integer.toBinaryString( subject.getState() ) ); }
}//OctalObserver.javapublic class OctalObserver extends Observer{public OctalObserver(Subject subject){this.subject = subject;this.subject.attach(this);}@Overridepublic void update() {System.out.println( "Octal String: " + Integer.toOctalString( subject.getState() ) ); }
}//HexaObserver.javapublic class HexaObserver extends Observer{public HexaObserver(Subject subject){this.subject = subject;this.subject.attach(this);}@Overridepublic void update() {System.out.println( "Hex String: " + Integer.toHexString( subject.getState() ).toUpperCase() ); }
}//步骤 4
//使用 Subject 和实体观察者对象。//ObserverPatternDemo.javapublic class ObserverPatternDemo {public static void main(String[] args) {Subject subject = new Subject();new HexaObserver(subject);new OctalObserver(subject);new BinaryObserver(subject);System.out.println("First state change: 15");   subject.setState(15);System.out.println("Second state change: 10");  subject.setState(10);}
}//步骤 5
//执行程序，输出结果：First state change: 15
Hex String: F
Octal String: 17
Binary String: 1111
Second state change: 10
Hex String: A
Octal String: 12
Binary String: 1010

//观察者模式，我理解的就是观察者订阅被观察者的状态
//当被观察者状态改变的时候会通知所有订阅的观察者的过程。//观察者接口：public abstract class Observer {    public abstract void update(String msg);
}//第一个观察者：public class F_Observer extends Observer {public void update(String msg) {System.out.println(F_Observer.class.getName() + " : " + msg);}
}//第二个观察者：public class S_Observer extends Observer {public void update(String msg) {System.out.println(S_Observer.class.getName() + " : " + msg);}
}//第三个观察者：public class T_Observer extends Observer {public void update(String msg) {System.out.println(T_Observer.class.getName() + " : " + msg);}
}//被观察者：public class Subject {        private List observers = new ArrayList<>();    //状态改变    public void setMsg(String msg) {        notifyAll(msg);    }   //订阅    public void addAttach(Observer observer) {        observers.add(observer);    }    //通知所有订阅的观察者    private void notifyAll(String msg) {        for (Observer observer : observers) {            observer.update(msg);        }   }
}//使用方法：public class Main {    public static void main(String[] args) {        F_Observer fObserver = new F_Observer();        S_Observer sObserver = new S_Observer();        T_Observer tObserver = new T_Observer();                Subject subject = new Subject();        subject.addAttach(fObserver);        subject.addAttach(sObserver);        subject.addAttach(tObserver);                subject.setMsg("msg change");    }
} //运行结果： test.F_Observer : msg changetest.S_Observer : msg changetest.T_Observer : msg change

本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场，不承担相关法律责任。如若转载，请注明出处。 如若内容造成侵权/违法违规/事实不符，请点击【内容举报】进行投诉反馈！