Perl：替换open '|-'管道为自定义/IPC::Open2管道的问题

一、手动用fork+pipe实现管道链 #

你之前用fork+pipe失败是因为管道创建和子进程文件句柄重定向处理不到位，以下是实现echo foo | tee /dev/stderr | tee /dev/stderr逻辑的完整代码：

#!/usr/bin/perl
use strict;
use warnings;

sub create_tee_chain_fh {
    # 创建第一个管道（父进程 -> 第一个tee）
    pipe(my $rd1, my $wr1) or die "Pipe 1 failed: $!";
    my $pid1 = fork();
    die "Fork 1 failed: $!" unless defined $pid1;

    if ($pid1 == 0) {
        # 第一个tee子进程：关闭写端，重定向stdin到管道读端
        close $wr1;
        open(STDIN, '<&', $rd1) or die "Redirect stdin failed: $!";
        close $rd1;

        # 创建第二个管道（第一个tee -> 第二个tee）
        pipe(my $rd2, my $wr2) or die "Pipe 2 failed: $!";
        my $pid2 = fork();
        die "Fork 2 failed: $!" unless defined $pid2;

        if ($pid2 == 0) {
            # 第二个tee子进程：关闭写端，重定向stdin到管道读端
            close $wr2;
            open(STDIN, '<&', $rd2) or die "Redirect stdin failed: $!";
            close $rd2;

            # 重定向stdout到/dev/null（无需继续传递内容）
            open(STDOUT, '>', '/dev/null') or die "Redirect stdout failed: $!";
            exec('tee', '/dev/stderr') or die "Exec tee 2 failed: $!";
        } else {
            # 第一个tee子进程：关闭读端，重定向stdout到第二个管道写端
            close $rd2;
            open(STDOUT, '>&', $wr2) or die "Redirect stdout failed: $!";
            close $wr2;

            exec('tee', '/dev/stderr') or die "Exec tee 1 failed: $!";
        }
    } else {
        # 父进程：关闭读端，返回写端作为输出句柄
        close $rd1;
        return $wr1;
    }
}

# 使用示例
my $fh;
# 根据条件选择不同管道
if (1) { # 替换为你的实际条件
    $fh = create_tee_chain_fh();
} else {
    # 原有其他命令管道逻辑
    open $fh, '|-', 'cat' or die "Open cat failed: $!";
}

# 写入内容（与原有逻辑一致）
print $fh "foo\n";
close $fh; # 关闭句柄触发数据流传递，等待子进程结束

关键注意事项 #

• 每个子进程必须关闭不需要的管道端，避免因句柄未关闭导致进程阻塞等待输入。
• 子进程通过open(STDIN, '<&', $rd)和open(STDOUT, '>&', $wr)完成标准IO重定向，确保命令能从管道读取、写入数据。
• 父进程仅保留最终的写句柄，写入后关闭它，触发所有子进程的数据流传递。

二、用IPC::Open3实现管道链（更简洁） #

如果不想手动处理fork和管道细节，IPC::Open3可更灵活地处理多进程IO重定向，以下是实现相同逻辑的代码：

#!/usr/bin/perl
use strict;
use warnings;
use IPC::Open3;
use Symbol 'gensym';

sub create_tee_chain_fh {
    # 启动第一个tee：stdin来自父进程，stdout指向第二个tee
    my ($w1, $r1, $e1);
    $e1 = gensym;
    my $pid1 = open3($w1, $r1, $e1, 'tee', '/dev/stderr');

    # 启动第二个tee：stdin来自第一个tee的stdout，stdout丢弃到/dev/null
    my ($w2, $r2, $e2);
    $e2 = gensym;
    my $pid2 = open3($w2, $r2, $e2, 'tee', '/dev/stderr');

    # 将第一个tee的stdout连接到第二个tee的stdin
    open($w2, '<&', $r1) or die "Connect pipes failed: $!";
    close $r1;
    close $r2; # 第二个tee的stdout无需保留，直接关闭
    close $e1; close $e2; # 忽略错误输出，如需处理可保留句柄

    # 返回第一个tee的输入句柄，供父进程写入
    return $w1;
}

# 使用示例与之前一致
my $fh;
if (1) {
    $fh = create_tee_chain_fh();
} else {
    open $fh, '|-', 'cat' or die "Open cat failed: $!";
}

print $fh "foo\n";
close $fh;

# 等待所有子进程结束
waitpid $_, 0 for ($pid1, $pid2);

之前IPC::Open2失败的原因 #

IPC::Open2仅支持单个子进程的双向管道（父进程读写单个进程），不适合直接构建多进程链。你之前只输出一次foo，核心问题是没有将第一个进程的stdout连接到第二个进程的stdin，导致第二个进程无输入、无输出。而IPC::Open3可分别处理stdin、stdout、stderr，更适合构建进程链。

三、与原有逻辑的整合 #

不管采用哪种方式，都可以将管道链的创建封装成子函数，返回一个可写的文件句柄$fh，主程序的写入逻辑无需修改，只需在条件分支中调用对应的创建函数即可。

内容的提问来源于stack exchange，提问作者josch