eleven26

/**
 * Boot the service provider.
 *
 * @return void
 */
public function boot()
{
    parent::boot();

    // 1. 加载 dingo/api 配置
    $this->app->configure('api');

    // 2. 获取 app 容器反射对象
    $reflection = new ReflectionClass($this->app);

    // 3. 拿出 app 容器中定义的中间件, 传递进 \Dingo\Api\Http\Middleware\Request 中间件中
    $this->app[Request::class]->mergeMiddlewares(
        $this->gatherAppMiddleware($reflection)
    );

    // 4. 把 \Dingo\Api\Http\Middleware\Request 中间件加到 app 中间件处理链起始位置，
    //    这样一来，请求会先经过 \Dingo\Api\Http\Middleware\Request 中间件处理，然后才是我们使用 `app()->middleware` 定义的中间件。
    $this->addRequestMiddlewareToBeginning($reflection);

    // Because Lumen sets the route resolver at a very weird point we're going to
    // have to use reflection whenever the request instance is rebound to
    // set the route resolver to get the current route.
    $this->app->rebinding(IlluminateRequest::class, function ($app, $request) {
        $request->setRouteResolver(function () use ($app) {
            $reflection = new ReflectionClass($app);

            $property = $reflection->getProperty('currentRoute');
            $property->setAccessible(true);

            return $property->getValue($app);
        });
    });

    $this->app->routeMiddleware([
        'api.auth' => Auth::class,
        'api.throttle' => RateLimit::class,
        'api.controllers' => PrepareController::class,
    ]);
}

/**
 * Handle an incoming request.
 *
 * @param \Illuminate\Http\Request $request
 * @param \Closure                 $next
 *
 * @return mixed
 */
public function handle($request, Closure $next)
{
    try {
        // 验证是否是 dingo 请求(前缀匹配上了 API_PREFIX 或者域名匹配上 API_DOMAIN)，若不是会直接传递给下一个中间件
        // (详情: \Dingo\Api\Provider\HttpServiceProvider::registerHttpValidation)
        // 若是:
        //    1. dingo 接管异常处理
        //    2. 转换 \Illuminate\Http\Request 为 \Dingo\Api\Http\Request
        //    3. 重新绑定 app 容器的 request 对象为 Dingo Request， 然后把 $request 传递给其他 app 容器中定义的中间件处理
        //    4. 异常的时候返回异常响应对象
        if ($this->validator->validateRequest($request)) {
            $this->app->singleton(LaravelExceptionHandler::class, function ($app) {
                return $app[ExceptionHandler::class];
            });

            $request = $this->app->make(RequestContract::class)->createFromIlluminate($request);

            $this->events->fire(new RequestWasMatched($request, $this->app));

            // 这个方法效果是所有中间件处理完之后才会执行控制器里面对应的方法
            return $this->sendRequestThroughRouter($request);
        }
    } catch (Exception $exception) {
        $this->exception->report($exception);

        return $this->exception->handle($exception);
    }

    return $next($request);
}

... // 其他内容和原文件一致

public function handleDynamic(IlluminateRequest $request)
{
    ob_start();

    if ($this->isLumen()) {
        // dingo router 路由处理
        $response = app('Dingo\Api\Http\Middleware\Request')->handle($request, function ($request) {
            return $request;
        });
        
        // 不是 dingo router 里面定义的路由
        if ($response instanceof \Illuminate\Http\Request) {
            $response = $this->app->dispatch($response);
        }
        
        if ($response instanceof SymfonyResponse) {
            $content = $response->getContent();
        } else {
            $content = (string)$response;
        }

        if ($response instanceof \Symfony\Component\HttpFoundation\Response) {
            $this->reflectionApp->callTerminableMiddleware($response);
        }
    } else {
        $response = $this->kernel->handle($request);
        $content = $response->getContent();
        $this->kernel->terminate($request, $response);
    }

    // prefer content in response, secondly ob
    if (!($response instanceof StreamedResponse) && strlen($content) === 0 && ob_get_length() > 0) {
        $response->setContent(ob_get_contents());
    }

    ob_end_clean();

    return $response;
}

... // 其他内容和原文件一致

require_once $basePath . '/app/Swoole/Laravel.php';

<?php

namespace App\Cleaners;

use Hhxsv5\LaravelS\Illuminate\Cleaners\CleanerInterface;
use Illuminate\Container\Container;

class ControllerCleaner implements CleanerInterface
{
    public function clean(Container $app, Container $snapshot)
    {
        $ref = new \ReflectionObject($app);
        $property = $ref->getProperty('instances');
        $property->setAccessible(true);
        $instances = $property->getValue($app);

        foreach ($instances as $key => $instance) {
            if ($instance instanceof \Laravel\Lumen\Routing\Controller) {
                $instance = null;
                app()->offsetUnset($key);
            }
        }
    }
}

'cleaners' => [
    App\Cleaners\ControllerCleaner::class, // 单例控制器清除
],

<?php

namespace App\Cleaners;

use Dingo\Api\Http\Middleware\Request;
use Hhxsv5\LaravelS\Illuminate\Cleaners\CleanerInterface;
use Illuminate\Container\Container;

class MiddlewareCleaner implements CleanerInterface
{
    public function clean(Container $app, Container $snapshot)
    {
        $reflect = new \ReflectionObject($snapshot);
        $property = $reflect->getProperty('middleware');
        $property->setAccessible(true);

        $middleware = $property->getValue($snapshot);

        // 移除 Dingo\Api\Http\Middleware\Request，防止死循环
        $middleware = array_values(array_diff($middleware, [Request::class]));

        app(Request::class)->setMiddlewares($middleware);
    }
}

'cleaners' => [
    App\Cleaners\MiddlewareCleaner::class, // 单例控制器清除
],

$app->middleware([
    XxxMiddleware::class,
]);

foreach (\DB::connection('xxx')->getMongoDB()->listCollections() as $collection) {
    echo $collection->getName() . PHP_EOL;
}