一位面试官问我:
什么是观察者和可观察对象，什么时候应该使用它们?
我不知道这些术语，所以当我回到家，开始在谷歌上搜索关于观察者和Observable的信息时，我从不同的资源中找到了一些观点:
1) Observable是一个类，Observer是一个接口。
2) Observable类维护了一个观察者列表。
3)当一个Observable对象被更新时，它会调用它的每个观察者的update()方法来通知它被更改了。
我找到了这个例子:
import java.util.Observable;
import java.util.Observer;
class MessageBoard extends Observable
{
public void changeMessage(String message)
{
setChanged();
notifyObservers(message);
}
}
class Student implements Observer
{
@Override
public void update(Observable o, Object arg)
{
System.out.println("Message board changed: " + arg);
}
}
public class MessageBoardTest
{
public static void main(String[] args)
{
MessageBoard board = new MessageBoard();
Student bob = new Student();
Student joe = new Student();
board.addObserver(bob);
board.addObserver(joe);
board.changeMessage("More Homework!");
}
}
但我不明白为什么我们需要观察者和可观察对象?setChanged()和notifyObservers(message)方法是干什么用的?
定义
观察者模式用于对象之间存在一对多的关系时，例如如果一个对象被修改，它的依赖对象将被自动通知，并对所有依赖对象进行相应的更改。
例子
比方说，你的永久地址改变了，那么你需要通知护照当局和pan卡当局。所以这里护照当局和泛卡当局是观察者，而你是受试者。
在Facebook上也一样，如果你订阅了某个人，那么无论何时有新的更新发生，你都会收到通知。
何时使用:
当一个对象改变其状态时，所有其他依赖对象必须自动改变其状态以保持一致性
当对象不知道它有多少观察者时。
当一个对象应该能够通知其他对象而不知道对象是谁时。
步骤1
创建Subject类。
Subject.java
import java.util.ArrayList;
import java.util.List;
public class Subject {
private List<Observer> observers
= new ArrayList<Observer>();
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.java
public abstract class Observer {
protected Subject subject;
public abstract void update();
}
步骤3
创建具体的观察者类
BinaryObserver.java
public class BinaryObserver extends Observer{
public BinaryObserver(Subject subject){
this.subject = subject;
this.subject.attach(this);
}
@Override
public void update() {
System.out.println( "Binary String: "
+ Integer.toBinaryString( subject.getState() ) );
}
}
OctalObserver.java
public class OctalObserver extends Observer{
public OctalObserver(Subject subject){
this.subject = subject;
this.subject.attach(this);
}
@Override
public void update() {
System.out.println( "Octal String: "
+ Integer.toOctalString( subject.getState() ) );
}
}
HexaObserver.java
public class HexaObserver extends Observer{
public HexaObserver(Subject subject){
this.subject = subject;
this.subject.attach(this);
}
@Override
public void update() {
System.out.println( "Hex String: "
+ Integer.toHexString( subject.getState() ).toUpperCase() );
}
}
步骤4
使用Subject和具体的观察者对象。
ObserverPatternDemo.java
public 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
验证输出。
第一个状态变化:15
十六进制字符串:F
八进制字符串:17
二进制字符串:1111
第二状态变化:10
十六进制字符串:A
八进制字符串:12
二进制字符串:1010
如果面试官要求在不使用观察者类和接口的情况下实现观察者设计模式，您可以使用下面的简单示例!
MyObserver作为观察者接口
interface MyObserver {
void update(MyObservable o, Object arg);
}
MyObservable作为Observable类
class MyObservable
{
ArrayList<MyObserver> myObserverList = new ArrayList<MyObserver>();
boolean changeFlag = false;
public void notifyObservers(Object o)
{
if (hasChanged())
{
for(MyObserver mo : myObserverList) {
mo.update(this, o);
}
clearChanged();
}
}
public void addObserver(MyObserver o) {
myObserverList.add(o);
}
public void setChanged() {
changeFlag = true;
}
public boolean hasChanged() {
return changeFlag;
}
protected void clearChanged() {
changeFlag = false;
}
// ...
}
你的MyObserver和MyObservable的例子!
class MessageBoard extends MyObservable {
private String message;
public String getMessage() {
return message;
}
public void changeMessage(String message) {
this.message = message;
setChanged();
notifyObservers(message);
}
public static void main(String[] args) {
MessageBoard board = new MessageBoard();
Student bob = new Student();
Student joe = new Student();
board.addObserver(bob);
board.addObserver(joe);
board.changeMessage("More Homework!");
}
}
class Student implements MyObserver {
@Override
public void update(MyObservable o, Object arg) {
System.out.println("Message board changed: " + arg);
}
}
