一步步理解观察者模式

今天说说观察者模式，这是一个很是常见的模式，不少事件的分发都基于此模式。

这里将从一个题目来讲说此模式的使用，有这样一道题：

某市一家报社开张，市民订阅报纸，尝试使用观察者模式解决此问题。

在使用观察者模式前，先说说普通的处理方法。

class Publisher {
    public $title = '';

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

    public function push() {
        echo "【{$this->title}】发布新闻" . PHP_EOL;
    }
}

class People {
    public $name = '';

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

    public function pull(Publisher $publisher) {
        echo "【{$this->name}】接收到【{$publisher->title}】发布的新闻" . PHP_EOL;
    }
}

/* 初始化用户 */
$peoples = [];
for ($i = 1; $i <= 5; $i++) {
    $peoples[] = new People("用户{$i}");
}

/* 报社使用 push 方法发布新闻 */
$publisher = new Publisher("报社1");
$publisher->push();

/* 全部订阅的市民使用 pull 方法接收报社对象 */
foreach ($peoples as $people) {
    $people->pull($publisher);
}

每次 publishier 使用 push 方法，都须要循环一遍 $peoples 进行通知，固然这里能够经过一个函数封装起来，每次调用便可。

如下是运行截图：

以上代码运行确定是没有任何问题的，也特别容易理解。只要运行了 push 方法，就循环调用一遍 pull 方法。但每次调用特别麻烦，有么有更好的改进呢？

来看一下接下来的代码：

class Publisher {
    public $title = '';
    private $peoples = [];

    public function __construct($title, $peoples) {
        $this->title = $title;
        $this->peoples = $peoples;
    }

    public function push() {
        echo "【{$this->title}】发布新闻" . PHP_EOL;

        // 一旦发布新闻，就通知全部订阅用户
        foreach ($this->peoples as $people) {
            // 这里注意有 $this
            $people->pull($this);
        }
    }
}

// 原先的 People 类不变，此处省略

$peoples = [];
for ($i = 1; $i <= 5; $i++) {
    $peoples[] = new People("用户{$i}");
}

// 建立 $publisher 时，直接将 $peoples 传给报社
$publisher = new Publisher("报社1", $peoples);
$publisher->push();

这里能够看到已经将循环移入了 Publisher 类中，每次只要执行 push 方法，全部的 people 对象都能收到消息。

但是这里 $peoples 是经过构造函数传进去的，能不能进行分离呢？

下面就改写一下代码：

class Publisher {
    public $title = '';
    private $peoples = [];

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

    public function addPeople(People $people) {
        $this->peoples[] = $people;
    }

    public function push() {
        echo "【{$this->title}】发布新闻" . PHP_EOL;

        foreach ($this->peoples as $people) {
            $people->pull($this);
        }
    }
}

// 客户端
$publisher = new Publisher("报社1");

for ($i = 1; $i <= 5; $i++) {
    $publisher->addPeople(new People("用户{$i}"));
}

$publisher->push();

改为这样后使用很是方便，思路也很是清晰。

以上就是观察者模式的雏形，接下来就是抽象化了...

interface IObserver {
    public function update(Publisher $publisher);
}

class Publisher {
    public $title = '';
    private $observers = [];

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

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

    public function push() {
        echo "【{$this->title}】发布新闻" . PHP_EOL;

        foreach ($this->observers as $observer) {
            $observer->update($this);
        }
    }
}

class People implements IObserver {
    public $name = '';

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

    public function update(Publisher $publisher) {
        echo "【{$this->name}】接收到【{$publisher->title}】发布的新闻" . PHP_EOL;
    }
}

$publisher = new Publisher("报社1");

for ($i = 1; $i <= 5; $i++) {
    $publisher->attach(new People("用户{$i}"));
}

$publisher->push();

以上就是比较标准的观察者模式结构，其中须要说明的是在 IObserver 接口中定义的 update 方法参数是能够根据场景须要进行修改的。

另外一个须要说的是在 Publisher 类中，能够建立一个 detach 方法用于退订。这样整个对于 $peoples 的管理就相对完整一些了。

其实有时候以为学习设计模式不要学的太死了，只要思路对，怎么写均可以。