设计模式-观察者模式

Posted on

0x00 观察者模式

也可称发布订阅模式(Publish/Subscribe).

定义

Define a one-to-many dependency between objets so that when one object changes state, all its dependents are notified and updated automatically.(定义对象间一对多的依赖关系，使得每当一个对象改变状态，则所有依赖于它的对象都会得到通知并自动更新．)

角色

  • Subject 被观察者, 必须能够动态地增加和取消观察者，起到观察观察者并通知观察者的职责.
  • Observer 观察者, 观察者接受到消息通知后，进行更新．
  • ConcreteSubject 具体被观察者, 定义被观察者自已的业务逻辑，同时定义对哪些事件进行通知．
  • ConcreteObserver 具体观察者, 每个具体观察者自己的处理逻辑．

优点

  • 抽象耦合观察者和被观察者之间的关系, 使之易于扩展．
  • 建立一套触发机制．

缺点

多级触发时，效率变差．

php 实现

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
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
<?php
/*
 * observer pattern
 */

//被观察者
abstract class Subject {
    private $observers = [];
    public function addObserver(Observer $_observer)
    {
        array_push($this->observers, $_observer);
    }

    public function delObserver(Observer $_observer)
    {
        $key = array_search($this->observers, $_observer);
        if ($key !== false) {
            array_splice($this->observers, $key, 1);
        }
    }

    // 通知所有观察者
    public function notifyObservers()
    {
        foreach($this->observers as $observer) {
            $observer->update();
        }
    }
}


// 具体被观察者
class ConcreteSubjects extends Subject {
    public function doSth()
    {
        parent::notifyObservers();
    }
}

// 观察者接口
interface Observer {
    public function update();
}


class ConcreteObserver implements Observer {
    public function update()
    {
        echo "Get it!Yes!Sir!";
    }
}

class Client {
    public static function main()
    {
        $subject = new ConcreteSubjects();
        $observers = new ConcreteObserver();
        $subject->addObserver($observers);
        $subject->doSth();
    }
}
(new Client())::main();

用武之地

  • 可拆分的非组合的关联行为场景.
  • 事件多级出发场景．
  • 跨系统的消息交换场景，如消息队列的处理机制．

0x01 小结

观察者模式需要重点解决两个问题:

  • 广播链, 在一个观察者模式中，最多出现一个对象既是观察者也是被观察者，即消息最多转发一次(转发两次)是比较恰当的好控制的．
  • 异步处理, 需要考虑线程安全和队列．