我对 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 来做到这一点,还是我走错了方向?如果这有点正确,我该如何解决?
还有另一种方法可以更好地解决这个问题吗?
正如我所说,如果我没有提供基本信息,我对此很陌生,很抱歉。请询问,我会更新我错过的任何内容。
谢谢。