3

我对 Plack、Twiggy 和 AnyEvent 很陌生,遇到了问题。

我有面向客户端的应用程序服务器,它们向后端游戏服务器发出请求。游戏服务器做了几件事。
1. 当请求从应用服务器到达时,它们对对象进行处理(例如,移动、购买、删除或启动对象)。
2. 他们定期更新所有“可移动”物体的位置(更新纬度/经度)。

为了尝试实现这一点,我设置了一个非常基本的 psgi 文件,它执行以下操作: AnyEvent 用于每两秒(重复)更新对象的纬度/经度。

use AnyEvent;
my $cond = AnyEvent->condvar;   
my $w; $w = AnyEvent->timer ('after' => 0, 'interval' => 2, cb => sub {
    while ( my ($key, $o) = each %{$self->{'objhash'}})
    {
        $self->position->update($o) if($o->{type} eq 'movable');
    }
});
$cond->recv;

my $app = sub {
my $env = shift;
    my $resp = $b->handler_rpc($env); #deal with application server requests (e.g. delete object)
    return $resp;
};

handler_rpc 只是处理从应用程序服务器启动的请求,以对对象执行某些操作。为了完整起见,应用服务器上的代码如下;

sub request_action
{
my $self   = shift;
my $vals   = shift;
my $y = $self->y;

use AnyEvent;
use AnyEvent::RPC;
use Data::SplitSerializer;
use Data::Dump qw(pp);

my $flattened = Data::SplitSerializer->new( path_style => 'DZIL' )->serialize($vals);
pp $flattened;

my $rpc = AnyEvent::RPC->new(
    host => '192.168.56.20',
    port => 5000,
    base => '/',
    type => 'REST', # or type => '+AnyEvent::RPC::Enc::REST',
    #debug => 10,
    timeout => 5,
);

my $cv = AE::cv;
$cv->begin; 

my $response;
$rpc->req(
    method => 'POST',
    call  => [ method => qw(handler_rpc)], #Not used atm
    query => $flattened,
    cb    => sub { # ( response, code, error )
        if ($response = shift) {
            warn "we had this response " . Dumper($response);
            $response = $response->{response};
            $cv->end;
        } else {
            my ($code,$err) = @_;
            $response = { 'status' => 'UNKNOWN_ERROR',
                          'code'   => $code,
                          'error'  => $err };
            warn "we have an error $code, $err";
        }
    },
);
$cv->recv;
return  $response;
}

在游戏服务器端,代码如下所示

sub handler_rpc {
my $self = shift;
my $vals = shift;

use Plack::Request;
my $req = Plack::Request->new($vals);

use Data::SplitSerializer;
use Data::Dump qw(pp);
use URI;
use URI::QueryParam;        

my $params = $req->parameters;

my $deep = Data::SplitSerializer->new( path_style => 'DZIL' )->deserialize($req->parameters);
pp $deep;   

#process the command
my $resp;
if( my $func = $self->can($deep->{cmd}) ) 
{
    warn "Calling method of " . $deep->{cmd};
    $resp = &$func( $self, $deep->{args} );
}                   

my $xs = new XML::Simple;
my $xml = $xs->XMLout($resp,
                  NoAttr => 1,
                  RootName=>'response', #TODO: put some key in here somewhere for security.
                 ); 
return [
    200, 
    ['Content-Type' => 'text/plain'],
    [ $xml ],
];  
}

这些部件单独工作。我的意思是,如果我只是担心获取和处理对游戏服务器的 RPC 请求,那么一切正常。

如果我只是使用 AnyEvent 定期更新可以正常工作的对象位置。

当我想在同一组对象上同时执行这两项操作时,就会出现问题。

它失败是因为 $cond->recv 阻塞并且我们实际上并没有到达 $app 所以 Twiggy 不处理请求或者如果我移动 $cond 行,我们启动应用程序并且 twiggy 等待来自应用程序的请求服务器,但 AnyEvent 事件不会发生(或它们发生一次)。

Twiggy 应该是非阻塞的(我认为这在这里很有用)并且在构建时考虑了 AnyEvent,所以我假设有一种方法可以做我想做的事,但是环顾了一会儿,我不是越来越远。

有没有办法使用 Twiggy、Plack 和 AnyEvent 来做到这一点,还是我走错了方向?如果这有点正确,我该如何解决?
还有另一种方法可以更好地解决这个问题吗?

正如我所说,如果我没有提供基本信息,我对此很陌生,很抱歉。请询问,我会更新我错过的任何内容。

谢谢。

4

1 回答 1

1

我想指出,最好将一些“后台”处理与处理 HTTP 请求分开。如果 HTTP 服务器/应用程序不必担心每两秒运行一些操作,那将是最好的。例如,这可能发生在单独的进程中,但需要将游戏状态保存在某种数据库中(而不仅仅是在内存中有一个散列 - 正如我现在理解你的代码那样)。

考虑到这一点,让我们转到您的具体问题。你不能$w->recv在你的应用程序之前拥有,因为那会阻塞。如果您只是删除它,那么您的 AnyEvent 观察者将在应用程序运行时立即超出范围,并且不会触发任何计时器事件。解决方案是根本不调用$w->recv(无需阻止 - 无论如何 Twiggy 都会调用事件循环),而是确保引用某些东西$w以防止它被垃圾收集。

只有在您的 psgi 文件运行时仍然存在的是对应用程序的引用。如果该应用程序关闭了您,$w那么它仍将被引用并且计时器将起作用。

最简单的解决方案是$w出现在里面$app。就像这样:

$app = sub {
    my $env = shift;
    $w;
    ... rest of app code ...
};
于 2014-05-12T22:32:43.520 回答