如何从调用该程序的 Perl 程序中观察正在运行的程序的 STDOUT？

Question

我们试图弄清楚如何从 Perl 脚本中运行 Java 应用程序，但仍然能够定期从 Java 应用程序的 STDOUT 中读取数据。

print "running dcmrcv.bat\n";

open my $fh_dcmrcv, "-|", 'z:\apps\dcm4che\dcm4che-2.0.26\bin\dcmrcv.bat \
  DCMRCV:11112 -dest z:\dcmrcv -journal z:\dcmrcv', 
  or die "could not execute dcmrcv: $!";

print "dcmrcv.bat started\n";

我们希望能够每隔几分钟从文件句柄 $fh_dmcrcv 读取一次，或者在文件句柄上有活动时设置 AnyEvent io 触发器。

但是，当我尝试从文件句柄读取时，如果我使用类似以下的内容，它会被阻止：

foreach my $line (<$fh_dmcrcv>) {
  print $line;
}

我们已经尝试了几种方法，不认为我们可以使用 File::Tail，因为模块似乎需要一个实际的文件。问题似乎是 $fh_dcmrcv 在我们读取它时阻止了我们，并不确定如何实现我们想要的正确方法。

编辑 #1

当我们运行 Perl 脚本时，我们会看到如下输出：

Z:\projects\demo_2>process_files.pl
running dcmrcv.bat
dcmrcv.bat started
Start Server listening on port 11112
11:55:13,495 INFO   - Start listening on 0.0.0.0/0.0.0.0:11112

脚本 process_files.pl 正在发出消息

running dcmrcv.bat
dcmrcv.bat started

。来自java程序的是： 启动服务器监听11112端口 11:55:13,495 INFO - 开始监听 0.0.0.0/0.0.0.0:11112

在这种情况下，我们只是为了这个问题而回显这些内容，实际上我们希望定期解析某些消息。并且永远不要重复其中任何一个。

任何见解都值得赞赏，

-Sam

Answer 1

大多数系统都支持 4 参数 select 函数（也很好地封装在 中） IO::Select) 可以告诉您套接字句柄或管道句柄上是否有输入等待。在 Windows 中，仅在套接字上支持 select，这导致了这种拜占庭解决方案：

1. 创建套接字对
2. Fork 并在子进程中运行命令 在子进程
3. 中，检索命令输出并将其写入socket
4. 在父级中，根据需要在套接字上使用选择和读取操作

示例：

use Socket;
use IO::Select;
use Time::HiRes;
$cmd = $^X . ' -MMath::BigInt -e "$_=1; '
       . 'print qq/$_!=/,Math::BigInt->new($_)->bfac(),qq/\n\n\n/'
       . ' for 4000..4100"';
socketpair A,B,AF_UNIX,SOCK_STREAM,PF_UNSPEC;  # step 1
if (fork() == 0) {
    open my $fh, '-|', $cmd;                   # step 2
    while (<$fh>) {
        print B;                               # step 3
    }
    close $fh;
    exit $? >> 8;
}
$s = IO::Select->new();
$s->add(\*A);
for (;;) {
    if ($s->can_read(0.25)) {                  # step 4
        $line = <A>;
        print "Do something with command output: $line";
    } else {
        print "No output now. Could be doing something else ...\n";
        Time::HiRes::sleep(0.25);
    }
}

您确定不想将命令输出写入临时文件吗？

Answer 2

使用 IO::Select 或四个参数select()读取时读取不会阻塞。 编辑：没关系，你在 Windows 上，所以这不起作用。一种选择：让一个中间进程从此管道中读取数据，并保留一个中间文件，其中包含您需要的任何尾部长度。布莱赫。

也就是说，从管道中“每隔几分钟”读取一次的最佳方法是每隔几秒读取一次。

Answer 3

尝试用这个代替阅读：

while (my $line = <$fh_dmcrcv>) {
   print $line;
}

问候