簡介
MVC框架在現在的開發中相當流行，不論你使用的是JAVA,C#,PHP或者IOS，你肯定都會選擇一款框架。雖然不能保證100%的開發語言都會使用框架，但是在PHP社區當中擁有*多數量的MVC框架。今天你或許還在使用Zend，明天你換了另一個項目也許就會轉投Yii,Laravel或者CakePHP的懷抱。如果你剛開始使用一種框架，當你看它的源碼的時候你會覺得一頭霧水，是的，這些框架都很復雜。因為這些流行的框架並不是短時間之內就寫出來就發行的，它們都是經過一遍又一遍的編寫和測試加上不斷的更新函數庫才有了今天得模樣。所以就我的經驗來看，了解MVC框架的設計核心理念是很有必要的，不然你就會感覺在每一次使用一個新的框架的時候一遍又一遍的從頭學習。
所以*好的理解MVC的方法就是寫一個你自己的MVC框架。在這篇文章中，我將會向你展示如何構建一個自己的MVC框架。
MVC架構模式
M: Model-模型
V: View-視圖
C: Controller-控制器
MVC的關鍵概念就是從視圖層分發業務邏輯。首先解釋以下HTTP的請求和相應是如何工作的。例如，我們有一個商城網站，然后我們想要添加一個商品，那么*簡單的一個URL就會是像下面這個樣子：
http://bestshop.com/index.php?p=admin&c=goods&a=add
http://bestshop.com就是主域名或者基礎URL；
p=admin 意味着處在管理模塊,，或者是系統的后台模塊。同時我們肯定也擁有前台模塊，前台模塊供所有用戶訪問(本例中, 它是p=public)
c=goods&a=add 意思是URL請求的是goods控制器里的add方法。
前台控制器設計
在上面的例子中index.php中是什么？在PHP框架中它被稱為入口文件。這個文件通常都被命名為index.php，當然你也可以給它別的命名。這個index.php的*主要的作用就是作為HTTP請求的唯一入口文件，這樣無論你的URL請求什么資源，它都必須通過這個Index.php來請求。你可能要問為什么，它是如何做到的？PHP中的前端控制器用到了Apache服務器的分布式配置.htaccess實現的。在這個文件中，我們可以使用重寫模塊告訴Apache服務器重定向到我們的index.php入口文件，就像下面這樣：
<IfModule mod_rewrite.c> Options +FollowSymLinks RewriteEngine on # Send request via index.php RewriteCond %{REQUEST_FILENAME} !-f RewriteCond %{REQUEST_FILENAME} !-d RewriteRule ^(.*)$ index.php/$1 [L] </IfModule>
這個配置文件非常有用，還有當你重寫這個配置文件的時候你不需要重啟Apache。但是當你修改Apache的其他配置文件的時候你都需要重啟Apache才能生效，因為Apache只有在啟動的時候才會讀取這些配置文件。
同時，index.php還會進行框架的初始化並且分發路由請求給對應的控制器和方法。
我們的MVC目錄結構
現在讓我們開始創建我們的框架目錄結構。我們你可以隨便先建立一個文件夾，命名為你項目的名稱，比如:/bestshop。在這個文件夾下你需要建立下面的文件夾：
/application-存放web應用程序目錄
/framework-存放框架文件目錄
/public-存放所有的公共的靜態資源，比如HTML文件，CSS文件和jJS文件。
index.php-唯一入口文件
然后在application文件夾下再建立下一級的目錄
/config-存放應用的配置文件
/controllers-應用的控制器類
/model-應用的模型類
/view-應用的視圖文件
現在在application/controllers文件夾下，我們還需要創建兩個文件夾，一個frontend，一個backend：
同樣的，在view下也建立frontend和backend文件夾：
就像你看到的，在application的controllers和view下面建立了backen和frontend文件夾，就像我們的用用有前台和后台功能一樣。但是為什么不在model下也這樣做呢？
Well, the reason here is, normally for a web app:是因為一般在我們的應用中，前台和后台其實是可以看做是兩個“網站的”，但是CRUD操作的是同一個數據庫，這就是問什么管理員更新了貨物的價格的時候，前台用戶可以馬上看到價格的變化，因為前台和后台是共享一個數據庫（表）的。所以在model中沒必要再去建立兩個文件夾。
:現在讓我們回到framework文件夾中，一些框架的文件夾命名會用框架的名字命名，比如"symfony"。在framework中讓我們快速建立下面的子目錄：
/core-框架核心文件目錄
/database-數據庫目錄（比如數據庫啟動類）
/helpers-輔助函數目錄
/libraries-類庫目錄
現在進入public文件夾，建立下面的目錄：
/css-存放css文件
/images-存放圖片文件
/js-存放js文件
/uploads-存放上傳的文件
OK。到目前為止這就是我們這個迷你的MVC框架的目錄結構了！
框架核心類
現在在framework/core下建立一個Framework.class.php的文件。寫入以下代碼：
1 // framework/core/Framework.class.php 2 3 class Framework { 4 5 6 public static function run() { 7 8 echo "run()"; 9 10 }
我們創建了一個靜態方法run()，現在讓我們通過入口文件index.php測試一下：
1 <?php 2 3 4 require "framework/core/Framework.class.php"; 5 6 7 Framework::run();
你可以在你的瀏覽器里訪問index.php看到結果。通常這個靜態方法被命名為run()或者bootstrap()。在這個方法中，我們要做3件*主要的事情：
1 class Framework { 2 3 4 public static function run() { 5 6 // echo "run()"; 7 8 self::init(); 9 10 self::autoload(); 11 12 self::dispatch(); 13 14 } 15 16 17 private static function init() { 18 19 } 20 21 22 private static function autoload() { 23 24 25 } 26 27 28 private static function dispatch() { 29 30 31 } 32 33 }
初始化
init()方法：
1 // Initialization 2 3 private static function init() { 4 5 // Define path constants 6 7 define("DS", DIRECTORY_SEPARATOR); 8 9 define("ROOT", getcwd() . DS); 10 11 define("APP_PATH", ROOT . 'application' . DS); 12 13 define("FRAMEWORK_PATH", ROOT . "framework" . DS); 14 15 define("PUBLIC_PATH", ROOT . "public" . DS); 16 17 18 define("CONFIG_PATH", APP_PATH . "config" . DS); 19 20 define("CONTROLLER_PATH", APP_PATH . "controllers" . DS); 21 22 define("MODEL_PATH", APP_PATH . "models" . DS); 23 24 define("VIEW_PATH", APP_PATH . "views" . DS); 25 26 27 define("CORE_PATH", FRAMEWORK_PATH . "core" . DS); 28 29 define('DB_PATH', FRAMEWORK_PATH . "database" . DS); 30 31 define("LIB_PATH", FRAMEWORK_PATH . "libraries" . DS); 32 33 define("HELPER_PATH", FRAMEWORK_PATH . "helpers" . DS); 34 35 define("UPLOAD_PATH", PUBLIC_PATH . "uploads" . DS); 36 37 38 // Define platform, controller, action, for example: 39 40 // index.php?p=admin&c=Goods&a=add 41 42 define("PLATFORM", isset($_REQUEST['p']) ? $_REQUEST['p'] : 'home'); 43 44 define("CONTROLLER", isset($_REQUEST['c']) ? $_REQUEST['c'] : 'Index'); 45 46 define("ACTION", isset($_REQUEST['a']) ? $_REQUEST['a'] : 'index'); 47 48 49 define("CURR_CONTROLLER_PATH", CONTROLLER_PATH . PLATFORM . DS); 50 51 define("CURR_VIEW_PATH", VIEW_PATH . PLATFORM . DS); 52 53 54 // Load core classes 55 56 require CORE_PATH . "Controller.class.php"; 57 58 require CORE_PATH . "Loader.class.php"; 59 60 require DB_PATH . "Mysql.class.php"; 61 62 require CORE_PATH . "Model.class.php"; 63 64 65 // Load configuration file 66 67 $GLOBALS['config'] = include CONFIG_PATH . "config.php"; 68 69 70 // Start session 71 72 session_start(); 73 74 }
在注釋中你可以看到每一步的目的。
自動加載
在項目中，我們不想在腳本中想使用一個類的時候手動的去include或者require加載，這就是為什么PHP MVC框架都有自動加載的功能。例如，在symfony中，如果你想要加載lib下的類，它將會被自動引入。很神奇是吧？現在讓我們在自己的框架中加入自動加載的功能。
這里我們要用的PHP中的自帶函數spl_autoload_register：
1 // Autoloading 2 3 private static function autoload(){ 4 5 spl_autoload_register(array(__CLASS__,'load')); 6 7 } 8 9 10 // Define a custom load method 11 12 private static function load($classname){ 13 14 15 // Here simply autoload app’s controller and model classes 16 17 if (substr($classname, -10) == "Controller"){ 18 19 // Controller 20 21 require_once CURR_CONTROLLER_PATH . "$classname.class.php"; 22 23 } elseif (substr($classname, -5) == "Model"){ 24 25 // Model 26 27 require_once MODEL_PATH . "$classname.class.php"; 28 29 } 30 31 }
每一個框架都有自己的命名規則，我們的也不例外。對於一個控制器類，它需要被命名成類似xxxController.class.php，對於一個模型類，需要被命名成xxModel.class.php。為什么在使用一個框架的時候你需要遵守它的命名規則呢？自動加載就是一條原因。
路由/分發
// Routing and dispatching private static function dispatch(){ // Instantiate the controller class and call its action method $controller_name = CONTROLLER . "Controller"; $action_name = ACTION . "Action"; $controller = new $controller_name; $controller->$action_name(); }
在這步中，index.php將會分發請求到對應的Controller::Aciton()方法中。
基礎Controller類
通常在框架的核心類中都有一個基礎的控制器。在symfony中，被稱為sfAction;在iOS中，被稱為UIViewController。在這里我們命名為Controller，在framework/core下建立Controller.class.php
1 <?php 2 3 // Base Controller 4 5 class Controller{ 6 7 // Base Controller has a property called $loader, it is an instance of Loader class(introduced later) 8 9 protected $loader; 10 11 12 public function __construct(){ 13 14 $this->loader = new Loader(); 15 16 } 17 18 19 public function redirect($url,$message,$wait = 0){ 20 21 if ($wait == 0){ 22 23 header("Location:$url"); 24 25 } else { 26 27 include CURR_VIEW_PATH . "message.html"; 28 29 } 30 31 32 exit; 33 34 } 35 36 } 37 基礎控制器有一個變量$loader，它是Loader類的實例化（后面介紹）。准確的說，$this->loader是一個變量指向了被實例化的Load類。在這里我不過多的討論，但是這的確是一個非常關鍵的概念。我遇到過一些PHP開發者相信在這個語句之后： 38 39 $this->loader = new Loader(); 40 $this->load是一個對象。不，它只是一個引用。這是從Java中開始使用的，在Java之前，在C++和Objective C中被稱為指針。引用是個封裝的指針類型。比如，在iOS(O-C)中，我們創建了一個對象： 41 42 UIButton *btn = [UIButton alloc] init];
加載類
在framework.class.php中，我們已經封裝好了應用的控制器和模型的自動加載。但是如何自動加載在framework目錄中的類呢？現在我們可以新建一個Loader類，它會加載framework目錄中的類和函數。當我們加載framework類時，只需要調用這個Loader類中的方法即可。
1 class Loader{ 2 3 // Load library classes 4 5 public function library($lib){ 6 7 include LIB_PATH . "$lib.class.php"; 8 9 } 10 11 12 // loader helper functions. Naming conversion is xxx_helper.php; 13 14 public function helper($helper){ 15 16 include HELPER_PATH . "{$helper}_helper.php"; 17 18 } 19 20 }
封裝模型
我們需要下面兩個類來封裝基礎Model類：
Mysql.class.php - 在framework/database下建立，它封裝了數據庫的鏈接和一些基本查詢方法。
Model.class.php - framework/core下建立，基礎模型類，封裝所有的CRUD方法。
Mysql.class.php ：
1 <?php 2 3 /** 4 5 *================================================================ 6 7 *framework/database/Mysql.class.php 8 9 *Database operation class 10 11 *================================================================ 12 13 */ 14 15 class Mysql{ 16 17 protected $conn = false; //DB connection resources 18 19 protected $sql; //sql statement 20 21 22 23 /** 24 25 * Constructor, to connect to database, select database and set charset 26 27 * @param $config string configuration array 28 29 */ 30 31 public function __construct($config = array()){ 32 33 $host = isset($config['host'])? $config['host'] : 'localhost'; 34 35 $user = isset($config['user'])? $config['user'] : 'root'; 36 37 $password = isset($config['password'])? $config['password'] : ''; 38 39 $dbname = isset($config['dbname'])? $config['dbname'] : ''; 40 41 $port = isset($config['port'])? $config['port'] : '3306'; 42 43 $charset = isset($config['charset'])? $config['charset'] : '3306'; 44 45 46 47 $this->conn = mysql_connect("$host:$port",$user,$password) or die('Database connection error'); 48 49 mysql_select_db($dbname) or die('Database selection error'); 50 51 $this->setChar($charset); 52 53 } 54 55 /** 56 57 * Set charset 58 59 * @access private 60 61 * @param $charset string charset 62 63 */ 64 65 private function setChar($charest){ 66 67 $sql = 'set names '.$charest; 68 69 $this->query($sql); 70 71 } 72 73 /** 74 75 * Execute SQL statement 76 77 * @access public 78 79 * @param $sql string SQL query statement 80 81 * @return $result，if succeed, return resrouces; if fail return error message and exit 82 83 */ 84 85 public function query($sql){ 86 87 $this->sql = $sql; 88 89 // Write SQL statement into log 90 91 $str = $sql . " [". date("Y-m-d H:i:s") ."]" . PHP_EOL; 92 93 file_put_contents("log.txt", $str,FILE_APPEND); 94 95 $result = mysql_query($this->sql,$this->conn); 96 97 98 99 if (! $result) { 100 101 die($this->errno().':'.$this->error().'<br />Error SQL statement is '.$this->sql.'<br />'); 102 103 } 104 105 return $result; 106 107 } 108 109 /** 110 111 * Get the first column of the first record 112 113 * @access public 114 115 * @param $sql string SQL query statement 116 117 * @return return the value of this column 118 119 */ 120 121 public function getOne($sql){ 122 123 $result = $this->query($sql); 124 125 $row = mysql_fetch_row($result); 126 127 if ($row) { 128 129 return $row[0]; 130 131 } else { 132 133 return false; 134 135 } 136 137 } 138 139 /** 140 141 * Get one record 142 143 * @access public 144 145 * @param $sql SQL query statement 146 147 * @return array associative array 148 149 */ 150 151 public function getRow($sql){ 152 153 if ($result = $this->query($sql)) { 154 155 $row = mysql_fetch_assoc($result); 156 157 return $row; 158 159 } else { 160 161 return false; 162 163 } 164 165 } 166 167 /** 168 169 * Get all records 170 171 * @access public 172 173 * @param $sql SQL query statement 174 175 * @return $list an 2D array containing all result records 176 177 */ 178 179 public function getAll($sql){ 180 181 $result = $this->query($sql); 182 183 $list = array(); 184 185 while ($row = mysql_fetch_assoc($result)){ 186 187 $list[] = $row; 188 189 } 190 191 return $list; 192 193 } 194 195 /** 196 197 * Get the value of a column 198 199 * @access public 200 201 * @param $sql string SQL query statement 202 203 * @return $list array an array of the value of this column 204 205 */ 206 207 public function getCol($sql){ 208 209 $result = $this->query($sql); 210 211 $list = array(); 212 213 while ($row = mysql_fetch_row($result)) { 214 215 $list[] = $row[0]; 216 217 } 218 219 return $list; 220 221 } 222 223 224 225 226 /** 227 228 * Get last insert id 229 230 */ 231 232 public function getInsertId(){ 233 234 return mysql_insert_id($this->conn); 235 236 } 237 238 /** 239 240 * Get error number 241 242 * @access private 243 244 * @return error number 245 246 */ 247 248 public function errno(){ 249 250 return mysql_errno($this->conn); 251 252 } 253 254 /** 255 256 * Get error message 257 258 * @access private 259 260 * @return error message 261 262 */ 263 264 public function error(){ 265 266 return mysql_error($this->conn); 267 268 } 269 270 } 271
Model.class.php：
1 <?php 2 3 // framework/core/Model.class.php 4 5 // Base Model Class 6 7 class Model{ 8 9 protected $db; //database connection object 10 11 protected $table; //table name 12 13 protected $fields = array(); //fields list 14 15 public function __construct($table){ 16 17 $dbconfig['host'] = $GLOBALS['config']['host']; 18 19 $dbconfig['user'] = $GLOBALS['config']['user']; 20 21 $dbconfig['password'] = $GLOBALS['config']['password']; 22 23 $dbconfig['dbname'] = $GLOBALS['config']['dbname']; 24 25 $dbconfig['port'] = $GLOBALS['config']['port']; 26 27 $dbconfig['charset'] = $GLOBALS['config']['charset']; 28 29 30 31 $this->db = new Mysql($dbconfig); 32 33 $this->table = $GLOBALS['config']['prefix'] . $table; 34 35 $this->getFields(); 36 37 } 38 39 /** 40 41 * Get the list of table fields 42 43 * 44 45 */ 46 47 private function getFields(){ 48 49 $sql = "DESC ". $this->table; 50 51 $result = $this->db->getAll($sql); 52 53 foreach ($result as $v) { 54 55 $this->fields[] = $v['Field']; 56 57 if ($v['Key'] == 'PRI') { 58 59 // If there is PK, save it in $pk 60 61 $pk = $v['Field']; 62 63 } 64 65 } 66 67 // If there is PK, add it into fields list 68 69 if (isset($pk)) { 70 71 $this->fields['pk'] = $pk; 72 73 } 74 75 } 76 77 /** 78 79 * Insert records 80 81 * @access public 82 83 * @param $list array associative array 84 85 * @return mixed If succeed return inserted record id, else return false 86 87 */ 88 89 public function insert($list){ 90 91 $field_list = ''; //field list string 92 93 $value_list = ''; //value list string 94 95 foreach ($list as $k => $v) { 96 97 if (in_array($k, $this->fields)) { 98 99 $field_list .= "`".$k."`" . ','; 100 101 $value_list .= "'".$v."'" . ','; 102 103 } 104 105 } 106 107 // Trim the comma on the right 108 109 $field_list = rtrim($field_list,','); 110 111 $value_list = rtrim($value_list,','); 112 113 // Construct sql statement 114 115 $sql = "INSERT INTO `{$this->table}` ({$field_list}) VALUES ($value_list)"; 116 117 if ($this->db->query($sql)) { 118 119 // Insert succeed, return the last record’s id 120 121 return $this->db->getInsertId(); 122 123 //return true; 124 125 } else { 126 127 // Insert fail, return false 128 129 return false; 130 131 } 132 133 134 135 } 136 137 /** 138 139 * Update records 140 141 * @access public 142 143 * @param $list array associative array needs to be updated 144 145 * @return mixed If succeed return the count of affected rows, else return false 146 147 */ 148 149 public function update($list){ 150 151 $uplist = ''; //update fields 152 153 $where = 0; //update condition, default is 0 154 155 foreach ($list as $k => $v) { 156 157 if (in_array($k, $this->fields)) { 158 159 if ($k == $this->fields['pk']) { 160 161 // If it’s PK, construct where condition 162 163 $where = "`$k`=$v"; 164 165 } else { 166 167 // If not PK, construct update list 168 169 $uplist .= "`$k`='$v'".","; 170 171 } 172 173 } 174 175 } 176 177 // Trim comma on the right of update list 178 179 $uplist = rtrim($uplist,','); 180 181 // Construct SQL statement 182 183 $sql = "UPDATE `{$this->table}` SET {$uplist} WHERE {$where}"; 184 185 186 187 if ($this->db->query($sql)) { 188 189 // If succeed, return the count of affected rows 190 191 if ($rows = mysql_affected_rows()) { 192 193 // Has count of affected rows 194 195 return $rows; 196 197 } else { 198 199 // No count of affected rows, hence no update operation 200 201 return false; 202 203 } 204 205 } else { 206 207 // If fail, return false 208 209 return false; 210 211 } 212 213 214 215 } 216 217 /** 218 219 * Delete records 220 221 * @access public 222 223 * @param $pk mixed could be an int or an array 224 225 * @return mixed If succeed, return the count of deleted records, if fail, return false 226 227 */ 228 229 public function delete($pk){ 230 231 $where = 0; //condition string 232 233 //Check if $pk is a single value or array, and construct where condition accordingly 234 235 if (is_array($pk)) { 236 237 // array 238 239 $where = "`{$this->fields['pk']}` in (".implode(',', $pk).")"; 240 241 } else { 242 243 // single value 244 245 $where = "`{$this->fields['pk']}`=$pk"; 246 247 } 248 249 // Construct SQL statement 250 251 $sql = "DELETE FROM `{$this->table}` WHERE $where"; 252 253 if ($this->db->query($sql)) { 254 255 // If succeed, return the count of affected rows 256 257 if ($rows = mysql_affected_rows()) { 258 259 // Has count of affected rows 260 261 return $rows; 262 263 } else { 264 265 // No count of affected rows, hence no delete operation 266 267 return false; 268 269 } 270 271 } else { 272 273 // If fail, return false 274 275 return false; 276 277 } 278 279 } 280 281 /** 282 283 * Get info based on PK 284 285 * @param $pk int Primary Key 286 287 * @return array an array of single record 288 289 */ 290 291 public function selectByPk($pk){ 292 293 $sql = "select * from `{$this->table}` where `{$this->fields['pk']}`=$pk"; 294 295 return $this->db->getRow($sql); 296 297 } 298 299 /** 300 301 * Get the count of all records 302 303 * 304 305 */ 306 307 public function total(){ 308 309 $sql = "select count(*) from {$this->table}"; 310 311 return $this->db->getOne($sql); 312 313 } 314 315 /** 316 317 * Get info of pagination 318 319 * @param $offset int offset value 320 321 * @param $limit int number of records of each fetch 322 323 * @param $where string where condition,default is empty 324 325 */ 326 327 public function pageRows($offset, $limit,$where = ''){ 328 329 if (empty($where)){ 330 331 $sql = "select * from {$this->table} limit $offset, $limit"; 332 333 } else { 334 335 $sql = "select * from {$this->table} where $where limit $offset, $limit"; 336 337 } 338 339 340 341 return $this->db->getAll($sql); 342 343 } 344 345 } 346
現在我們可以在application下創建一個User模型，對應數據庫里的user表：
1 <?php 2 3 // application/models/UserModel.class.php 4 5 class UserModel extends Model{ 6 7 8 public function getUsers(){ 9 10 $sql = "select * from $this->table"; 11 12 $users = $this->db->getAll($sql); 13 14 return $users; 15 16 } 17 18 }
后台的indexController：
1 <?php 2 3 // application/controllers/admin/IndexController.class.php 4 5 6 class IndexController extends BaseController{ 7 8 public function mainAction(){ 9 10 include CURR_VIEW_PATH . "main.html"; 11 12 // Load Captcha class 13 14 $this->loader->library("Captcha"); 15 16 $captcha = new Captcha; 17 18 $captcha->hello(); 19 20 $userModel = new UserModel("user"); 21 22 $users = $userModel->getUsers(); 23 24 } 25 26 public function indexAction(){ 27 28 $userModel = new UserModel("user"); 29 30 $users = $userModel->getUsers(); 31 32 // Load View template 33 34 include CURR_VIEW_PATH . "index.html"; 35 36 } 37 38 public function menuAction(){ 39 40 include CURR_VIEW_PATH . "menu.html"; 41 42 } 43 44 public function dragAction(){ 45 46 include CURR_VIEW_PATH . "drag.html"; 47 48 } 49 50 public function topAction(){ 51 52 include CURR_VIEW_PATH . "top.html"; 53 54 } 55 56 }
到目前為止，我們后台的index控制器就正常執行了，控制器中實例化了模型類，並且將得到的數據傳給了視圖中的模板，這樣在瀏覽器中就能看到數據了。
轉自:phpchina原創譯文 1小時內打造你自己的PHP MVC框架 http://www.phpchina.com/article-40109-1.html
原文鏈接：http://www.codeproject.com/Articles/1080626/WebControls/