Perl管道实现进程间通信的实例详解

发布时间:2019-09-03编辑:脚本学堂
本文详细介绍了perl中使用管道实现进程间通信的方法,举了一些perl进程间通信的例子,供大家学习参考。

本文主要内容:
Perl管道实现进程间通信

fork()函数:
作用:进程复制函数。
用法:$pid=fork();   
讲解:
无参数;当本进程为父进程时返回值为子进程的PID值,当进程为子进程时返回值为0。

实例:
 

复制代码 代码示例:

#!usr/bin/perl -w
$pid=fork();   #复制进程,并把返回值附入$pid
die "Error:$!n" unless defined $pid;  #制定程序的错误机制,此步可略

if($pid!=0){   #条件选择,测试$pid值,以确定为子进程还是父进程
  print"This is a main pid!PID is $$!n"; #$pid值不等于0,此为父进程(附:$$为保留变量,其值为此进程的PID)
}else{   #否则.....
  print"This is a sub pid!PID is $$!n";  #$pid值为0,此为子进程
}
exit 1;
 

分析:
以上程序没有父进程与子进程的明显分化,要将它们分开就要靠测试$pid的值,所以对fork()函数的调用来说条件语句是非常重要的,需要通过它们来辨别fork()的返回值。

注:fork()函数:
Does a fork(2) system call to create a new process running the same program at the same point.
fork以后,子进程从fork点开始和主进程运行相同的程序,所以可以通过测试$pid来使主进程和子进程运行不同的程序,子进程所做的工作结束后应该退出,不然会继续运行if代码块以后的父进程的程序,这样会运行两次父进程的程序。

fork,It clones off a duplicate process identical in virtually every aspect to its parent, including variable settings and open files.(《perl cookbook》)
例1,
 

复制代码 代码示例:

#!/usr/bin/perl -w
my $pid = fork();
if ($pid != 0) {
print "is parentn";
} else {
# this is the child process
print "is childn";  #子进程退出,会继续运行if一下的程序。
}

print 'program after "if"'."n" #会打印两次,一次是父进程打印,一次是子进程打印的。

例2,
 

复制代码 代码示例:
#!/usr/bin/perl -w
my $pid = fork();
if ($pid != 0) {
print "is parentn";
} else {
# this is the child process
print "is childn"; 
exit 0; #子进程退出,不会运行if以后的程序
}
print 'program after "if"'."n" #只有父进程打印一次

pipe():创建管道对。
格式: pipe(READ,WRITE);

The pipe function creates two connected filehandles, a reader and writer, whereby anything written to the writer can be read from the reader.(摘自《perl cookbook》)
pipe创建两个连接的句柄,一个读,一个写,任何写入到writer的都可以从reader中读出。

实 例:pipe(README,WRITEME); #创建了一个管道对,"README"用于读,"WRITEME"用于写。
 

复制代码 代码示例:
$aaa=pipe(AAA,BBB); #创建了一个管道对,"AAA"用于读,"BBB"用于写,$aaa变量为调用pipe()的返回值。

讲解:正常调用后返回值为非零数,第一个参数为被创建的读管道,第二个参数为被创建的写管道。此函数通常配合进程中 的fork()函数一同使用,步骤是先使用pipe()函 数建立管道对,再使用fork()创建新进程,在不同的进程关闭不同的管道,这样就可以达到管道间通信的目的了。

close(): 关闭管道
格式: close(AAA);
close BBB;

讲 解:close()在调用时能将子程序的终止代码放到特殊变量$?中;当关闭的是写管道时close()调用将进入堵塞状态直至另一端完成它的 全部工作为止。
 
子进程通过父进程获得输入
 

复制代码 代码示例:

#!/usr/bin/perl -w
my $uid ="test 123";

pipe(CHILD_RDR, PARENT_WTR);
my $pid = fork();
if ($pid != 0) {
#this is parent process
close CHILD_RDR;
print PARENT_WTR "$uid";
} else {
# this is the child process
close PARENT_WTR;
$u = <CHILD_RDR>;
print $u;

}

父进程通过子进程获得输入
 

复制代码 代码示例:

#!/usr/bin/perl -w
my $uid ="test 123";

pipe(PARENT_RDR, CHILD_WTR);
my $pid = fork();
if ($pid == 0) {
#this is child process
close PARENT_RDR;
print CHILD_WTR "$uid";
} else {
# this is the parent process
close CHILD_WTR;
$u = <PARENT_RDR>;
print $u;

}

子进程和父进程双向通信:
http://perldoc.perl.org/perlipc.html#Bidirectional-Communication-with-Yourself
 

复制代码 代码示例:

#!/usr/bin/perl -w
# pipe1 - bidirectional communication using two pipe pairs
# designed for the socketpair-challenged
use IO::Handle; # thousands of lines just for autoflush :-(

pipe(PARENT_RDR, CHILD_WTR); # XXX: failure?
pipe(CHILD_RDR, PARENT_WTR); # XXX: failure?
CHILD_WTR->autoflush(1); 
PARENT_WTR->autoflush(1);

if ($pid = fork) {
  #this is parent process
  close PARENT_RDR; close PARENT_WTR;
  print CHILD_WTR "Parent Pid $$ is sending thisn";
  chomp($line = <CHILD_RDR>);
  print "Parent Pid $$ just read this: `$line'n";
  close CHILD_RDR; close CHILD_WTR;
  waitpid($pid,0);
}
else
{
  #this is child process
  die "cannot fork: $!" unless defined $pid;
  close CHILD_RDR; close CHILD_WTR;
  chomp($line = <PARENT_RDR>);
  print "Child Pid $$ just read this: `$line'n";
  print PARENT_WTR "Child Pid $$ is sending thisn";
  close PARENT_RDR; close PARENT_WTR;
  exit;
}
 

改进版:
 

复制代码 代码示例:
#!/usr/bin/perl -w
# pipe6 - bidirectional communication using socketpair
# "the best ones always go both ways"
 
  use Socket;
  use IO::Handle;
  # We say AF_UNIX because although *_LOCAL is the
  # POSIX 1003.1g form of the constant, many machines
  # still don't have it.
  socketpair($child, $parent, AF_UNIX, SOCK_STREAM, PF_UNSPEC)
      or die "socketpair: $!";
 
  $child->autoflush(1);
  $parent->autoflush(1);
 
  if ($pid = fork) {
      close $parent;
      print $child "Parent Pid $$ is sending thisn";
      chomp($line = <$child>);
      print "Parent Pid $$ just read this: '$line'n";
      close $child;
      waitpid($pid,0);
  } else {
      die "cannot fork: $!" unless defined $pid;
      close $child;
      chomp($line = <$parent>);
      print