PHP設計模式之觀察者模式定義與用法分析

abstract class EventGenerator
{
  private $ObServers = [];
  //增加觀察者
  public function add(ObServer $ObServer)
  {
    $this->ObServers[] = $ObServer;
  }
  //事件通知
  public function notify()
  {
    foreach ($this->ObServers as $ObServer) {
      $ObServer->update();
    }
  }
}
/**
 * 觀察者接口類
 * Interface ObServer
 */
interface ObServer
{
  public function update($event_info = null);
}
/**
 * 觀察者1
 */
class ObServer1 implements ObServer
{
  public function update($event_info = null)
  {
    echo "觀察者1 收到執(zhí)行通知 執(zhí)行完畢！\n";
  }
}
/**
 * 觀察者1
 */
class ObServer2 implements ObServer
{
  public function update($event_info = null)
  {
    echo "觀察者2 收到執(zhí)行通知 執(zhí)行完畢！\n";
  }
}
/**
 * 事件
 * Class Event
 */
class Event extends EventGenerator
{
  /**
   * 觸發(fā)事件
   */
  public function trigger()
  {
    //通知觀察者
    $this->notify();
  }
}
//創(chuàng)建一個事件
$event = new Event();
//為事件增加旁觀者
$event->add(new ObServer1());
$event->add(new ObServer2());
//執(zhí)行事件 通知旁觀者
$event->trigger();

?php
 /**
 * 3.1php設計模式-觀測者模式
 * 3.1.1概念:其實觀察者模式這是一種較為容易去理解的一種模式吧，它是一種事件系統(tǒng)，意味
 *     著這一模式允許某個類觀察另一個類的狀態(tài)，當被觀察的類狀態(tài)發(fā)生改變的時候，
 *     觀察類可以收到通知并且做出相應的動作;觀察者模式為您提供了避免組件之間
 *     緊密耦合的另一種方法
 * 3.1.2關鍵點:
 *    1.被觀察者->追加觀察者;->一處觀察者;->滿足條件時通知觀察者;->觀察條件
 *    2.觀察者 ->接受觀察方法
 * 3.1.3缺點:
 * 3.1.4觀察者模式在PHP中的應用場合:在web開發(fā)中觀察者應用的方面很多
 *    典型的:用戶注冊(驗證郵件，用戶信息激活)，購物網(wǎng)站下單時郵件/短信通知等
 * 3.1.5php內(nèi)部的支持
 *    SplSubject 接口，它代表著被觀察的對象，
 *    其結(jié)構：
 *    interface SplSubject
 *    {
 *      public function attach(SplObserver $observer);
 *      public function detach(SplObserver $observer);
 *      public function notify();
 *    }
 *    SplObserver 接口，它代表著充當觀察者的對象，
 *    其結(jié)構：
 *    interface SplObserver
 *    {
 *      public function update(SplSubject $subject);
 *    }
 */
 /**
 * 用戶登陸-詮釋觀察者模式
 */
class User implements SplSubject {
  //注冊觀察者
  public $observers = array();
  //動作類型
  CONST OBSERVER_TYPE_REGISTER = 1;//注冊
  CONST OBSERVER_TYPE_EDIT = 2;//編輯
  /**
   * 追加觀察者
   * @param SplObserver $observer 觀察者
   * @param int $type 觀察類型
   */
  public function attach(SplObserver $observer, $type)
  {
    $this->observers[$type][] = $observer;
  }
  /**
   * 去除觀察者
   * @param SplObserver $observer 觀察者
   * @param int $type 觀察類型
   */
  public function detach(SplObserver $observer, $type)
  {
    if($idx = array_search($observer, $this->observers[$type], true))
    {
      unset($this->observers[$type][$idx]);
    }
  }
  /**
   * 滿足條件時通知觀察者
   * @param int $type 觀察類型
   */
  public function notify($type)
  {
    if(!empty($this->observers[$type]))
    {
      foreach($this->observers[$type] as $observer)
      {
        $observer->update($this);
      }
    }
  }
  /**
   * 添加用戶
   * @param str $username 用戶名
   * @param str $password 密碼
   * @param str $email 郵箱
   * @return bool
   */
  public function addUser()
  {
    //執(zhí)行sql
    //數(shù)據(jù)庫插入成功
    $res = true;
    //調(diào)用通知觀察者
    $this->notify(self::OBSERVER_TYPE_REGISTER);
    return $res;
  }
  /**
   * 用戶信息編輯
   * @param str $username 用戶名
   * @param str $password 密碼
   * @param str $email 郵箱
   * @return bool
   */
  public function editUser()
  {
    //執(zhí)行sql
    //數(shù)據(jù)庫更新成功
    $res = true;
    //調(diào)用通知觀察者
    $this->notify(self::OBSERVER_TYPE_EDIT);
    return $res;
  }
}
/**
* 觀察者-發(fā)送郵件
*/
class Send_Mail implements SplObserver
{
  /**
   * 相應被觀察者的變更信息
   * @param SplSubject $subject
   */
  public function update(SplSubject $subject)
  {
    $this->sendMail($subject->email, $title, $content);
  }
  /**
   *發(fā)送郵件
   *@param str $email 郵箱地址
   *@param str $title 郵件標題
   *@param str $content 郵件內(nèi)容
   */
  public function sendEmail($email, $title, $content)
  {
    //調(diào)用郵件接口，發(fā)送郵件
  }
}
?>