【图解设计模式】Observer模式

Posted on | In

当观察对象的状态发生变化时，会通知给观察者。适用于根据对象状态进行相应处理的场景。

示例

观察者将观察一个会生成数值的对象，并将它生成的数值结果显示出来。不同的观察者的显示方式不一样。

类图

mcgmIe.png

Observer接口

1
2
3
public interface Observer {
    public abstract void update(NumberGenerator generator);
}

NumberGenerator类

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
import java.util.ArrayList;
import java.util.Iterator;

public abstract class NumberGenerator {
    private ArrayList observers = new ArrayList();

    public void addObserver(Observer observer) {
        observers.add(observer);
    }

    public void deleteObserver(Observer observer) {
        observers.remove(observer);
    }

    public void notifyObservers() {
        Iterator it = observers.iterator();

        while (it.hasNext()) {
            Observer o = (Observer) it.next();
            o.update(this);
        }
    }

    public abstract int getNumber();
    public abstract void execute();
}

RandomNumberGenerator类

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
import java.util.Random;

public class RandomNumberGenerator extends NumberGenerator {
    private Random random = new Random();
    private int number;

    @Override
    public int getNumber() {
        return number;
    }

    @Override
    public void execute() {
        for (int i = 0; i < 20; i++) {
            number = random.nextInt(50);
            notifyObservers();
        }
    }
}

DigitObserver类

1
2
3
4
5
6
7
8
9
10
11
public class DigitObserver implements Observer {
    @Override
    public void update(NumberGenerator generator) {
        System.out.println("DigitObserver:" + generator.getNumber());

        try {
            Thread.sleep(100);
        } catch (InterruptedException e) {
        }
    }
}

GraphObserver类

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
public class GraphObserver implements Observer {
    @Override
    public void update(NumberGenerator generator) {
        System.out.print("GraphObserver:");

        for (int i = 0; i < generator.getNumber(); i++)
            System.out.print("*");

        System.out.println("");

        try {
            Thread.sleep(100);
        } catch (InterruptedException e) {
        }
    }
}

Main类

1
2
3
4
5
6
7
8
9
10
11
public class Main {

    public static void main(String[] args) {
        NumberGenerator generator = new RandomNumberGenerator();
        Observer observer1 = new DigitObserver();
        Observer observer2 = new GraphObserver();
        generator.addObserver(observer1);
        generator.addObserver(observer2);
        generator.execute();
    }
}

运行结果

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
DigitObserver:14
GraphObserver:**************
DigitObserver:43
GraphObserver:*******************************************
DigitObserver:21
GraphObserver:*********************
DigitObserver:33
GraphObserver:*********************************
DigitObserver:36
GraphObserver:************************************
DigitObserver:43
GraphObserver:*******************************************
DigitObserver:19
GraphObserver:*******************
DigitObserver:32
GraphObserver:********************************
DigitObserver:33
GraphObserver:*********************************
DigitObserver:5
GraphObserver:*****
DigitObserver:20
GraphObserver:********************
DigitObserver:13
GraphObserver:*************
DigitObserver:30
GraphObserver:******************************
DigitObserver:28
GraphObserver:****************************
DigitObserver:9
GraphObserver:*********
DigitObserver:22
GraphObserver:**********************
DigitObserver:26
GraphObserver:**************************
DigitObserver:34
GraphObserver:**********************************
DigitObserver:7
GraphObserver:*******
DigitObserver:42
GraphObserver:******************************************

登场角色

Subject（观察对象）

Subject角色表示观察对象。Subject角色定义了注册观察者和删除观察者的方法。此外，它还声明了“获取现在的状态”的方法。在示例程序中，由NumberGenerator类扮演此角色。

ConcreteSubject（具体的观察对象）

ConcreteSubject角色表示具体的被观察对象。当自身状态发生变化后，它会通知所有已经注册的Observer角色。在示例程序中，由RandomNumberGenerator类扮演此角色。

Observer（观察者）

Observer角色负责接收来自Subject角色的状态变化的通知。为此，它声明了update方法。在示例程序中，由Observer接口扮演此角色。

ConcreteObserver（具体的观察者）

ConcreteObserver角色表示具体的Observer。当它的update方法被调用后，会去获取要观察的对象的最新状态。在示例程序中，由DigitObserver类和GraphObserver类扮演此角色。

类图

mgkirj.png