wildfire/pipeline_processor

多管道处理器

v0.1.2 2020-08-06 10:30 UTC

Requires

• php: >= 5.5
• guzzlehttp/guzzle: ~6.0
• monolog/monolog: ^1.0

Requires (Dev)

• phpunit/phpunit: 4.5.*

MIT

• wildfire

• pipeline_processor
• 多管道处理器

README

依赖

• PHP5.5+
• monolog/monolog

安装

composer require wildfire/pipeline_processor

使用

<?php
include 'vendor/autoload.php';

use \PipelineProcessor\PipelineProcessor;
use \PipelineProcessor\Handler\OrderHandler;
use \PipelineProcessor\Handler\PayHandler;
use \PipelineProcessor\Registry;

// 创建一些处理器
$order = new OrderHandler();
$pay = new PayHandler();

//创建一些通道
$application = new PipelineProcessor('application');
$api = new PipelineProcessor('api');

// 或者克隆第一个，只是改变下通道
$security = $api->withName('security');

//对通道应用哪些处理器
$application->pushHandler($pay);
$api->pushHandler($pay);
$security->pushHandler($pay);

$application1 = $application->withName('application1');
$api1 = $application->withName('api1');

//通道的另一种调用方式
Registry::addLogger($application1);
Registry::addLogger($api1);

//通道开始处理
$application->info('application');
$api->info('api');
$security->info('security');

Registry::application1()->info('application1');
Registry::api1()->info('api1');
Registry::clear();

创建Job处理类

<?php

namespace PipelineProcessor\Handler;

use PipelineProcessor\Handler\AbstractHandler;

// 必须继承PipelineProcessor\Handler\AbstractHandler, 并实现方法perform
class OrderHandler extends AbstractHandler
{
    protected function perform($record)
    {
        $this->getLogger()->info($record);
    }
}