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 '');
}
}