Perl之Linux::Inotify2
关于 inotify 机制的详细介绍可以参考文章:
inotify -- Linux 2.6 内核中的文件系统变化通知机制
文章写得很详细,而且还给出了c语言实现的例子。
下面我就来说说Perl里面,如何利用Linux::Inotify2 实现任务异步操作的例子。
比如 A进程(线程)将要完成的任务按一定规则 写到inotify监控的目录下,通过inotify机制自动解析并完成任务的执行。
# 下面的脚本就是 inotify发现被监控的目录有变化了,通过读取变化的文件,解析变完成任务
use utf8;
use JSON;
use Linux::Inotify2;
# inotify based job excution engine
my $inotify = new Linux::Inotify2 or die "unable to create new inotify obj: $!";
# 创建被监控的相关目录
mkdir "/var/inotify" unless -d "/var/inotify";
mkdir "/var/inotify/jobs" unless -d "/var/inotify/jobs"; #被监控(即待完成的任务)的目录
mkdir "/var/inotify/done" unless -d "/var/inotify/done"; #已完成操作的目录
# 举例说明:添加新任务到 jobs目录下,保持任务id的唯一性如 oid1,oid2....
# /var/inotify/jobs/oid1
# /var/inotify/jobs/oid2
# /var/inotify/jobs/oid3
#上述任务完成后, 将其移到done目录
# /var/inotify/done/oid1
# /var/inotify/done/oid2
# /var/inotify/done/oid3
# 一些日志
system("date >/var/inotify.log");
system("whoami >>/var/inotify.log");
system("echo 'pid: $$' >>/var/inotify.log");
$inotify->watch("/var/inotify/jobs", IN_CLOSE_WRITE, sub {
my $e = shift;
my $job_file = $e->fullname;
append_to_file("/var/inotify.log", "\n>>> [".localtime(time)."] job file: ".$job_file."\n".read_from_file($job_file)."\n");
##################################################
# 执行任务
print $job_file,"\n";
my @entries = split /\r\n/, read_from_file($job_file); #文件内容按行分割到数组
foreach my $obj (@entries) {
## ....
my @arry = split(/ m: /,$obj); #按一定规则解析
print $arry[0],"\n";
print $arry[1],"\n";
append_to_file("/var/inotify.log", "\n\n>>>>> [".localtime(time)."] array: ".$arry[0]." ".$arry[1]."\n");
if (index($arry[0],"redpack") >= 0) { #任务1
&task1($arry[1]);
} else { #任务2
&task2($arry[0],$arry[1]);
}
}
########################################
# 任务完成 移到 done目录
system("mv $job_file /var/inotify/done/");
});
# 辅助函数
sub append_to_file {
open FILE, ">>", $_[0];
print FILE $_[1];
close FILE;
}
sub read_from_file {
local $/;
open FILE, $_[0];
my $c = <FILE>;
close FILE;
return $c;
}
sub write_to_file {
open FILE, ">", $_[0];
print FILE $_[1];
close FILE;
}
sub task1 {
}
sub task2 {
}
1 while $inotify->poll;
通过下面的命令让上面的脚本作为常驻进程运行:
nohup perl inotify.pl > /dev/null 2>&1 &
上一篇: onScrollChanged()