namespace java com.thrift.demo.service service HelloService{  string sayHello(1:string username)}

thrift -gen java HelloService.thrift

public class HelloServiceImpl implements HelloService.Iface { @Override public String sayHello(String username) throws TException { return "Hello Thrift Service : " + username; }}

public class HelloServer { public static final int SERVER_PORT = 8090; public void startServer() { try {  System.out.println("HelloService TSimpleServer start ....");  TProcessor tprocessor = new HelloService.Processor<HelloService.Iface>(new HelloServiceImpl());  // 簡單的單線程服務模型，一般用于測試  TServerSocket serverTransport = new TServerSocket(SERVER_PORT);  TServer.Args tArgs = new TServer.Args(serverTransport);  tArgs.processor(tprocessor);  tArgs.protocolFactory(new TBinaryProtocol.Factory());  TServer server = new TSimpleServer(tArgs);  server.serve(); } catch (Exception e) {  System.out.println("Server start error!!!");  e.printStackTrace(); } } public static void main(String[] args) { HelloServer server = new HelloServer(); server.startServer(); }}

public class HelloClient { public static final String SERVER_IP = "localhost"; public static final int SERVER_PORT = 8090; public static final int TIMEOUT = 30000; public void startClient(String userName) { TTransport transport = null; try {  transport = new TSocket(SERVER_IP, SERVER_PORT, TIMEOUT);  // 協議要和服務端一致  TProtocol protocol = new TBinaryProtocol(transport);  HelloService.Client client = new HelloService.Client(protocol);  transport.open();  String result = client.sayHello(userName);  System.out.println("Thrify client result =: " + result); } catch (TTransportException e) {  e.printStackTrace(); } catch (TException e) {  e.printStackTrace(); } finally {  if (null != transport) {  transport.close();  } } } public static void main(String[] args) { HelloClient client = new HelloClient(); client.startClient("Michael"); }}