關于PHP事件驅動框架的一些基本信息請先看我上一篇博客(基于CodeIgniter的事件驅動擴展和開發規范http://www.it165.net/pro/html/201206/2945.html)

這里將使用上一篇博客中的寫的事件類和規范來寫一個簡單 用php 和 mysql 模擬文件系統的增刪改查 例子。

步驟

1.數據庫設計和基本結構

　　1.1我們用一張表來表示文件和文件夾，主要字段和意義如下表所示。

　　　　文件系統是一種簡單的樹形結構，特點是：文件夾節點有子節點，文件節點沒有子節點。

2.類設計和定義

　　2.1要考慮的問題

　　　　從要實現的操作“增、刪、改、查”來看，要考慮的主要問題只有一個，就是在對文件夾節點進行刪改操作時，如何讓上層目錄和下層文件或文件夾進行相應的更改。

　　2.2希望的寫法

　　　　1.對文件類（也可以用來表示文件夾）有簡單的save , set , delete 等方法。

　　　　2.希望有一個類來表示文件的所有祖先節點，這個類可以是一個簡單的文件類的集合。它在必要時可以將所有的祖先文件夾實例化。它能提供一些簡單的集合操作方法。

　　　　3.希望有一個類來表示文件的所有子文件和子文件夾，他能提供一些方法讓我批量操作子文件或文件夾。

　　2.3類定義

　　　　這里的實體類，和實體集合類參考了前端框架backbone。

　　　　我先定義了一個實體類，這個類有基本增刪改查操作。

class Entity {    private $attributes = array();    private $is_deleted = false;    public function __construct() {    }    public function reset( $data ) {        $this -> chunk();        return $this -> set( $data );    }    public function get( $attr_name ) {        return isset( $this -> attributes[$attr_name] ) ? $this -> attributes[$attr_name]->value : false;    }        public function get_attr_detail( $attr_name ){        return isset( $this -> attributes[$attr_name] ) ? $this -> attributes[$attr_name] : false;    }    public function set() {        if( $this -> is_deleted ){            return false;        }                $args = func_get_args();        if( count( $args) == 1 ){            $attr_array = ( array ) $args[0];        }else if(  count( $args) == 2 ){            $attr_array = array($args[0] => $args[1] );        }        foreach( $attr_array as $key => $value ) {            $value_obj = new stdClass();            $value_obj ->  changed = false;            $value_obj ->  new = true;                        if( isset($this -> attributes[$key])){                $value_obj -> new  = false;                if( $this -> attributes[$key] -> value !== $value ){                    $value_obj -> changed  = true;                    $value_obj -> last  = $this -> attributes[$key] -> value;                }            }            $value_obj -> value = $value;                        $this -> attributes[$key] = $value_obj;        }        return $this;    }    public function chunk() {        $this -> attributes = array( );        return $this;    }    public function save() {        return false;    }        public function delete(){        $this -> deleted = true;    }        public function to_object() {        $object = new stdClass();        foreach( $this -> attributes as $key => $value_obj ) {            $object -> $key = $value_obj ->value;        }        return $object;    }    public function to_array() {        return ( array ) $this -> to_object();    }        public function is_empty(){        return empty( $this -> attributes );    }        public function is_delete(){        return $this -> deleted;    }}

　　　　然后定義了一個集合類，這個類實現了spl的IteratorAggregate 接口，使得php可以對它進行foreach操作。

class Entity_collection implements IteratorAggregate{    public $length = 0;    public $options = array(        'child_class' => "Entity"    );    public $children = array( );    public function __construct( $options ) {                $this -> options = array_merge( $this -> options, $options );            $this -> load_children( $this -> options );    }        private function load_children( &$options ){        if( !empty( $options['children_data'] ) ) {            $this -> reset_from_data( $options['children_data'] );                    } else if( !empty( $options['children'] ) ) {                        $this -> reset( $options['children'] );        }    }    public function to_array() {        $output = array( );        foreach( $this -> children as $child ) {            $output[] = $child -> to_object();        }        return $output;    }    public function reset( &$children ) {        $this -> children = $children;        $this -> length = count( $children );    }    public function reset_from_data( $children_data ) {        foreach( $children_data as $child_data ) {            $class_name = $this -> options['child_class'];            $children_obj = new $class_name( $child_data );            if( !$children_obj -> is_empty() ){                $this -> children[] = $children_obj;            }        }                $this -> length = count( $this -> children );    }        public function get( $id ){        foreach( $this -> children as &$child ){            if( $child -> get("id") == $id ){                return $child;            }        }        return false;    }        public function getIterator(){        return new ArrayIterator( $this -> children );    }}

　　定義了文件（文件夾）類，繼承自實體類。這里注意里面使用另一個叫做file_database的單例，這個單例是用來進行具體數據庫操作。單獨提出來是為了提高擴展性。用戶可以通過修改file_database類來應對自己的需求。

class File extends Entity{    private $file_database;    public function __construct( $fid = false ){        parent::__construct();        $this -> file_database = File_database::get_instance();        if( $fid ){            if( is_object( $fid ) || is_array( $fid ) ){                $data = $fid;            }else{                $data = $this -> file_database -> load_file( $fid );            }            $this -> reset( $data );        }    }    public function save(){        $data = $this -> to_object();        $id = $this -> get( 'id' );        if( $id ){            $new_data = $this -> file_database -> update_file( $data );        }else{            $new_data = $this -> file_database -> insert_file( $data );        }        if( $new_data ){            $this -> reset( $new_data );        }else{            //錯誤處理        }        return $this;    }        public function delete(){            }}

　　文件祖先類，這里注意它不是直接集成自實體集合類。

class File_ancenstors implements IteratorAggregate{    public $file = false;    public $ancestors;    public function __construct( $fid ){        $this -> file = new File( $fid );        $this -> load_ancestor_entities( $this -> file -> get( 'route' ) );    }    private function load_ancestor_entities( $route ){        $ancestor_ids = explode( '/', $route );        $collection_options = array(            'child_class' => "File",            'children_data' => $ancestor_ids        );        $this -> ancestors = new Entity_collection( $collection_options );        return $this;    }        public function getIterator(){        return $this -> ancestors;    }}

　　　　子文件（不包括后代文件）集合類

class File_children extends Entity_collection{    private $file_database;        public function __construct( $fid ){        $this -> file_database = File_database::get_instance();        $options = array(            'child_class' => 'File',        );        parent::__construct( $options );                $this -> load_children_entities( $fid );    }    public function load_children_entities( $fid ){        $children_data = $this -> file_database -> load_children_files( $fid );        $this -> reset_from_data( $children_data  );        return $this;    }}

　　最后數據庫操作類

class File_database{    const table = 'files';    static $instance = false;    private $CI = false;    static function get_instance(){        if( !File_database::$instance ){            new File_database();                    }        return File_database::$instance;    }    private $db;    public function __construct(){        $this -> CI = &get_instance();        $this -> db = $this -> CI -> db;                self::$instance = &$this;    }    public function load_file( $fid ){        $mid = $this -> CI -> user -> id % var_get("user_mod");        $table_name = self::table ."_{$mid}";        return $this -> db -> get_where( $table_name, array( "id" => $fid ) ) -> row();    }    public function update_file( $file ){        if( !isset( $file -> id ) ){            return false;        }        $update_data = ( array ) $file;        $mid = $update_data['uid'] % var_get("user_mod");        $table_name = self::table."_{$mid}";        $this -> db -> where( "id", $update_data['id'] );        unset( $update_data['id'] );        $update_result = $this -> db -> update( $table_name, $update_data );        return $update_result ? $file : false;    }    public function insert_file( $file ){        if( isset( $file -> id ) ){            return false;        }        $insert_data = ( array ) $file;        $insert_data['id'] = $this -> generate_file_id();        $mid = $insert_data['uid'] % var_get("user_mod");        $table_name = self::table."_{$mid}";        $insert_result = $this -> db -> insert( $table_name, $insert_data );        if( $insert_result ){            $this -> db -> where( 'id', $insert_data['id'] );            $new_data = $this -> db -> get( $table_name ) -> row();        }        return $insert_result ? $new_data : false;    }    private function generate_file_id(){        do{            $fid = $this -> salt( 16 );        }while( $this -> file_id_exist( $fid ) );        return $fid;    }    private function salt( $length = 16 ){        return substr( md5( uniqid( rand(), true ) ), 0, $length );    }    public function file_id_exist( $fid ){        if( $this-> db -> query( "SELECT id FROM files WHERE id = '{$fid}'" ) -> num_rows() ){            return true;        }        return false;    }        public function load_children_files( $fid ){        $mid = $this -> CI -> user -> id % var_get("user_mod");        $table_name = self::table ."_{$mid}";                $this -> db -> where( 'pid', $fid );        $mysql_result = $this -> db -> get( $table_name );        return $mysql_result ? $mysql_result -> result() : array();    }}

3.模塊定義

　　3.1希望的寫法

　　　　1.希望在寫對任何一個節點的邏輯操作時，無論增刪改查，我都可以先只考慮考慮當前節點。通過拋出事件讓自己的模塊，或者其他擴展模塊來決定要不要進行相應的其他操作。

　　　　2.在寫任何一個針對文件某一變化（如修改、刪除）時，代碼不關心只對自己模塊內的變化負責。

　　3.2模塊實現

　　　　這里我使用CodeIgniter作為基礎框架，讀者也可以直接自己移植。具體的內容請看注釋。

<?php/** * @author 侯振宇 * @date 2012-6-26 * @encode UTF-8 */class File_model extends CI_Model{        public function __construct(  ){        parent::__construct( );        //file factory 包含了和文件相關的類        $this -> load -> library("File_factory");    }    //聲明本模塊需要進行權限驗證的接口    public function auth(){        return array(            'main/file_list' => array(                'file_owner_validate' => array(                    'validate' => 'is_operator_file_owner'                )            ),            'main/file_update' => array(                'file_owner_validate' => array(                    'validate' => 'is_operator_file_owner'                )            )        );    }    //聲明模塊要監聽的事件，可以是內部事件，也可以是外部事件。    //這里監聽的都是內部的文件操作的事件，如果修改，增加。為的是分離祖先后者后臺的連帶操作。    public function listen(){        return array(            "file_update" => "react_file_update",            "file_insert" => "react_file_insert",            "file_remove" => "react_file_remove",        );    }        //文件更新后   更新父目錄的size等屬性。    public function react_file_update( $file ){                //size        if( $file -> get_attr_detail("size") -> changed ){            $size_change_value = $file -> get("size") - $file -> get_attr_detail("size") -> last;            $ancestors = new File_ancenstors( $file->get("id") );            foreach( $ancestors as &$ancestor ){                $ancestor -> set( "size", $ancestor -> get("size") + $size_change_value );                $ancestor -> save();            }        }    }        //文件插入后，更新文件route。當然這個操作你可以在文件新建的時候就寫好，這里只是示例。    public function react_file_insert( $file ){        $pfile = new File( $file -> get("pid") );        $file_route = explode('/', $pfile -> get('route') );        array_push( $file_route,  $file -> get("pid") );        $file_route_str = implode('/', array_filter( $file_route) );                $file -> set("route" , $file_route_str) -> save();    }        public function is_operator_file_owner(){        //根據自己情況進行判斷        return true;    }        //文件的一個列表    public function file_list( $fid ){        $files = new File_children( $fid );        return $files -> to_array();    }        //單個文件載入    public function file_load($fid){        $file = new File( $fid );        return $file -> to_object();    }        //某一文件的祖先    public function file_ancestors( $fid ){        $file_ancenstors = new File_ancenstors( $fid );        return  $file_ancenstors -> ancestors -> to_array()  ;    }        //創建文件    public function file_new(){        //測試例子        $file_attrs = array(            'name' =>  "new_test",            'uid' => 151,            'created' => now(),            'pid' => '8a0341838c007cf4',        );                $file = new File( $file_attrs );        $file -> save();        $this -> event -> trigger("file_insert", $file );        return $file;            }        //創建文件夾    public function folder_new( $pid, $name ){        $file_attrs = array(            'name' =>  $name,            'uid' => $this -> user -> id,            'created' => now(),            'pid' => $pid,        );                $file = new File( $file_attrs );        $file -> save();        $this -> event -> trigger("file_insert", $file );        return  $file -> to_object() ;    }                //文件更新    public function file_update( $fid, $data ){        $file = new File( $fid );        $file -> set( $data );        $file -> save();        $this -> event -> trigger( "file_update", $file );    }}?>

總結

事件驅動 相比模塊間通過接口來溝通的最大好處應該是進一步降低了耦合，同時使系統的邏輯更容易閱讀。

希望讀者能夠仔細閱讀代碼，能給我提出一些您的寶貴建議。畢竟我不希望我的博客只是放出一個現成的東西，編程讓大家測試一下而已。貴在交流。

我有兩個項目會基于事件驅動來做，非商業的，開源的，個人覺得還比較好玩。有興趣參與的請與我聯系。留言或者email都可以。謝謝。

鄭重聲明：本文版權歸原作者所有，轉載文章僅為傳播更多信息之目的，如作者信息標記有誤，請第一時間聯系我們修改或刪除，多謝。