OpenSSH POE会话陷入困境

Question

我正在使用POE :: Component :: OpenSSH和每个设备的单独POE :: Session对我们网络上的300多个无线电设备进行非阻塞ssh。我的脚本处于工作状态但是有些设备没有配置正确的密码（为简单起见，我们为所有设备保留相同的密码，因此使用相同的密码ssh到每个设备）。有时工程师会犯一个错误并使用NON-STANDARD ssh密码安装设备。在这种情况下，如果OpenSSH无法进行身份验证，则POE :: Session会被卡住（_stop永远不会被调用，脚本永远不会退出）。我知道这不是一个纯粹的程序问题。我们每天在网络上安装很少的设备，每次都不能指望我们的工程师输入正确的密码。因此，即使我更正了现有设备上的密码，将来也不可避免地要让设备使用错误的密码，这会导致我的进程挂起。

我可以做$ kernel-> stop但我不喜欢。我希望会议能够清除。有没有办法使用观察者会话清除会话中POE :: Component :: OpenSSH使用的资源/服务？任何帮助表示赞赏。请参阅下面的代码。

use strict;
use warnings;
use POE;
use POE::Component::OpenSSH;
use POE::Component::Client::Ping;
use Data::Dumper;

my $domain = shift;
my @args = ($domain);
my $session = POE::Session->create(
        args => \@args,
        inline_states => {
                _start => \&start,
                configcapture => \&configcapture,
                activecapture => \&activecapture,
                detectdfs => \&dfs,
                pong => \&pingresult,
                handlerror => \&handlerror,
                _stop   => \&stop,
        },
);

POE::Kernel->run();
exit;

sub start {
        $_[KERNEL]->sig( DIE => 'sig_DIE' );
        print "STARTING ... for $_[ARG0] \n";
        $_[HEAP]{'domain'} = $domain;

        my $ssh = POE::Component::OpenSSH->new(
                args => ['user@'.$domain.':6022', passwd => '123' ],
        );

        $ssh->capture({event => 'configcapture', timeout => 2},
                      'cat /tmp/system.cfg | grep radio.1.freq');
        $ssh->capture({event => 'activecapture', timeout => 2},
                      '/usr/www/status.cgi');
        $_[KERNEL]->delay(detectdfs => 5);
}

sub configcapture {
        $_[HEAP]{'configfreq'} = $_[ARG0]{'result'}[0];
}

sub activecapture {
        $_[HEAP]{'activefreq'} = $_[ARG0]{'result'}[0];
}

sub dfs {
        if(defined($_[HEAP]{'configfreq'}) &&
           defined($_[HEAP]{'activefreq'})) {
                print "CONFIG: $_[HEAP]{'configfreq'}\n";
                print "ACTIVE: $_[HEAP]{'activefreq'}\n";
        }
}

sub stop {
        my ($self, $output) = @_;
        print "Ending Session Here \n";
}

Answer 1

谢谢你的留言。尽管我自己找到了解决方案我在构造POE :: Component :: OpenSSH时必须添加timeout，以便为每个会话调用_stop事件。但剧本仍然没有退出。

由于POE :: Component :: OpenSSH使用POE :: Component :: Generic来生成阻塞Net :: OpenSSH进程作为POE会话，我只需要为openssh组件对象调用POE :: Component :: Generic的shutdown方法被卡住了（错误的密码或其他什么），并且所有会话都干净地结束并且脚本退出了。

请看下面的解决方案：

$_[HEAP]{'ssh'} = POE::Component::OpenSSH->new(
                args => [user@domain, passwd => '123', timeout => 180, async => 1, master_opts => [-o => "StrictHostKeyChecking=no"]],
        );

然后在_stop中

my ($kernel, $session, $heap) = @_[KERNEL, SESSION, HEAP];
delete $heap->{wheel};
$kernel->alias_remove($heap->{alias});
$kernel->alarm_remove_all();
$_[HEAP]{'ssh'}->object->shutdown;
delete($_[HEAP]{'ssh'});