laravel怎么使用Pipeline模式来组织业务逻辑_laravel Pipeline模式业务逻辑组织方法-Laravel-PHP中文网

laravel怎么使用Pipeline模式来组织业务逻辑_laravel Pipeline模式业务逻辑组织方法

冰火之心

发布： 2025-10-29 16:55:01

原创

226人浏览过

Laravel Pipeline通过链式调用将业务逻辑解耦，以用户注册为例，可依次执行发送邮件、记录日志等操作，每个处理器专注单一职责并通过__invoke传递数据，结合Service类提升可维护性，适用于多步骤、可复用的业务流程。

laravel怎么使用pipeline模式来组织业务逻辑_laravel pipeline模式业务逻辑组织方法

在 Laravel 中，Pipeline（管道）模式是一种优雅的方式来组织和处理业务逻辑的链式调用。它允许你将多个中间件式的处理步骤串联起来，每个步骤只关注自己的职责，最终将数据“传递”到终点。这种模式特别适合处理复杂的业务流程，比如订单创建、用户注册后的多步操作等。

理解 Laravel Pipeline 的核心概念

Laravel 的 Pipeline 类位于 Illuminate\Pipeline\Pipeline，它的设计灵感来源于 HTTP 中间件机制，但可以用于任意对象的处理流程。

核心思想是：把一个对象依次通过多个“处理器”（可类比为中间件），每个处理器可以修改或验证该对象，最后返回最终结果。

你需要明确三个要素：

初始对象：被传递的数据，如用户输入、订单模型等
经过的处理器：每一个闭包或类，用来处理逻辑
最终执行的方法：所有处理器完成后调用的终点方法

如何使用 Pipeline 组织业务逻辑

以用户注册后的一系列操作为例：发送欢迎邮件、记录日志、分配默认角色、触发事件等。

你可以把这些步骤拆解为独立的处理器，然后通过 Pipeline 串起来：

use Illuminate\Support\Facades\Bus;
use Illuminate\Pipeline\Pipeline;

$registeredUser = app(Pipeline::class)
    ->send($user) // 初始对象
    ->through([
        \App\Pipelines\SendWelcomeEmail::class,
        \App\Pipelines\LogUserRegistration::class,
        \App\Pipelines\AssignDefaultRole::class,
        \App\Pipelines\FireRegisteredEvent::class,
    ])
    ->then(function ($user) {
        return $user;
    });

登录后复制

每个类需要实现 __invoke 方法：

千帆大模型平台

面向企业开发者的一站式大模型开发及服务运行平台

查看详情

// app/Pipelines/AssignDefaultRole.php
namespace App\Pipelines;

use Closure;

class AssignDefaultRole
{
    public function __invoke($user, Closure $next)
    {
        $user->assignRole('member'); // 假设有 RBAC 实现

        return $next($user);
    }
}

登录后复制

注意：每个处理器必须调用 $next($user) 将对象传递给下一个环节，否则流程会中断。

结合 Service 类提升可维护性

为了不让控制器变得臃肿，建议将 Pipeline 调用封装到专门的服务类中：

// app/Services/UserRegistrationService.php
namespace App\Services;

use Illuminate\Pipeline\Pipeline;

class UserRegistrationService
{
    public function register(array $data)
    {
        $user = User::create($data);

        return app(Pipeline::class)
            ->send($user)
            ->through($this->stages())
            ->then(fn ($user) => $user);
    }

    protected function stages(): array
    {
        return [
            SendWelcomeEmail::class,
            LogUserRegistration::class,
            AssignDefaultRole::class,
            FireRegisteredEvent::class,
        ];
    }
}

登录后复制

在控制器中调用就非常简洁：

public function store(Request $request, UserRegistrationService $service)
{
    $user = $service->register($request->validated());

    return redirect()->home();
}

登录后复制