Middleware: 全局异常处理

我们在岩浆的实例其实已经注意到了，compose 的连接方式，让我们有能力精确控制异常。

Koa中间件最终行为强依赖注册顺序，比如我们这里要引入的异常处理，必须在业务逻辑中间件前注册，才能捕获后续中间件中未捕获异常，回想一下我们的调度器实现的异常传递流程。

  1. <?php
  3. class ExceptionHandler implements Middleware
  4. {
  5.     public function __invoke(Context $ctx, $next)
  6.     {
  7.         try {
  8.             yield $next;
  9.         } catch (\Exception $ex) {
  10.             $status = 500;
  11.             $code = $ex->getCode() ?: 0;
  12.             $msg = "Internal Error";
  14.             // HttpException的异常通常是通过Context的throw方法抛出
  15.             // 状态码与Msg直接提取可用
  16.             if ($ex instanceof HttpException) {
  17.                 $status = $ex->status;
  18.                 if ($ex->expose) {
  19.                     $msg = $ex->getMessage();
  20.                 }
  21.             }
  22.             // 这里可这对其他异常区分处理
  23.             // else if ($ex instanceof otherException) { }
  25.             $err = [ "code" => $code,  "msg" => $msg ];
  26.             if ($ctx->accept("json")) {
  27.                 $ctx->status = 200;
  28.                 $ctx->body = $err;
  29.             } else {
  30.                 $ctx->status = $status;
  31.                 if ($status === 404) {
  32.                     $ctx->body = (yield Template::render(__DIR__ . "/404.html"));
  33.                 } else if ($status === 500) {
  34.                     $ctx->body = (yield Template::render(__DIR__ . "/500.html", $err));
  35.                 } else {
  36.                     $ctx->body = (yield Template::render(__DIR__ . "/error.html", $err));
  37.                 }
  38.             }
  39.         }
  40.     }
  41. }
  43. $app->υse(new ExceptionHandler());

可以将FastRoute与Exception中间件结合，很容可以定制一个按路由匹配注册的异常处理器，留待读者自行实现。

顺序问题再比如session中间件，需要优先于业务处理中间件,

而像处理404状态码的中间件，则需要在upstream流程中(逆序)的收尾阶段，我们仅仅只关心next后逻辑：

  1. <?php
  2. function notfound(Context $ctx, $next)
  3. {
  4.     yield $next;
  6.     if ($ctx->status !== 404 || $ctx->body) {
  7.         return;
  8.     }
  10.     $ctx->status = 404;
  12.     if ($ctx->accept("json")) {
  13.         $ctx->body = [
  14.             "message" => "Not Found",
  15.         ];
  16.         return;
  17.     }
  19.     $ctx->body = "<h1>404 Not Found</h1>";
  20. }