PHP Pipeline 實現中介軟體的示常式式碼

Pipeline 設計模式
水管太長，只要有一處破了，就會漏水了，而且不利於複雜環境彎曲轉折使用。所以我們都會把水管分成很短的一節一節管道，然後最大化的讓管道大小作用不同，因地制宜，組裝在一起，滿足各種各樣的不同需求。
由此得出 Pipeline 的設計模式，就是將複雜冗長的流程 (processes) 截成各個小流程，小任務。每個最小量化的任務就可以複用，透過組裝不同的小任務，構成複雜多樣的流程 (processes)。
最後將「輸入」引入管道，根據每個小任務對輸入進行操作 (加工、過濾)，最後輸出滿足需要的結果。
你可以拿koa的中介軟體機制來做參考 ，也就是我們常說的削洋蔥思路
在前端裡早期有一個工程打包工具 gulp 寫法就更能體現 pipeline
gulp.task('css', function(){ return gulp.src('client/templates/*.less') .pipe(less()) .pipe(minifyCSS()) .pipe(gulp.dest('build/css')) }); gulp.task('js', function(){ return gulp.src('client/javascript/*.js') .pipe(sourcemaps.init()) .pipe(concat('app.min.js')) .pipe(sourcemaps.write()) .pipe(gulp.dest('build/js')) }); gulp.task('default', [ 'html', 'css', 'js' ]);
IlluminatePipeline
Laravel 框架中的中介軟體，就是利用 IlluminatePipeline 來實現的，本來想寫寫我對 「Laravel 中介軟體」原始碼的解讀，但發現網上已經有很多帖子都有表述了，所以本文就簡單說說如何使用 IlluminatePipeline 。
public function demo(Request $request) { $pipe1 = function ($payload, Closure $next) { $payload = $payload + 1; return $next($payload); }; $pipe2 = function ($payload, Closure $next) { $payload = $payload * 3; return $next($payload); }; $data = $request->input('data', 0); $pipeline = new Pipeline(); return $pipeline ->send($data) ->through([$pipe1, $pipe2]) ->then(function ($data) { return $data; }); }
今天主要學習學習「Pipeline」，順便推薦一個 PHP 外掛： league/pipeline 。
composer require league/pipeline
使用起來也很方便
use LeaguePipelinePipeline; class TimesTwoStage { public function __invoke($payload) { return $payload * 2; } } class AddOneStage { public function __invoke($payload) { return $payload + 1; } } $pipeline = (new Pipeline) ->pipe(new TimesTwoStage) ->pipe(new AddOneStage); // Returns 21 $pipeline->process(10);
接下來我們新增FastRouter在我的專案中使用。
上面的程式碼修改成這樣
我們接下來看看 RespondJson 裡做了什麼.
<?php namespace PlatappsMiddlewares; class RespondJson { public function __invoke($payload) { header('Content-type:text/json'); return $payload; } }
就簡單的加了個 header
我們試試把註釋到一個渠道
我們再次訪問的時候就變成
當然這是很簡單的中介軟體，這種中介軟體遠遠不夠，這裡是核心程式碼，可以去這裡看看，也比較簡單。
我們最終需要修改pipe這個方法
namespace LeaguePipeline; class Pipeline implements PipelineInterface { /** * @var callable[] */ private $stages = []; /** * @var ProcessorInterface */ private $processor; public function __construct(ProcessorInterface $processor = null, callable ...$stages) { $this->processor = $processor ?? new FingersCrossedProcessor; $this->stages = $stages; } public function pipe(callable $stage): PipelineInterface { $pipeline = clone $this; $pipeline->stages[] = $stage; return $pipeline; } public function process($payload) { return $this->processor->process($payload, ...$this->stages); } public function __invoke($payload) { return $this->process($payload); } }
這麼多框架裡面我這裡建議拿Tp6的來做參考，功能還算夠用。
<?php

// +---------------------------------------------------------------------- //

| ThinkPHP [ WE CAN DO IT JUST THINK ] // +---------------------------------------------------------------------- //

| Copyright (c) 2006~2019 http://thinkphp.cn All rights reserved. // +---------------------------------------------------------------------- //

| Licensed ( http://www.apache.org/licenses/LICENSE-2.0 ) // +---------------------------------------------------------------------- //

| Author: yunwuxin<448901948@qq.com>// +----------------------------------------------------------------------

namespace think; use Closure; use Exception; use Throwable; class Pipeline { protected $passable; protected $pipes = []; protected $exceptionHandler; /** * 初始資料 * @param $passable * @return $this */ public function send($passable) { $this->passable = $passable; return $this; } /** * 呼叫棧 * @param $pipes * @return $this */ public function through($pipes) { $this->pipes = is_array($pipes) ? $pipes : func_get_args(); return $this; } /** * 執行 * @param Closure $destination * @return mixed */ public function then(Closure $destination) { $pipeline = array_reduce( array_reverse($this->pipes), $this->carry(), function ($passable) use ($destination) { try { return $destination($passable); } catch (Throwable | Exception $e) { return $this->handleException($passable, $e); } }); return $pipeline($this->passable); } /** * 設定異常處理器 * @param callable $handler * @return $this */ public function whenException($handler) { $this->exceptionHandler = $handler; return $this; } protected function carry() { return function ($stack, $pipe) { return function ($passable) use ($stack, $pipe) { try { return $pipe($passable, $stack); } catch (Throwable | Exception $e) { return $this->handleException($passable, $e); } }; }; } /** * 異常處理 * @param $passable * @param $e * @return mixed */ protected function handleException($passable, Throwable $e) { if ($this->exceptionHandler) { return call_user_func($this->exceptionHandler, $passable, $e); } throw $e; } }
這種寫法有什麼好？
其實就好就好在，你在處理一個請求的過程中，分配任務的時候，在處理的過程，每個中間的人，只要做自己處理的請求和結果還有請求即可。讓當資料到達Controller裡的時候，顯示業務邏輯的時候更加強大。