thrift java多线程非阻塞同步/异步调用实例 - JAVA

首先创建thrift文件
[java]
namespace java thriftservice Hello{ string helloString(1:string para)}
执行thrift -gen java test.thrift
会生成一个Hello.java文件
将Hello.java文件拷贝至IDE
server端代码：
package com.thrift.test.Async; 
  
 import org.apache.thrift.TProcessorFactory; 
 import org.apache.thrift.protocol.TCompactProtocol; 
 import org.apache.thrift.server.THsHaServer; 
 import org.apache.thrift.server.TNonblockingServer; 
 import org.apache.thrift.server.TServer; 
 import org.apache.thrift.transport.TFramedTransport; 
 import org.apache.thrift.transport.TNonblockingServerSocket; 
 import org.apache.thrift.transport.TTransportException; 
  
 /**
  * @ * @version
  */ 
 public class Server { 
     public final static int PORT = 8989; 
  
     @SuppressWarnings({ "rawtypes", "unchecked" }) 
     private void start() { 
         try { 
             TNonblockingServerSocket socket = new TNonblockingServerSocket(PORT); 
             final Hello.Processor processor = new Hello.Processor(new HelloImpl()); 
             THsHaServer.Args arg = new THsHaServer.Args(socket); 
             // 高效率的、密集的二进制编码格式进行数据传输 
             // 使用非阻塞方式，按块的大小进行传输，类似于 Java 中的 NIO 
             arg.protocolFactory(new TCompactProtocol.Factory()); 
             arg.transportFactory(new TFramedTransport.Factory()); 
             arg.processorFactory(new TProcessorFactory(processor)); 
             System.out.println("#服务启动-使用:非阻塞&高效二进制编码"); 
             //TServer server = new THsHaServer(arg); 
             TServer server = new TNonblockingServer(arg); 
             server.serve(); 
         } catch (TTransportException e) { 
             e.printStackTrace(); 
         } catch (Exception e) { 
             e.printStackTrace(); 
         } 
     } 
  
     public static void main(String args[]) { 
         Server srv = new Server(); 
         srv.start(); 
     } 
 }  
   
 
 client端代码：
 [java]
 package com.thrift.test.Async; 
  
 import java.io.IOException; 
  
 import org.apache.thrift.TApplicationException; 
 import org.apache.thrift.TException; 
 import org.apache.thrift.async.TAsyncClientManager; 
 import org.apache.thrift.protocol.TCompactProtocol; 
 import org.apache.thrift.protocol.TProtocol; 
 import org.apache.thrift.protocol.TProtocolFactory; 
 import org.apache.thrift.transport.TFramedTransport; 
 import org.apache.thrift.transport.TNonblockingSocket; 
 import org.apache.thrift.transport.TNonblockingTransport; 
 import org.apache.thrift.transport.TSocket; 
 import org.apache.thrift.transport.TTransport; 
 import org.apache.thrift.transport.TTransportException; 
  
 /**
  * 
  */  www.2cto.com
 public class Client { 
     public static final String address = "127.0.0.1"; 
     public static final int port = 8989; 
     public static final int clientTimeout = 30000; 
  
     public static void main_syn() { 
         TTransport transport = new TFramedTransport(new TSocket(address, port, clientTimeout)); 
         TProtocol protocol = new TCompactProtocol(transport); 
         Hello.Client client = new Hello.Client(protocol); 
  
         try { 
             transport.open(); 
             System.out.println(client.helloString("larry")); 
  
         } catch (TApplicationException e) { 
             System.out.println(e.getMessage() + " " + e.getType()); 
         } catch (TTransportException e) { 
             e.printStackTrace(); 
         } catch (TE
thrift java多线程非阻塞同步/异步调用实例(一)
