0

我正在尝试使用 perl POE 设置客户端-服务器应用程序。

在阅读了一些关于CPAN的 POE 文档并尝试了一些食谱的示例后，最终重现了警报，我遇到了以下问题：

我的自定义组件中的事件在（客户端）会话中触发。

package POE::Component::OXO_TCP_Server;

use strict;
use warnings;
use POE;
use POE::Filter::Reference;
use POE::Component::Server::TCP;

sub new {
    my ($proto, %args) = @_;
    my $class = ref ($proto) || $proto;

    my $send_up_intervall   = 10;
    my %default = (
      Alias         => "oxo_tcp_server",
      Address       => "localhost",
      Port          => 12345,
      ClientFilter  => "POE::Filter::Reference",
      ClientInput   => \&handle_client_input,

      ClientDisconnected => sub {
          $_[KERNEL]->yield("shutdown");
      },

      SessionParams => [ options => { debug => 1, trace => 1 } ],

      InlineStates => {
        _start => sub {
          $_[HEAP]->{next_alarm_time} = int(time()) + 1;
          $_[KERNEL]->alarm(tick => $_[HEAP]->{next_alarm_time});
        },

        tick => sub {
          print "tick at ", time(), "\n";
          $_[HEAP]->{next_alarm_time}++;
          $_[KERNEL]->alarm(tick => $_[HEAP]->{next_alarm_time});
        }, 
      }
    );

    # add \%args; to \%default
    my $self = POE::Component::Server::TCP->new(%default);
    return $self;
}

sub handle_client_input {...}

1;

当我向服务器发送一些输入时，事件

=== 8071 === 2 -> tick (from ../lib/POE/Component/OXO_TCP_Server.pm at 65) tick at 1433857644
...

被解雇。

但我希望他们独立于客户（仅按时间）被解雇。

我怎样才能做到这一点？我在文档或食谱中没有找到这个。

为了避免重载_start我还尝试在

Started => sub {
  $_[HEAP]->{next_alarm_time} = int(time()) + 1;
  $_[KERNEL]->alarm(tick => $_[HEAP]->{next_alarm_time});
},

在第一个视图看起来它正在工作，因为调试说：

=== 8093 === 1 -> tick (from ../lib/POE/Component/OXO_TCP_Server.pm at 47)

但事实并非如此。可能它仍然是错误的会话。想法？

谢谢。

4

1 回答 1

0

我找到了自己的一种方式。我添加了一个额外的会话：

POE::Session->create(
  inline_states => {
        _start => sub {

          $_[HEAP]->{next_alarm_time} = int(time()) + 1;
          $_[KERNEL]->alarm(tick => $_[HEAP]->{next_alarm_time});
        },

        tick => sub {
          print "tick at ", time(), "\n";
          $_[HEAP]->{next_alarm_time}++;
          $_[KERNEL]->alarm(tick => $_[HEAP]->{next_alarm_time});
        },
  },
);

这样它就独立于POE::Component::Server::TCP了。可能还有其他/更好的方法。

于 2015-06-09T14:18:58.633 回答