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(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");
 }
}