Laravel Pipeline通过将复杂流程拆分为多个独立处理步骤，实现代码解耦与职责分离。以用户注册为例，可依次执行发送欢迎邮件、分配角色、记录日志等操作，每个步骤由单独类实现__invoke方法，通过Pipeline::send($user)->through([...])->then()串联执行，数据依次流过各处理器，便于维护和扩展。
Laravel 的 Pipeline 模式是一种优雅的处理复杂业务逻辑的方式，特别适合需要经过多个步骤或中间处理的场景，比如用户注册后的系列操作、订单创建流程、数据校验与转换等。它通过将多个处理类串联起来，让数据依次“流过”每个处理器，从而实现职责分离和代码解耦。
什么是 Laravel Pipeline
Laravel 自带的 Pipeline 类位于 Illuminate\Pipeline\Pipeline，它允许你将一个对象传递给一系列“管道”（即处理类或闭包），每个管道都可以对这个对象进行处理，然后传递给下一个，直到流程结束。
这种模式的核心思想是：把复杂的流程拆分成多个独立的小步骤，每一步只关注自己的任务，便于维护和测试。
如何使用 Pipeline 处理复杂逻辑
以“用户注册后的一系列操作”为例，比如发送欢迎邮件、分配默认角色、记录日志、触发事件等，我们可以用 Pipeline 来组织这些步骤。
1. 定义处理类每个步骤写成一个独立的类，实现 __invoke 方法（因为 Pipeline 会调用它们为可调用对象）：
app/Pipelines/SendWelcomeEmail.php
to($user->email)->subject('欢迎');
});
return $next($user);
}
}
app/Pipelines/AssignDefaultRole.php
assignRole('member'); // 假设有权限系统
return $next($user);
}
}
app/Pipelines/LogUserRegistration.php
name} ({$user->email})");
return $next($user);
}
}
2. 在控制器中使用 Pipeline在注册成功后，启动 Pipeline 流程：
use Illuminate\Support\Facades\Pipeline;
$user = User::create([
'name' => '张三',
'email' => 'zhangsan@example.com',
'password' => bcrypt('123456')
]);
Pipeline::send($user)
->through([
\App\Pipelines\SendWelcomeEmail::class,
\App\Pipelines\AssignDefaultRole::class,
\App\Pipelines\LogUserRegistration::class,
])
->then(function ($user) {
// 最终回调
return response()->json(['message' => '注册成功', 'user' => $user]);
});
Pipeline 的执行流程说明
调用 send() 设置初始对象，through() 指定处理类数组，then() 定义最终回调。每个处理器接收两个参数：当前对象和下一个闭包（$next），必须调用 $next($object) 才能继续流程。
如果某个步骤中断（比如验证失败没调用 $next），后续步骤就不会执行，可用于条件控制。
实际应用场景建议
- 订单创建流程：库存检查 → 扣减库存 → 创建订单 → 支付初始化 → 发送通知
- API 数据预处理：参数清洗 → 格式转换 → 权限校验 → 缓存检查
- 用户认证扩展：多因素验证、登录设备记录、风险检测等
使用 Pipeline 后，主逻辑更清晰，新增或调整步骤只需修改 through 数组或增加类，不影响原有代码。
基本上就这些。Laravel Pipeline 不复杂但容易忽略，合理使用能让代码更整洁、可维护性更强。
