当前位置：首页 → 问答吧 → 问题：POE模块的使用

问题：POE模块的使用

时间：2010-09-02

来源：互联网

se strict;
use Net::Ftp;
use Socket;
use Sys::Hostname;
use POE;
$|++;
my $host = $ARGV[0]||get_ip();
my $user = $ARGV[1]||'ftpadmin';
my $pwd = $ARGV[2]||'adminftp1';
create POE::Session(
inline_states =>
{_start => \&start,
_stop => sub{print "exit\n";exit(0);},
watcher => \&ftp_watch,
},
);
POE::Kernel->run;
sub start
{
$_[KERNEL]->yield('watcher',$host,$user,$pwd);
$_[HEAP]->{max_try} = 10;
$_[HEAP]->{try_time} =0;
}
sub ftp_watch
{
print "ok\n";
my ($kernel,$heap,$host,$user,$pwd) = @_[KERNEL,HEAP,ARG0..ARG2];
my $ftp=Net::FTP->new($host,Debug=>0,Timeout=>120,Passive => 0);
if (!$ftp)
{
# restart();
print "restart\n";
print $heap->{try_time},"\t",$heap->{max_try},"\n";
if (++$heap->{try_time} > $heap->{max_try})
{
print 'restart ftp-server faild,i will exit after 5sec',"\n";
$kernel->yield('_stop');
}
$kernel->yield("watcher",$host,$user,$pwd);
}
$ftp->quit();
$heap->{try_time} = 0;
print "\rftp server is normal";
# $kernel->delay_set("watcher",1,$host,$user,$pwd);
# $kernel->yield('watcher');
}
sub get_ip
{
my $host = hostname();
my $name = (gethostbyname($host))[0];
return inet_ntoa(scalar(gethostbyname($name || 'localhost')));
}

复制代码

问题：程序是当连接不上ftp的时候就做其他的事情，当我关闭ftp服务的时候，运行程序，但是只输出了2次的ok，就是说，watcher这个事件只运行了两次，并没有尝试10次的连接···然后就执行stop事件，打印exit了····本人万分不懂···谢谢解答

作者: wfnh 发布时间: 2010-09-02

问题已经解决了，但是我还是不懂，可能和整个的框架有关··一定要事件才行·····可惜·没什么中文的资料··杯具啊····
下面我是改写的代码，仅供解决办法···代码粗糙~~见谅见谅~~

ps：觉得用poe写的东西···很清晰···只要写callback就行了····易读性很强（我的可能不怎么样），非常好的东西···POE··

use strict;
use Net::Ftp;
use Socket;
use Sys::Hostname;
use POE;
$|++;
my $host = $ARGV[0]||get_ip();
my $user = $ARGV[1]||'ftpadmin';
my $pwd = $ARGV[2]||'adminftp1';
create POE::Session(
inline_states =>
{_start => \&start,
_stop => sub{print "exit\n";},
watcher => \&ftp_watch,
restart => \&restart,
success => \&disconnect
},
);
POE::Kernel->run;
exit(0);
sub start
{
$_[KERNEL]->yield('watcher',$host,$user,$pwd);
$_[HEAP]->{max_try} = 10;
$_[HEAP]->{try_time} =0;
print <<READ
说明：本程序将监控FTP服务，当FTP服务不能提供正常工作时，程序将尝试重启FTP服务
READ
}
sub ftp_watch
{
my ($kernel,$heap,$host,$user,$pwd) = @_[KERNEL,HEAP,ARG0..ARG2];
my $ftp=Net::FTP->new($host,Debug=>0,Timeout=>120,Passive => 0);
$ftp ? $kernel->yield('success',$ftp) : $kernel->yield('restart');
}
sub get_ip
{
my $host = hostname();
my $name = (gethostbyname($host))[0];
return inet_ntoa(scalar(gethostbyname($name || 'localhost')));
}
sub restart
{
# `net stop Serv-U`;
# sleep 1;
# my $return = `net start Serv-U`;
# print "state:\n$return\n";
print "restart\n";
++$_[HEAP]->{try_time} > $_[HEAP]->{max_try} ? $_[KERNEL]->call('_stop') : $_[KERNEL]->delay_set("watcher",1,$host,$user,$pwd);
print $_[HEAP]->{try_time},"\t",$_[HEAP]->{max_try},"\n";
}
sub disconnect
{
$_[ARG0]->quit();
$_[HEAP]->{try_time} = 0;
print "\rftp server is normal";
$_[KERNEL]->delay_set("watcher",1,$host,$user,$pwd);
}

复制代码

作者: wfnh 发布时间: 2010-09-02

问题：POE模块的使用

热门阅读

热门下载