醉里挑灯看剑

0%

观察者模式-行为型

发表于 分类于 ，

观察者模式：定义对象间的一种一对多依赖关系，使得每当一个对象状态发生改变时，其相关依赖对象皆得到通知并被自动更新。

发生改变的对象称为观察目标，而被通知的对象称为观察者，一个观察目标可以对应多个观察者，而且这些观察者之间没有相互联系，可以根据需要增加和删除观察者，使得系统更易于扩展。

观察者模式又叫做发布-订阅（Publish/Subscribe）模式、模型-视图（Model/View）模式、源-监听器（Source/Listener）模式或从属者（Dependents）模式。

优点

观察者模式可以实现表示层和数据逻辑层的分离，并定义了稳定的消息更新传递机制，抽象了更新接口，使得可以有各种各样不同的表示层作为具体观察者角色。

观察者模式在观察目标和观察者之间建立一个抽象的耦合。

观察者模式支持广播通信。

观察者模式符合“开闭原则”的要求。

缺点

如果一个观察目标对象有很多直接和间接的观察者的话，将所有的观察者都通知到会花费很多时间。

如果在观察者和观察目标之间有循环依赖的话，观察目标会触发它们之间进行循环调用，可能导致系统崩溃。

观察者模式没有相应的机制让观察者知道所观察的目标对象是怎么发生变化的，而仅仅只是知道观察目标发生了变化。

适用

一个抽象模型有两个方面，其中一个方面依赖于另一个方面。将这些方面封装在独立的对象中使它们可以各自独立地改变和复用。

一个对象的改变将导致其他一个或多个对象也发生改变，而不知道具体有多少对象将发生改变，可以降低对象之间的耦合度。

一个对象必须通知其他对象，而并不知道这些对象是谁。

需要在系统中创建一个触发链，A对象的行为将影响B对象，B对象的行为将影响C对象……，可以使用观察者模式创建一种链式触发机制。

应用

观察者模式在软件开发中应用非常广泛，如某电子商务网站可以在执行发送操作后给用户多个发送商品打折信息

某团队战斗游戏中某队友牺牲将给所有成员提示等等，凡是涉及到一对一或者一对多的对象交互场景都可以使用观察者模式。

在JDK的java.util包中，提供了Observable类以及Observer接口，它们构成了Java语言对观察者模式的支持。

PHP 示例

方法1 手工实现

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
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
<?php
/**
 * Interface SubjectInterface
 */
interface SubjectInterface
{
    public function attach(ObserverInterface $observer);

    public function detach(ObserverInterface $observer);

    public function notify();
}

/**
 * Class Subject
 */
class Subject implements SubjectInterface
{
    protected $subject;

    protected $observers = array();

    public function __construct($subject)
    {
        $this->subject = $subject;
    }

    public function attach(ObserverInterface $observer)
    {
        $this->observers[] = $observer;
    }

    public function detach(ObserverInterface $observer)
    {
        foreach ($this->observers as $key => $o) {
            if ($o === $observer) {
                unset($this->observers[$key]);
            }
        }
    }

    public function notify()
    {
        foreach ($this->observers as $key => $o) {
            $o->update($this);
        }
    }

    public function getSubject()
    {
        return $this->subject;
    }
}

/**
 * Interface ObserverInterface
 */
interface ObserverInterface
{
    public function update(SubjectInterface $s);
}

/**
 * Class Observer
 */
abstract class Observer implements ObserverInterface
{
    protected $name = null;

    public function __construct($name)
    {
        $this->name = $name;
    }

    abstract public function update(SubjectInterface $s);
}

/**
 * Class Observer1
 */
class Observer1 extends Observer
{
    public function update(SubjectInterface $s)
    {
        echo $s->getSubject() . '->' . __CLASS__ . '->' . $this->name . ' on update';
        echo PHP_EOL;
    }
}

/**
 * Class Observer2
 */
class Observer2 extends Observer
{
    public function update(SubjectInterface $s)
    {
        echo $s->getSubject() . '->' . __CLASS__ . '->' . $this->name . ' on update';
        echo PHP_EOL;
    }
}

$subject = new Subject('subject');
$observer = new Observer1('observerinstance');
$observer1 = new Observer1('observerinstance1');
$observer2 = new Observer2('observerinstance2');

$subject->attach($observer);
$subject->attach($observer1);
$subject->attach($observer2);
$subject->notify();

echo PHP_EOL;

$subject->detach($observer);
$subject->notify();

方法2 使用PHP SPL接口

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
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
<?php
/**
 * Class Subject
 */
class Subject implements SplSubject
{
    protected $subject;

    protected $observers = array();

    public function __construct($subject)
    {
        $this->observers = new SplObjectStorage();
        $this->subject = $subject;
    }

    public function attach(SplObserver $observer)
    {
        $this->observers->attach($observer);
    }

    public function detach(SplObserver $observer)
    {
        $this->observers->detach($observer);
    }

    public function notify()
    {
        foreach ($this->observers as $key => $o) {
            $o->update($this);
        }
    }

    public function getSubject()
    {
        return $this->subject;
    }
}

/**
 * Class Observer
 */
abstract class Observer implements SplObserver
{
    protected $name = null;

    public function __construct($name)
    {
        $this->name = $name;
    }

    abstract public function update(SplSubject $s);
}

/**
 * Class Observer1
 */
class Observer1 extends Observer
{
    public function update(SplSubject $s)
    {
        echo $s->getSubject() . '->' . __CLASS__ . '->' . $this->name . ' on update';
        echo PHP_EOL;
    }
}

/**
 * Class Observer2
 */
class Observer2 extends Observer
{
    public function update(SplSubject $s)
    {
        echo $s->getSubject() . '->' . __CLASS__ . '->' . $this->name . ' on update';
        echo PHP_EOL;
    }
}