TTransportException使用Apache Thrift时出现异常

Question

我正在使用apache Thrift.我得到TTransportException异常,而everthing看起来很好用我的代码.这是我的Thrift服务器代码:

private TNonblockingServerSocket socket;
/**
 * @breif Store processor instance.
 */
private PringService.Processor processor;
/**
 * Store server instance.
 */
private TServer tServer;
/**
 *
 * @breif A handle to the unique Singleton instance.
 */
static private ThriftServer _instance = null;

/**
 * @breif The unique instance of this class.
 * @throws TTransportException
 */
static public ThriftServer getInstance() throws TTransportException {
    if (null == _instance) {
        _instance = new ThriftServer();
    }
    return _instance;
}

/**
 * @breif A Ctor for ThriftServer. Initialize all members.
 * @throws TTransportException
 */
private ThriftServer() throws TTransportException {
    socket = new TNonblockingServerSocket(Config.THRIFT_PORT);
    processor = new PringService.Processor(new Handler());
    THsHaServer.Args args = new THsHaServer.Args(socket);
    args.processor(processor);
    args.transportFactory(new TFramedTransport.Factory());
    args.inputProtocolFactory(new TBinaryProtocol.Factory());
    args.outputProtocolFactory(new TBinaryProtocol.Factory());
    tServer = new THsHaServer(args);
    /*tServer = new THsHaServer(processor, socket,
     new TFramedTransport.Factory(),
     new TFramedTransport.Factory(),
     new TBinaryProtocol.Factory(),
     new TBinaryProtocol.Factory());*/
}

/**
 * @breif main method
 * @param args the command line arguments
 * @throws TTransportException
 */
public static void main(String[] args) throws TTransportException {
    // To Run it directly from PringCore.jar, else use SmsProcessor Helper functionality
    ThriftServer server = new ThriftServer();
    server.execute(args);
}

@Override
/**
 * @breif Starts the execution.
 */
protected void execute(String[] args) {
    if (db != null) {
        db.close();
    }
    tServer.serve();
}

私有静态类Handler实现了PringService.Iface {......}}

这是我的节俭客户:

    TTransport transport;
  try {
     transport = new TSocket("localhost", Config.THRIFT_PORT);        
     transport.open();

     TProtocol protocol = new TBinaryProtocol(transport);
     PringService.Client client = new PringService.Client(protocol);

     String result = client.importPringer(2558456, true);

    System.out.println("Result String is ::"+result);
     transport.close();
  } catch (TTransportException e) {
     e.printStackTrace();
  } catch (TException e) {
     e.printStackTrace();
  }

当我运行我的Thrift服务器然后运行thrift客户端时,我得到以下异常:

org.apache.thrift.transport.TTransportException
at org.apache.thrift.transport.TIOStreamTransport.read(TIOStreamTransport.java:132)
at org.apache.thrift.transport.TTransport.readAll(TTransport.java:84)
at org.apache.thrift.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:378)
at org.apache.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:297)
at org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:204)
at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:69)

我在我的节俭服务器或客户端上使用不匹配的传输sockt/layer吗？还是有其他错误？

在此先感谢您的指导:)

Answer 1

使用时TNonblockingServerSocket,您需要同时使用TFramedTransport服务器端和客户端.该文件中TNonblockingServerSocket是相当明确有关:

要使用此服务器,您必须在最外层的传输中使用TFramedTransport,否则此服务器将无法确定何时已从线路读取整个方法调用.客户还必须使用TFramedTransport.

因此,您的客户应如下所示:

TTransport transport;

try {
    transport = new TSocket("localhost", Config.THRIFT_PORT);        
    transport.open();

    TProtocol protocol = new TBinaryProtocol(new TFramedTransport(transport));
    PringService.Client client = new PringService.Client(protocol);

    String result = client.importPringer(2558456, true);

    System.out.println("Result String is ::"+result);
    transport.close();
} catch (TTransportException e) {
    e.printStackTrace();
} catch (TException e) {
    e.printStackTrace();
}