无码潮喷A片无码高潮视频电车痴汉,可以直接进入网站的正能量视频,亚洲AV成人精品日韩一区18p

主頁 > 知識庫 > PHP Pipeline 實現(xiàn)中間件的示例代碼

PHP Pipeline 實現(xiàn)中間件的示例代碼

Pipeline 設計模式

水管太長，只要有一處破了，就會漏水了，而且不利于復雜環(huán)境彎曲轉折使用。所以我們都會把水管分成很短的一節(jié)一節(jié)管道，然后最大化的讓管道大小作用不同，因地制宜，組裝在一起，滿足各種各樣的不同需求。

由此得出 Pipeline 的設計模式，就是將復雜冗長的流程 (processes) 截成各個小流程，小任務。每個最小量化的任務就可以復用，通過組裝不同的小任務，構成復雜多樣的流程 (processes)。

最后將「輸入」引入管道，根據(jù)每個小任務對輸入進行操作 (加工、過濾)，最后輸出滿足需要的結果。

你可以拿koa的中間件機制來做參考，也就是我們常說的削洋蔥思路

在前端里早期有一個工程打包工具gulp寫法就更能體現(xiàn)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 框架中的中間件，就是利用 Illuminate\Pipeline 來實現(xiàn)的，本來想寫寫我對「Laravel 中間件」源碼的解讀，但發(fā)現(xiàn)網(wǎng)上已經(jīng)有很多帖子都有表述了，所以本文就簡單說說如何使用 Illuminate\Pipeline。

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 League\Pipeline\Pipeline;

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 Platapps\Middlewares;
class RespondJson
{
  public function __invoke($payload)
  {
    header('Content-type:text/json');
    return $payload;
  }
}

就簡單的加了個 header

我們試試把注釋到一個渠道

我們再次訪問的時候就變成

當然這是很簡單的中間件，這種中間件遠遠不夠，這里是核心代碼，可以去這里看看，也比較簡單。

我們最終需要修改pipe這個方法

namespace League\Pipeline;

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;

  /**
   * 初始數(shù)據(jù)
   * @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;
  }

  /**
   * 執(zhí)行
   * @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;
  }
}

這種寫法有什么好？

其實就好就好在，你在處理一個請求的過程中，分配任務的時候，在處理的過程，每個中間的人，只要做自己處理的請求和結果還有請求即可。讓當數(shù)據(jù)到達Controller里的時候，顯示業(yè)務邏輯的時候更加強大

到此這篇關于PHP Pipeline 實現(xiàn)中間件的示例代碼的文章就介紹到這了,更多相關PHP Pipeline 中間件內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

您可能感興趣的文章:

Golang之casbin權限管理的實現(xiàn)
thinkphp5.1的model模型自動更新update_time字段實例講解
Thinkphp5.1獲取項目根目錄以及子目錄路徑的方法實例講解
Thinkphp使用Zxing擴展庫解析二維碼內容圖文講解
laravel與thinkphp之間的區(qū)別與優(yōu)缺點
ThinkPHP的標簽制作實例講解
thinkphp的鉤子的兩種配置和兩種調用方法
ThinkPHP6.0如何利用自定義驗證規(guī)則規(guī)范的實現(xiàn)登陸
如何使用Casbin作為ThinkPHP的權限控制中間件

標簽：南通黃山隴南河南武漢唐山通遼平頂山

巨人網(wǎng)絡通訊聲明：本文標題《PHP Pipeline 實現(xiàn)中間件的示例代碼》，本文關鍵詞 PHP,Pipeline,實現(xiàn),中間件,；如發(fā)現(xiàn)本文內容存在版權問題，煩請?zhí)峁┫嚓P信息告之我們，我們將及時溝通與處理。本站內容系統(tǒng)采集于網(wǎng)絡，涉及言論、版權與本站無關。