我试图用thrift的TFileTransport包装一个Java类,以便从Python调用。我尝试使用TJSON和TBinary两种协议,但始终出现此异常
org.apache.thrift.transport.TTransportException: FileTransport error: bad event size
at org.apache.thrift.transport.TFileTransport.readEvent(TFileTransport.java:327)
at org.apache.thrift.transport.TFileTransport.read(TFileTransport.java:468)
at org.apache.thrift.transport.TFileTransport.readAll(TFileTransport.java:439)
at org.apache.thrift.protocol.TJSONProtocol$LookaheadReader.read(TJSONProtocol.java:263)
at org.apache.thrift.protocol.TJSONProtocol.readJSONSyntaxChar(TJSONProtocol.java:320)
at org.apache.thrift.protocol.TJSONProtocol.readJSONArrayStart(TJSONProtocol.java:784)
at org.apache.thrift.protocol.TJSONProtocol.readMessageBegin(TJSONProtocol.java:795)
at org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:27)
at org.apache.thrift.transport.TFileProcessor.processUntil(TFileProcessor.java:69)
at org.apache.thrift.transport.TFileProcessor.processChunk(TFileProcessor.java:102)
at org.apache.thrift.transport.TFileProcessor.processChunk(TFileProcessor.java:111)
at org.apache.thrift.transport.TFileProcessor.processChunk(TFileProcessor.java:118)
at com.netflix.suro.client.SendToPyServer.startThriftServer(SendToPyServer.java:51)
at com.netflix.suro.client.SendToPyServer.main(SendToPyServer.java:67)
这是我的Python客户端的外观:
^{pr2}$这是我的服务器:
public static void startThriftServer(SendPyInterface.Processor processor) {
try {
File input = new File("src/main/java/com/netflix/suro/client/ThriftFile.in");
if(!input.exists()){
input.createNewFile();
}
File output = new File("src/main/java/com/netflix/suro/client/ThriftFile.out");
if(!output.exists()){
output.createNewFile();
}
TFileTransport inputFileTransport = new TFileTransport(input.getAbsolutePath(), true);
TFileTransport outputFileTransport = new TFileTransport(output.getAbsolutePath(), false);
System.out.println(input.getAbsolutePath());
System.out.println(input.length());
inputFileTransport.open();
outputFileTransport.open();
System.out.println(inputFileTransport.getBytesRemainingInBuffer());
inputFileTransport.setTailPolicy(tailPolicy.WAIT_FOREVER);
System.out.println("Wait ...");
System.out.println(inputFileTransport.getBuffer());
TFileProcessor fProcessor =
new TFileProcessor(processor, new TJSONProtocol.Factory(), inputFileTransport, outputFileTransport);
try {
fProcessor.processChunk();
} catch (TTransportException e) {
e.printStackTrace();
}
System.out.println("File Thrift service started ...");
} catch (Exception e) {
e.printStackTrace();
}
我从这个帖子中得到了一个例子: Example on how to use TFileTransport in Thrift (Client/Server)
从这篇文章中: http://theprogrammersguideto.com/thrift/blog/code/chapter-3-moving-bytes-with-transports/
根据docs in the old Thrift wiki,java和C++的文件传输实际上是一个framed transport,它在数据前面写了一个附加的4字节头。这里的名字似乎有点误导人。在
相反,使用的pythontfileobjecttransport只是一个简单的包装器。这意味着传输不兼容,因此会出现错误消息。在
因此,
TSimpleFileTransport
应该与Java一起使用,而不是TFileTransport
。在相关问题 更多 >
编程相关推荐