Apache Thrift：客户端超时问题

Question

我有一些带有 perl-server 和 php-client 的 Apache Thrift (v.0.6.1) 测试应用程序。

我无法解释的行为：如果我们使用无效参数调用服务器方法，我们会在服务器输出中看到错误，但 php-client 会无限期地等待响应。

以下是服务器的来源：

sub new {
    my $classname = shift;
    my $self      = {};

    return bless($self,$classname);
}

sub DateToTimestamp
{
    my ($self, $date) = @_;
    my $result = CommonAPI::DateToTimestamp($date);
    return $result;
}

eval {
  my $handler       = new RPCHandler;
  my $processor     = new RPCPerformanceTest::RPCPerformanceTestProcessor($handler);
  my $serversocket  = new Thrift::ServerSocket(9091);
  my $forkingserver = new Thrift::ForkingServer($processor, $serversocket);
  print "Starting the server...\n";
  $forkingserver->serve();
  print "done.\n";
}; if ($@) {
  if ($@ =~ m/TException/ and exists $@->{message}) {
    my $message = $@->{message};
    my $code    = $@->{code};
    my $out     = $code . ':' . $message;
    die $out;
  } else {
    die $@;
  }
}

和客户端：

try {

    $socket = new TSocket($server_host, $server_port);

    $transport = new TBufferedTransport($socket, 1024, 1024);
    $protocol = new TBinaryProtocol($transport);

    $client = new RPCPerformanceTestClient($protocol);
    $transport->open();

    $start = microtime(true);

    $result = $client->DateToTimestamp('071/26/2011 01:23:45');

    var_dump($result);

} catch (Exception $e) {
    echo 'Exception: <b>' . $e->getMessage() . '</b>';
}

为什么会发生这种情况？是我的错吗？这是预期的行为吗？

Answer 1

Thrift PHP 库有点损坏。您需要手动设置超时时间
例如

  $socket = new TSocket('host', 9095);
  $socket->setSendTimeout(60000);
  $socket->setRecvTimeout(60000)

Answer 2

对于不提供消息长度的协议，这种情况经常发生：客户端发送的数据多于服务器期望的数据，并等待服务器接收数据。服务器接收一些数据，尝试解析它但失败。现在协议的服务器端处于错误状态。如果继续读取数据，可能会阻塞。最有可能的是，服务器端向您发送了一些错误响应，并同时等待客户端接收响应，但这也永远不会发生。

这是我的猜测。恕我直言，最好的策略是为客户端和服务器套接字设置超时。