perl 双向管道 调用本地脚本问题

mrstupid

程序目的是将一个输入导向一个本地的perl脚本, 再将这个脚本执行结果返回到当前的脚本, 使用open2双向管道操作, 但是总是不能成功, 请各位大大看看:

问题好像是本地脚本XXX.pl执行有问题, 因为是双向通信, 在IO上使用异步通信, select+sysread实现非阻塞的管道读取.


代码1， 主脚本代码:

2. #!/usr/bin/perl -w
3. use strict;
4. BEGIN {
5.         push(@INC, ".");
6. }
7. use FileHandle;
8. use IPC::Open2;
11. my %test_h = ();
13. sub test {
14.         my $in;
15.         my $out;
16.         #my $pid = open2($in, $out, "cat " );
17.         my $pwd = `pwd`;
18.         chomp($pwd);
19.     my $pid = open2($test_h{"in"}, $test_h{"out"}, "./XXX1.pl" );
20.         printf STDOUT ("%x %d    %x   %d\n", $test_h{"in"}, fileno($test_h{"in"}), $test_h{"out"}, fileno($test_h{"out"}));
21.     while(1) {
22.                 my $out = $test_h{"out"};
24.                 printf $out ("%s", "stuff\n");                            #先向管道中输入一些字符串.
25.                 printf $out ("stuff\n");
27.                 my $in = $test_h{"in"};
28.                 #my $got = <$in>;
29.                 #my $got = <{$test_h{"in"}}>;
30.                 #printf STDOUT ("WE GET: %s\n", $got);
31.         my ($eof, @lines) = &nonblockGetLines($in);          #尝试从管道中进行读取,
32.                 if($eof) { last; }
33.                 foreach my $line (@lines) {
34.                         printf STDOUT ("GOT: %s\n", $line);
35.                 }
36.         sleep(1);
37.     }
38. }
40. # Returns:  ($eof,@lines)
41. my %nonblockGetLines_last;
42. sub nonblockGetLines {
43.         my $fh = $_[0];
44.         my $rfd = '';
45.         $nonblockGetLines_last{$fh} = ''
46.                 unless defined $nonblockGetLines_last{$fh};
48.         #set file handle bit mask
49.         vec($rfd, fileno($fh), 1) = 1;
50.         #if something's coming
51.         my $out_fd = 0;
52.         if (not select($out_fd=$rfd, undef, undef, 0)>=0 )
53.         {
54.                 printf STDERR ("%x select not ready.\n", $fh);
55.                 return (0);
56.         }
57.         printf STDERR ("OUT_FD:%x   IN_FD:%x  fileno: %d \n", ord($out_fd), ord($rfd), fileno($fh));
59.    
60.         ##        ##        ##        ##        ##        ##        ##        ##        ##
61.         # 使用select+sysread进行nonblock的管道读取.
62.         #   
63.         #            这里$out_fd总是0， 即是说西面的XXX.pl没有print任何东西.
64.         ##        ##        ##        ##        ##        ##        ##        ##        ##
66.         if(not vec($out_fd, fileno($fh), 1)) {   
67.                 printf STDERR ("%x not this one.\n", $fh);
68.                 return (0);
69.         }
70.         my $buf = '';
71.         my $n = sysread($fh, $buf, 1024*1024, 0);               
72.         if ( ! defined $n ) {
73.                 #on error, we just print an error message
74.                 printf STDERR ("MAPPER: %x got a read error at input line.\n", $fh);
75.         }elsif($n == 0) {
76.                 # If we're done, make sure to send the last unfinished line
77.                 return (1,$nonblockGetLines_last{$fh});
78.         }
79.         # Prepend the last unfinished line
80.         $buf = $nonblockGetLines_last{$fh}.$buf;
81.         # And save any newly unfinished lines
82.         if(substr($buf,-1) !~ /[\r\n]/ && $buf =~ s/([^\r\n]*)$//) {
83.                 $nonblockGetLines_last{$fh} = $1;
84.         } else {
85.                 $nonblockGetLines_last{$fh} = '';
86.         }
87.         return $buf ? (0,split(/\n/,$buf)) : (0);
88. }
90. &test();

复制代码

脚本2: 被调用的本地脚本XXX1.pl:

2. #!/usr/bin/perl -w
3. #
6. while(<STDIN>) {    ###echo接收到的字符串
7.         print "M2\t", $_;
8. }

复制代码

mrstupid

如果我将调用脚本的语句写成:

"cat"
那么程序是可以顺利打印出东西, 但是改成 "./XXX.pl" "perl ./XXX.pl" 都不行, 可以肯定的是XXX.pl是执行起来了的, 我在XXX.pl里面创建文件, 可以看到文件被创建了. 就是接收不到字符串.

mrstupid

好像是buffer的问题, 不是不出东西, 我在XXX.pl里面设置
local $| = 1;
以后, 就可以得到输出了.

对管道通信还不熟, 有熟悉的大大可以讲讲为什么这里buffer不flush, 主脚本就一点数据都得不到吗?