一步步理解觀察者模式

今天說說觀察者模式，這是一個很是常見的模式，不少事件的分發都基於此模式。

這裏將從一個題目來講說此模式的使用，有這樣一道題：

某市一家報社開張，市民訂閱報紙，嘗試使用觀察者模式解決此問題。

在使用觀察者模式前，先說說普通的處理方法。

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 的管理就相對完整一些了。

其實有時候以爲學習設計模式不要學的太死了，只要思路對，怎麼寫均可以。