Thrift TNonblockingServer EOF异常

我有用java编写的服务器应用程序和常规客户端应用程序。我的服务器上来请求和做某事。我使用Thonft和TNonBlockingServer。Thrift TNonblockingServer EOF异常

public static void nonBlockingServer(HbaseLayerService.Processor processor) { 
      try { 
       final Integer serverPort = ConfigurationManager.instance().getServerPort(); 
       TNonblockingServerTransport serverTransport = new TNonblockingServerSocket(serverPort); 
       TServer server = new TNonblockingServer(new TNonblockingServer.Args(serverTransport).processor(processor)); 

       server.serve(); 
      } catch (Exception e) { 
       Throwables.propagate(e); 
      } 
     }

我的客户发送〜100Mb的数据

TTransport transport = new TFramedTransport(new TSocket('localhost', 12345, 100000)) 
transport.open() 
TProtocol protocol = new TBinaryProtocol(transport); 
HbaseLayerService.Client client = new HbaseLayerService.Client(protocol); 
def putList = [] //~1500000 objects (string, string, string, int, byte[]) 
client.putEvent(new PutEventsOperation(putsToSend));

此操作过程中，我有一个错误：

Exception in thread "main" org.apache.thrift.transport.TTransportException 
    at org.apache.thrift.transport.TIOStreamTransport.read(TIOStreamTransport.java:132) 
    at org.apache.thrift.transport.TTransport.readAll(TTransport.java:86) 
    at org.apache.thrift.transport.TFramedTransport.readFrame(TFramedTransport.java:129) 
    at org.apache.thrift.transport.TFramedTransport.read(TFramedTransport.java:101) 
    at org.apache.thrift.transport.TTransport.readAll(TTransport.java:86) 
    at org.apache.thrift.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:429) 
    at org.apache.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:318) 
    at org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:219) 
    at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:69) 
    at communication_struct.thrift.HbaseLayerService$Client.recv_putEvent(HbaseLayerService.java:96)

此异常的类型为4：END_OF_FILE。

随着TSimpleServer一切正常，但我想采取几个连接，并在一个线程队列中进行操作。

来源

2015-04-23 Piotr Sobolewski

这个问题不是关于[thrift-protocol]。这是关于运输。 – JensG

“*〜1500000 objects *” - [数据块的大小是多少？]（https://github.com/apache/thrift/blob/7a8b286b3f03046a1b89f405129dbc042ddae818/lib/java/src/org/apache/thrift/transport/ TIOStreamTransport.java） – JensG

它不小于50 MB，不超过100MB –

最后我找到了解决方案。在这种特殊情况下，你应该新的大小TFramedTransport.Factory添加为象下面这样：

TServer server = new TNonblockingServer(new TNonblockingServer.Args(serverTransport) 
        .processor(processor) 
        .transportFactory(new TFramedTransport.Factory(MAX_FRAMED_TRANSPORT_SIZE)) 
        .protocolFactory(new TBinaryProtocol.Factory()) 
      );

相同的操作应该在客户端完成：

TTransport transport = new TFramedTransport(new TSocket('localhost', 12345), MAX_FRAMED_TRANSPORT_SIZE)

在我的情况MAX_FRAMED_TRANSPORT_SIZE = 256 * 1024 * 1024。

来源

2015-04-24 09:34:55

我看着错误的文件。上面的链接不再是主干'lib/java'，而是2011年的一个提交。当时没有这样的CTOR（并且在javame中，现在还没有）。所以是的，绝对正确的答案。 – JensG

Thrift TNonblockingServer EOF异常

回答

相关问题