php实现管道
PHP 实现管道的方法
在 PHP 中，管道（Pipeline）通常指将多个操作串联起来，前一个操作的输出作为后一个操作的输入。以下是几种实现方式：
使用函数式编程风格
通过链式调用函数或方法实现管道：
function pipe($value, ...$callbacks) {
foreach ($callbacks as $callback) {
$value = $callback($value);
}
return $value;
}
$result = pipe(
5,
fn($x) => $x * 2,
fn($x) => $x + 3,
fn($x) => $x / 2
);
// 结果为 (5*2 +3)/2 = 6.5使用对象方法链
面向对象风格可以通过返回 $this 实现链式调用：
class Pipeline {
private $value;
public function __construct($value) {
$this->value = $value;
}
public function then(callable $callback) {
$this->value = $callback($this->value);
return $this;
}
public function get() {
return $this->value;
}
}
$result = (new Pipeline(5))
->then(fn($x) => $x * 2)
->then(fn($x) => $x + 3)
->then(fn($x) => $x / 2)
->get();使用生成器（Generator）
对于大数据处理，可以使用生成器实现惰性求值的管道：
function generatorPipe(iterable $input, callable ...$stages) {
foreach ($input as $item) {
$value = $item;
foreach ($stages as $stage) {
$value = $stage($value);
}
yield $value;
}
}
$data = [1, 2, 3, 4];
$pipeline = generatorPipe(
$data,
fn($x) => $x * 2,
fn($x) => $x + 1
);
foreach ($pipeline as $result) {
echo $result . "\n";
}
// 输出 3, 5, 7, 9使用 PHP 的管道操作符（PHP 8.1+）
PHP 8.1 引入了部分管道支持：
$result = strtoupper(
str_replace('_', ' ',
'hello_world'
)
);
// 可改写为：
$result = 'hello_world'
|> str_replace('_', ' ', ...)
|> strtoupper(...);实际应用示例
处理用户输入数据的管道：
function sanitizeInput(string $input): string {
return pipe(
$input,
fn($x) => trim($x),
fn($x) => htmlspecialchars($x),
fn($x) => stripslashes($x)
);
}以上方法可根据具体场景选择使用，函数式风格适合简单转换，对象方法链适合复杂流程，生成器适合大数据处理。
