$ctx->body.='>m1';

$ctx->next();

$ctx->body.='>m1 end';

});

$app->use('Middleware2');

$app->run();

基本上跟koa类似，先new一个app对象，使用use方法添加中间件，支持闭包或外部文件。

$ctx支持注入所需的各种参数，方便各中间件共用。

完整代码

//app.php

classApp{

private$m=array();

private$ctx=array();

functionnext(){

$f=$this->c->current();

if(!$f)return;

$this->c->next();

$f($this);

}

functionrun(){

$this->c=$this->_gen();

$this->next();

}

privatefunction_gen(){

foreach($this->mas$v){

yield$v;

}

}

privatefunction_add($m){

if(!empty($this->m)&&$this->m[count($this->m)-1]===false)return;

if(!$m){

$this->m[]=false;

}elseif(($minstanceofClosure)){

$this->m[]=$m;

}else{

$m=$this->_load($m);

if(!function_exists($m)){

thrownewException('middleware error');

}

else$this->m[]=$m;

}

}

//处理文件加载，返回执行函数(如需要，可加入命名空间处理)

privatefunction_load($m){

$f='./middleware/'.$m.".php";

if(!file_exists($f))thrownewException('middleware error');

require$f;

return$m;

}

function__call($m,$v){

if('use'==$m){

$p=isset($v[0])?$v[0]:'';

$this->_add($p);

}else{

thrownewException('method not exists');

}

}

function__set($k,$v){

print_r($k);

print_r($v);

$this->ctx[$k]=$v;

}

function__get($k){

returnisset($this->ctx[$k])?$this->ctx[$k]:NULL;

}

}

//app.php

classApp{

private$m=array();

private$ctx=array();

functionnext(){

$f=$this->c->current();

if(!$f)return;

$this->c->next();

$f($this);

}

functionrun(){

$this->c=$this->_gen();

$this->next();

}

privatefunction_gen(){

foreach($this->mas$v){

yield$v;

}

}

privatefunction_add($m){

if(!empty($this->m)&&$this->m[count($this->m)-1]===false)return;

if(!$m){

$this->m[]=false;

}elseif(($minstanceofClosure)){

$this->m[]=$m;

}else{

$m=$this->_load($m);

if(!function_exists($m)){

thrownewException('middleware error');

}

else$this->m[]=$m;

}

}

//处理文件加载，返回执行函数(如需要，可加入命名空间处理)

privatefunction_load($m){

$f='./middleware/'.$m.".php";

if(!file_exists($f))thrownewException('middleware error');

require$f;

return$m;

}

function__call($m,$v){

if('use'==$m){

$p=isset($v[0])?$v[0]:'';

$this->_add($p);

}else{

thrownewException('method not exists');

}

}

function__set($k,$v){

print_r($k);

print_r($v);

$this->ctx[$k]=$v;

}

function__get($k){

returnisset($this->ctx[$k])?$this->ctx[$k]:NULL;

}

}

没错，这就是全部的代码。

代码讲解 use方法 use可以加入闭包或外部文件，且php5不支持use作为方法名，这里用 __call来实现重载，当调用use时由 __call来调用私有的 _add方法。

_add对传进来的参数作判断，如果是字符串，表示外部加载，则去判断文件和处理函数是否存在和有效，然后将处理函数加到中间件队列。

这里面如果use()传递空参数，表示忽略后面的中间件。

run方法 添加完中间件后，执行 $app->run()方法运行，来看看是怎么执行的：

调用私有的_gen来生成一个生成器，该生成器可以迭代返回队列中的中间件处理函数。 调用next方法执行下一个中间件(这里即第一个入口)

2.1 调用生成器的current方法获得当前的处理函数

2.2 执行该函数(传递$this作为参数，即$ctx),并调用生成器的next方法后移到下一个处理函数

直到生成器没有返回时结束。 中间件中需调用 $ctx->next()将控制权交到下一个中间件，从而迭代完所有的中间件。

__get和 __set方法 提供了 __get和 __set方法，是方便在中间件中使用$ctx直接设置和访问未经定义的值。如：

$ctx->body='hello';

$ctx->tplName='a.tpl';

$ctx->body='hello';

$ctx->tplName='a.tpl';

That is all

本文来源网络，侵立删！