Laravel 的 Pipeline 不是责任链模式,而是线性、不可中断的函数式调用链;每个阶段必须显式调用 $next($passable) 推进流程,否则静默中断,不抛异常也不自动终止传播。

直接说结论:Laravel 的 Pipeline 不是责任链模式,它本质是**线性、不可中断的函数式调用链**;强行模拟责任链(比如中途 return 退出)会破坏其设计契约,导致后续阶段被跳过但无提示——这是最常踩的坑。
为什么 Pipeline 不等于责任链模式
Laravel 的 Illuminate\Pipeline\Pipeline 没有「拦截并终止传播」的内置机制。每个闭包必须显式调用 $passable(即 $next($passable))才能进入下一环;不调用就静默结束,不会抛异常,也不会自动跳转到“最终返回值”。这和典型责任链中「处理器决定是否继续传递」的语义不同。
常见错误现象:
- 在中间件里写了
if ($x) return $passable;,结果后续阶段全丢了,调试时发现数据没被处理却无报错 - 误以为
then()返回值会自动作为下个阶段的输入——其实每个阶段都接收原始$passable,除非你手动传递修改后的值
正确用法:每个阶段必须调用 $next($passable)
标准写法要求每个可调用对象(闭包或类)都接收两个参数:$passable 和 $next,且必须调用 $next($passable)(或其变体)来推进流程。
示例:对用户数据添加时间戳并过滤敏感字段
use Illuminate\Pipeline\Pipeline;
$result = app(Pipeline::class)
->send($user)
->through([
function ($user, $next) {
$user['created_at'] = now()->toDateTimeString();
return $next($user); // 必须调用,否则中断
},
function ($user, $next) {
unset($user['password'], $user['api_token']);
return $next($user); // 同样必须
}
])
->then(function ($user) {
return $user;
});
关键点:
这是一个免费的企业网站系统,任何人可以免费下载、修改和使用本程序,也可以用来为企业建网站。没有任何功能限制,且不发布收费版。容兴免费企业网站系统后台功能简介:1.基本设置:基本信息,联系方式,网站设置,导航管理,模块启闭,静态设置,安全设置,数据库管理2.产品管理:产品列表,添加产品,产品分类3.文章管理:文章列表,发表文章,文章分类,公司简介,网站公告4.客服互动:留言管理,在线客服,友情链接5
-
$next是由 Pipeline 动态注入的闭包,不是你定义的函数名 - 所有中间逻辑必须基于传入的
$user做修改,并把修改后值传给$next(...) - 如果某个阶段想“短路”,只能靠抛异常,不能靠 return 值
想实现责任链?得自己封装或换方案
若真需要「某阶段决定是否继续」的能力(如权限校验失败就终止),Pipeline 不适合直接使用。可行替代方式:
- 用普通数组 +
foreach循环,每个处理器返回布尔值控制是否继续 - 自定义一个带
handle($input, $shouldContinue)接口的类集合,手动管理流转 - 改用 Laravel 的
Middlewares(在 HTTP 生命周期中天然支持return response()中断)
例如简单责任链示例:
$handlers = [
fn($data) => $data['age'] >= 18 ? true : (abort(403, 'Under age'), false),
fn($data) => isset($data['email']) ? true : (abort(400, 'Email required'), false),
];
$input = ['age' => 17, 'email' => 'a@b.c'];
foreach ($handlers as $handler) {
if (!$handler($input)) break;
}
容易被忽略的细节:$next 的执行时机与异常捕获
$next($passable) 实际触发的是下一个阶段的执行,不是“注册”;也就是说,Pipeline 构建时不做任何调用,then() 才真正开始运行整个链条。这意味着:
- 无法在
through()阶段做类型检查或提前验证 - 异常发生在哪个阶段,堆栈里只会显示
then()调用点,需结合日志定位具体闭包 - 若某阶段抛出异常,
$next后面的代码不会执行,但前面已完成的操作不可回滚(无事务保障)
所以实际项目中,建议每个阶段尽量轻量、幂等,并在外层加 try/catch 处理整体失败。









