TNonblockingServer usage ------------------------ Key: THRIFT-1368 URL: https://issues.apache.org/jira/browse/THRIFT-1368 Project: Thrift Issue Type: Question Components: Java - Library Affects Versions: 0.7 Reporter: Jensen Li
Code for server side: TNonblockingServerTransport transport = new TNonblockingServerSocket(8888);; AbstractNonblockingServerArgs<TNonblockingServer.Args> args = new TNonblockingServer.Args(transport ); args.processor(new Calculator.Processor<Iface>(new CalculatorHandler())); TNonblockingServer server = new TNonblockingServer(args ); server.serve(); Client code: SocketAddress remote = new InetSocketAddress("localhost", 8888); SocketChannel channel = SocketChannel.open(remote); TNonblockingSocket tnSocket = new TNonblockingSocket(channel); TTransport framedTransport = new TFramedTransport.Factory().getTransport(tnSocket); TTransport transport = framedTransport; TProtocol protocol = new TBinaryProtocol(transport); Calculator.Client client = new Calculator.Client(protocol); System.out.println(client.add(1, 2)); framedTransport.close(); For each interface method, the first time invoking will fail, with below exception, but later it's okay. And for multithread client, some threads may fail with the same exception, some threads succeed, could you tell what's the cause? Exception: Exception in thread "main" org.apache.thrift.transport.TTransportException: Cannot read. Remote side has closed. Tried to read 4 bytes, but only got 0 bytes. (This is often indicative of an internal error on the server side. Please check your server logs.) 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: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) -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa For more information on JIRA, see: http://www.atlassian.com/software/jira