Perl进程间通讯研究


Perl进程间通讯前几天做了一个比较简单的东西,但感觉比较意思就在这里记下来。大概的需求是这样的:有一个程序在会产生一些警告信息并保存在/var/log/alert中的。如果有新的警告信息时就要在服务器上发出警告的声音,但启动是通过web界面的而不是在命令行。

  刚开始想到步骤是这样的:

  1、 因为是要在后台运行,肯定是fork一个子进程,父进程退出而不会使web程序阻塞在此,

  2、 然后再fork一个子进程,父进程负责监听日志文件的更新。子进程负责调用声音程序。两者之者用管道通讯。

  3、 要实时监控日志文件的更新,因为不想搞太复杂就用管道的方式:open(LOG,"tail -n 2 -f  /var/log/alert| ") ||die "Unable to open log file $!\n";这样就可以简单的得到文件的实时更新

  4、 要考虑到退出,所以需要一个文件保存进程ID。

  这样实现的代码很简单:

  my $pidfile ="/tmp/alertsounds.pid";

  sub StartAlertSounds{

  my $pid;

  if ($pid = fork()) {

  return;

  } elsif (defined $pid) {

  system("echo pid=$ > $pidfile'");#保存进程ID

  &RunAlertSounds();

  }

  }else {

  die "Can't fork: $!\n";

  }

  }

  sub RunAlertSounds{

  my $pid;

  pipe(README, WRITEME);

  if ($pid = fork()) { #父进程

  close(README);

  open(LOG,"tail -n 2 -f  /var/log/alert| ") ||die "Unable to open log file $!\n";

  while (<LOG>) {

  print WRITEME "Sounds\n";

  }

  close(LOG );

  close(WRITEME);

  }elsif (defined $pid) { #子进程

  close(WRITEME);

  while(<README>){

  system("/usr/bin/sounds/AlertSounds >/dev/null 2>&1");

  }

  close(README);

  }else {

  die "Can't fork: $!\n";

  }

  }

  但测试一下就发现了不少问题:

  1、 退出时open(LOG,"tail -n 2 -f  /var/log/snort/alert| ")所产生的子进程不会一起退出。

  2、 当短时间内(比如1秒)有多条信息过来时,我们希望只产生一条警告声音,但现在会连续响多条。

  3、 有时父进程往管道写数据时子进程不一定能马上收到;

  分析一下就有下面的解决方法:

  1、 使父进程成为进程组的头领进程,然后在父进程退出前给进程组发送退出信号。

  2、 使用锁机制,父进程写数据前锁定。等子进程调用声音程序完成后再解锁。在解锁前如果父进程有监听到新的警告就忽略。简单的一点的锁机制就用一个文件:父进程创建一个空文件表示已经上锁,子进程删除这个文件表示解锁

  3、 这个是因为缓存问题,把管道的缓存设置好就行了。

  修改后的代码如下:

  my $pidfile ="/tmp/alertsounds.pid";

  my $lockfilename="/tmp/sounds.lock";

  sub StartAlertSounds{

  my $pid;

  if ($pid = fork()) {

  return;

  } elsif (defined $pid) {

  setpgrp(0,0);#当前进程成为进程组的头领

  $SIG{INT} = \&catch_zap;   # INT信号处理

  $SIG{QUIT} = \&catch_zap;     # QUIT信号处理

  system("echo $ > $pidfile'");#保存进程ID

  &RunAlertSounds();

  }

  }else {

  die "Can't fork: $!\n";

  }

  }

  sub RunAlertSounds{

  my $pid;

  system("rm -f $lockfilename");

  pipe(README, WRITEME);

  if ($pid = fork()) { #父进程

  close(README);#关闭读端

  select( WRITEME ); #这里一定要选择,不然设置的缓存大小不会对WRITEME有效

  $| = 1;

  open(LOG,"tail -n 2 -f  /var/log/alert| ") ||die "Unable to open log file $!\n";

  while (<LOG>) {

  system(“touch $lockfilename");#加锁

  print WRITEME "Sounds\n";

  }

  close(LOG );

  close(WRITEME);

  waitpid($pid, 0);

  }elsif (defined $pid) { #子进程

  close(WRITEME);#关闭写端

  while(<README>){

  system(“/usr/bin/sounds/AlertSounds >/dev/null 2>&1");

  sleep(1);

  system("rm -f $lockfilename");#解锁

  }

  close(README);

  }else {

  die "Can't fork: $!\n";

  }

  }

  sub catch_zap{

  local $SIG{QUIT} = 'IGNORE';   # 排除自己

  kill(QUIT, -$);         # 通知进程组的所有进程退出

  system("echo > $pidfile");

  exit;

  }

  sub StoptAlertSounds{

  if(-e $pidfile ){

  @pid = `cat $pidfile `;

  kill(QUIT,$pid[0]}) if(defined $pid[0] and $pid[0] ne '');

  }

  }



相关阅读:
php面向对象全攻略 (十一)__toString()用法 克隆对象 __call处理调用错误
如何正确理解PHP的错误信息
在WIN200和WIN98下Tomcat服务器安装实例
很全的显示阴历(农历)日期的js代码
用php发送带附件的Email
多域控制器环境下Active Directory灾难恢复
关闭系统服务导致Windows XP系统无法识别移动硬盘
在GridView中LinkButton的属性的应用(如何不用选中就删除这一行)
ControlJS优化阿里妈妈广告提高页面脚本的加载速度
菜鸟javascript基础资料整理3 正则
有关FreeBSD的汉化与使用
在XP和Windows Server 2003使用凭据管理中
表单的一些基本用法与技巧
input之怎么清除默认值
快速导航

Copyright © 2016 phpStudy |