Laravel Pipeline通过链式调用将业务逻辑解耦，以用户注册为例，可依次执行发送邮件、记录日志等操作，每个处理器专注单一职责并通过__invoke传递数据，结合Service类提升可维护性，适用于多步骤、可复用的业务流程。
在 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();
}
适用场景与注意事项
Pipeline 模式适用于以下情况：
- 多个顺序执行的业务步骤
- 每一步都可以独立测试和复用
- 需要灵活增减处理环节
- 希望避免“面条代码”式的长方法
需要注意：
- 不要在某个处理器中做耗时操作（如大量计算或同步网络请求），考虑使用队列
- 如果某步失败，应抛出异常或在内部处理错误，避免静默失败
- 调试时可通过日志跟踪每一步的状态变化
基本上就这些。Laravel 的 Pipeline 让你用清晰的方式组织复杂流程，代码更易读、易维护，也更容易扩展。关键是把每个处理单元做得小而专注。
