php观察折模式

<?php

class Paper{

  private $_observers = array();

  public function register($sub){

    $this->_observers[] = $sub;

  }

  public function trigger(){

    if(!empty($this->_observers)){

      foreach($this->_observers as $observer){

        $observer->update();

      }

    }

  }

}

interface Observerable{

  public function update();

}

class Subscriber implements Observerable{

  public $name = "";

  public function __construct($name){

    $this->name = $name;

  }

  public function update(){

    echo $this->name." callback\n";

  }

}

$paper = new Paper();

$paper->register(new Subscriber('xiaoming'));

$paper->register(new Subscriber('xiaoli'));

$paper->trigger();

　　被观察者通过自身的接口，将观察者注册到自己的属性里。

当触发调用的时候通过观察者统一实现的接口方法通知观察者。

当有新的观察者进来的时候，只需要新观察者实现接口，然后注册到被观察者属性里就可以啦。

这降低了主题对象和观察者对象的耦合度。

设计原则

在观察者模式中，会改变的是主题的状态以及观察者的数目。用这个模式，你可以改变依赖于主题状态的对象，却不必改变主题。——找出程序中会变化的方面，然后将其和固定不变的方面相分离!

主题和观察者都使用接口:观察者利用主题的接口向主题注册，而主题利用观察者接口通知观察者。这样可以让两者之间运作正常，又同时具有松耦合的优点! ——针对接口编程，不针对实现编程!

。

观察者模式利用“组合”将许多观察者组合进主题中。对象(观察者——主题)之间的这种关系不是通过继承产生的，而是在运行时利用组合的方式产生的。 ——多用组合，少用继承！

http://www.cnblogs.com/baochuan/archive/2012/02/22/2362668.html

Thinkphp3.2.3就是通过这个模式来实现的。

\Tinkphp\Core\Library\Think\Think.class.php

81-83行，通过这个注册，观察者；

          // 加载应用行为定义

          if(is_file(CONF_PATH.'tags.php'))

              // 允许应用增加开发模式配置定义

              Hook::import(include CONF_PATH.'tags.php');

　　附上被观察者源码；

\Thinkphp\Core\Library\Think\Hook.class.php

<?php

// +----------------------------------------------------------------------

// | ThinkPHP [ WE CAN DO IT JUST THINK ]

// +----------------------------------------------------------------------

// | Copyright (c) 2006~2013 http://topthink.com All rights reserved.

// +----------------------------------------------------------------------

// | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )

// +----------------------------------------------------------------------

// | Author: liu21st <liu21st@gmail.com>

// +----------------------------------------------------------------------

namespace Think;

/**

 * ThinkPHP系统钩子实现

 */

class Hook {

    static private  $tags       =   array();

    /**

     * 动态添加插件到某个标签

     * @param string $tag 标签名称

     * @param mixed $name 插件名称

     * @return void

     */

    static public function add($tag,$name) {

        if(!isset(self::$tags[$tag])){

            self::$tags[$tag]   =   array();

        }

        if(is_array($name)){

            self::$tags[$tag]   =   array_merge(self::$tags[$tag],$name);

        }else{

            self::$tags[$tag][] =   $name;

        }

    }

    /**

     * 批量导入插件

     * @param array $data 插件信息

     * @param boolean $recursive 是否递归合并

     * @return void

     */

    static public function import($data,$recursive=true) {

        if(!$recursive){ // 覆盖导入

            self::$tags   =   array_merge(self::$tags,$data);

        }else{ // 合并导入

            foreach ($data as $tag=>$val){

                if(!isset(self::$tags[$tag]))

                    self::$tags[$tag]   =   array();

                if(!empty($val['_overlay'])){

                    // 可以针对某个标签指定覆盖模式

                    unset($val['_overlay']);

                    self::$tags[$tag]   =   $val;

                }else{

                    // 合并模式

                    self::$tags[$tag]   =   array_merge(self::$tags[$tag],$val);

                }

            }

        }

    }

    /**

     * 获取插件信息

     * @param string $tag 插件位置 留空获取全部

     * @return array

     */

    static public function get($tag='') {

        if(empty($tag)){

            // 获取全部的插件信息

            return self::$tags;

        }else{

            return self::$tags[$tag];

        }

    }

    /**

     * 监听标签的插件

     * @param string $tag 标签名称

     * @param mixed $params 传入参数

     * @return void

     */

    static public function listen($tag, &$params=NULL) {

        if(isset(self::$tags[$tag])) {

            if(APP_DEBUG) {

                G($tag.'Start');

                trace('[ '.$tag.' ] --START--','','INFO');

            }

            foreach (self::$tags[$tag] as $name) {

                APP_DEBUG && G($name.'_start');

                $result =   self::exec($name, $tag,$params);

                if(APP_DEBUG){

                    G($name.'_end');

                    trace('Run '.$name.' [ RunTime:'.G($name.'_start',$name.'_end',6).'s ]','','INFO');

                }

                if(false === $result) {

                    // 如果返回false 则中断插件执行

                    return ;

                }

            }

            if(APP_DEBUG) { // 记录行为的执行日志

                trace('[ '.$tag.' ] --END-- [ RunTime:'.G($tag.'Start',$tag.'End',6).'s ]','','INFO');

            }

        }

        return;

    }

    /**

     * 执行某个插件

     * @param string $name 插件名称

     * @param string $tag 方法名（标签名）

     * @param Mixed $params 传入的参数

     * @return void

     */

    static public function exec($name, $tag,&$params=NULL) {

        if('Behavior' == substr($name,-8) ){

            // 行为扩展必须用run入口方法

            $tag    =   'run';

        }

        $addon   = new $name();

        return $addon->$tag($params);

    }

}

巴特西

php观察折模式

最新文章

热门文章