设计模式-观察者模式

Posted on | In
Words count in article: 453 | Reading time ≈ 2

观察者模式

定义

中介者模式（Mediator Pattern）是用来降低多个对象和类之间的通信复杂性。这种模式提供了一个中介类，该类通常处理不同类之间的通信，并支持松耦合，使代码易于维护。

类图

观察者模式类图

Subject

表示观察对象。定义了注册观察者和删除观察者的方法。此外，还声明了“获取现在状态”的方法。

ConcreteSubject

表示具体的被观察对象。当自身状态发生变化后，它会通知所有已经注册的Observer角色

Observer（观察者）

负责接收来自Subject的状态变化通知。为此，它声明了update方法

ConcreteObserver（具体的观察者）

表示具体的Observer。当他的update方法被调用后，会去获取要观察的对象的最新的状态。

示例

类图

观察者模式示例类图

DigitObserver

1
2
3
4
5
6
7
8
9
public class DigitObserver implements Observer {
    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
public class GraphObserver implements Observer {
    public void update(NumberGenerator generator) {
        System.out.print("GraphObserver:");
        int count = generator.getNumber();
        for (int i = 0; i < count; i++) {
            System.out.print("*");
        }
        System.out.println("");
        try {
            Thread.sleep(100);
        } catch (InterruptedException e) {
        }
    }
}

NumberGenerator

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
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();                 
}

Observer

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

RandomNumberGenerator

1
2
3
4
5
6
7
8
9
10
11
12
13
public class RandomNumberGenerator extends NumberGenerator {
    private Random random = new Random();   
    private int number;                     
    public int getNumber() {                
        return number;
    }
    public void execute() {
        for (int i = 0; i < 20; i++) {
            number = random.nextInt(50);
            notifyObservers();
        }
    }
}

Main

1
2
3
4
5
6
7
8
9
10
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();
    }
}
0%