Laravel怎么使用Pipeline(管道)处理复杂流程

Laravel Pipeline通过将数据依次传递给多个处理器来处理复杂流程，如用户注册后发送邮件、记录日志等。核心组件包括send传入初始对象、through指定处理器列表、then定义最终回调。每个处理器实现handle方法，接收数据和next回调，可修改数据或执行副作用后传递给下一个处理器。支持条件式添加处理器或在处理器内部判断是否继续，也可通过不调用$next()中断流程，配合try-catch处理异常。该模式提升代码清晰度与可维护性，适用于解耦多步骤业务逻辑。

在 Laravel 中，Pipeline（管道）是一个强大的设计模式工具，适合处理需要多个步骤依次处理同一数据的复杂流程。比如用户注册后的系列操作：发送欢迎邮件、记录日志、创建默认配置、推送通知等。使用 Pipeline 可以让代码更清晰、可维护性更高。

什么是 Pipeline？

Laravel 的 Pipeline 机制模仿了“流水线”工作方式：把一个对象传递给一系列处理器（类或闭包），每个处理器可以修改对象或执行副作用，然后交给下一个处理器。最终得到处理后的结果。

核心组件：

• Pipeline：Laravel 提供的类，用于串联处理器
• Through：指定处理器列表（中间件形式）
• Send：传入初始对象
• Then：定义最终回调，接收处理结果

如何使用 Pipeline 处理注册流程

假设我们要实现用户注册后的一系列操作，每个操作都封装成独立类。

CreateUserProfile.php

namespace App\Pipelines\Registration;

class CreateUserProfile
{
    public function handle($user, $next)
    {
        $user->profile()->create(['bio' => 'New user']);
        return $next($user);
    }
}

SendWelcomeEmail.php

Pixelcut

AI产品图片处理——背景移除替换、物体抹除和图片放大

下载

class SendWelcomeEmail
{
    public function handle($user, $next)
    {
        \Mail::to($user)->send(new WelcomeMail());
        return $next($user);
    }
}

LogUserRegistration.php

class LogUserRegistration
{
    public function handle($user, $next)
    {
        \Log::info('User registered: ' . $user->email);
        return $next($user);
    }
}

use Illuminate\Support\Facades\Pipeline;

class RegisterController extends Controller
{
    public function register(Request $request)
    {
        $user = User::create($request->only('name', 'email', 'password'));

        Pipeline::send($user)
                ->through([
                    CreateUserProfile::class,
                    SendWelcomeEmail::class,
                    LogUserRegistration::class,
                ])
                ->then(function ($user) {
                    return $user;
                });

        return response()->json(['message' => 'Registered successfully']);
    }
}

高级用法：条件式管道

有时某些步骤只在满足条件时才执行。可以在处理器内部判断，也可以动态构建管道。

$stages = [CreateUserProfile::class];

if ($user->wantsNewsletter()) {
    $stages[] = SubscribeToNewsletter::class;
}

Pipeline::send($user)->through($stages)->then(fn($user) => $user);

或者在处理器中控制是否继续：

class MaybeSendPromo
{
    public function handle($user, $next)
    {
        if (today()->isMonday()) {
            \Mail::to($user)->send(new PromoMail());
        }
        return $next($user); // 无论是否发邮件，继续流程
    }
}

异常处理与中断流程

如果某个处理器决定终止流程，可以直接返回结果，不再调用 $next()。

class CheckUserEligibility
{
    public function handle($user, $next)
    {
        if (! $user->isEligible()) {
            throw new \Exception('User not eligible');
        }

        return $next($user);
    }
}

使用 try-catch 包裹整个 Pipeline 调用。