thrift 开发教程 nick的日志 网易博客

thrift 开发教程 - nick的日志 - 网易博客

thrift 开发教程   

2011-05-27 15:27:29|  分类： thrift |  标签：  |字号 大中小 订阅

1 编写thrift文件(如aa.thrift)
namespace java  com.tv189.uc.thrift
namespace cpp thrift.vdb
namespace rb thrift.vdb
namespace perl thrift.vdb
namespace csharp thrift.vdb
namespace js thrift.vdb
namespace st thrift.vdb
namespace py thrift.vdb
namespace php thrift

service UCThriftService{
 string ucOperator(1:string actionType, 2:string uid, 3:string data),
}

2 生成java文件
thrift-0.6.0.exe -r --gen java uc.thrift
thrift-0.6.0.exe -r --gen java uc.thrift
thrift-0.6.0.exe -r --gen php uc.thrift
thrift-0.6.0.exe -r --gen py uc.thrift
可以生成php，py等等的

3 服务端编写

  1)实现 UCThriftService.Iface
public class UCThriftServiceImpl implements UCThriftService.Iface {
 public static Logger logger = Logger.getLogger(UCThriftServiceImpl.class);
 
 @Override
 public String ucOperator(String actionType, String suid, String data)
   throws TException {
  System.out.println("test");

 ｝
｝

2)运行的main编写
public class UCServiceServer {
 private static Logger logger = Logger.getLogger(UCServiceServer.class);
 
 public static void main(String... args) throws Exception {
  //这个是用properties编写的，可以自行决定
  String server = PropertiesUtil.getValue("tserver.properties","ucserver.nio","hahs");
  if ("nio".equalsIgnoreCase(server)) {
   startNIO();
  } if ("hahs".equalsIgnoreCase(server)) {
   startHAHS();
  } else {
   start();
  }

 }

 private static void start() throws TTransportException {
  String address = PropertiesUtil.getValue("tserver.properties","ucserver.address","0.0.0.0");
  int port = Integer.parseInt(PropertiesUtil.getValue("tserver.properties","ucserver.port","5555"));
  int clientTimeout = Integer.parseInt(PropertiesUtil.getValue("tserver.properties","ucserver.clientTimeout","30000"));
  int minWorkerThreads = Integer.parseInt(PropertiesUtil.getValue("tserver.properties","ucserver.minWorkerThreads","25"));
  int maxWorkerThreads = Integer.parseInt(PropertiesUtil.getValue("tserver.properties","ucserver.maxWorkerThreads","25"));
  String protocol = PropertiesUtil.getValue("tserver.properties","ucserver.protocol","binary");
  TServerSocket socket = new TServerSocket(new InetSocketAddress(address,
    port), clientTimeout);
  UCThriftService.Processor process = new UCThriftService.Processor(
    UCThriftServiceImpl.instance());
  TThreadPoolServer.Args arg = new TThreadPoolServer.Args(socket);
  if("compact".equalsIgnoreCase(protocol)){
   arg.protocolFactory(new TCompactProtocol.Factory());
  }else if("binary".equalsIgnoreCase(protocol)){
   arg.protocolFactory(new TBinaryProtocol.Factory());
  }else{
   arg.protocolFactory(new TBinaryProtocol.Factory());
  }
  arg.transportFactory(new TFramedTransport.Factory());
  arg.maxWorkerThreads(maxWorkerThreads);
  arg.minWorkerThreads(minWorkerThreads);
  // arg.processor(process);
  arg.processorFactory(new TProcessorFactory(process));
  TServer server = new TThreadPoolServer(arg);
  Logger.getLogger(UCServiceServer.class).info(
    UCServiceServer.class.getSimpleName() + " Listen at " + port);
  while(true){
   try {
    server.serve();
   } catch (Exception e) {
    logger.error(e.getMessage(),e);
    server.stop();
    Logger.getLogger(UCServiceServer.class).info(
      UCServiceServer.class.getSimpleName() + " Reload");
    server = new TThreadPoolServer(arg);
   }
  }
 }

 private static void startNIO() throws TTransportException {
  String address = PropertiesUtil.getValue("tserver.properties","ucserver.address","0.0.0.0");
  int port = Integer.parseInt(PropertiesUtil.getValue("tserver.properties","ucserver.port","5555"));
  int clientTimeout = Integer.parseInt(PropertiesUtil.getValue("tserver.properties","ucserver.clientTimeout","30000"));
  String protocol = PropertiesUtil.getValue("tserver.properties","ucserver.protocol","binary");
 TNonblockingServerSocket socket = new TNonblockingServerSocket(
    new InetSocketAddress(address, port), clientTimeout);
  UCThriftService.Processor process = new UCThriftService.Processor(
    UCThriftServiceImpl.instance());
  TNonblockingServer.Args arg = new TNonblockingServer.Args(socket);
  if("compact".equalsIgnoreCase(protocol)){
   arg.protocolFactory(new TCompactProtocol.Factory());
  }else if("binary".equalsIgnoreCase(protocol)){
   arg.protocolFactory(new TBinaryProtocol.Factory());
  }else{
   arg.protocolFactory(new TBinaryProtocol.Factory());
  }
  arg.transportFactory(new TFramedTransport.Factory());
  // arg.processor(process);
  arg.processorFactory(new TProcessorFactory(process));
  TServer server = new TNonblockingServer(arg);
  Logger.getLogger(UCServiceServer.class).info(
    "NIO " + UCServiceServer.class.getSimpleName() + " Listen at "
      + port);
  while(true){
   try {
    server.serve();
   } catch (Exception e) {
    
    server.stop();
    Logger.getLogger(UCServiceServer.class).info(
      "NIO " + UCServiceServer.class.getSimpleName() + " Reload");
    server = new TNonblockingServer(arg);
   }
  }
 }
 
 private static void startHAHS() throws TTransportException {
  String address = PropertiesUtil.getValue("tserver.properties","ucserver.address","0.0.0.0");
  int port = Integer.parseInt(PropertiesUtil.getValue("tserver.properties","ucserver.port","5555"));
  int clientTimeout = Integer.parseInt(PropertiesUtil.getValue("tserver.properties","ucserver.clientTimeout","30000"));
  int minWorkerThreads = Integer.parseInt(PropertiesUtil.getValue("tserver.properties","ucserver.minWorkerThreads","25"));
  String protocol = PropertiesUtil.getValue("tserver.properties","ucserver.protocol","binary");
 
  TNonblockingServerSocket socket = new TNonblockingServerSocket(
    new InetSocketAddress(address, port), clientTimeout);
  UCThriftService.Processor process = new UCThriftService.Processor(
    UCThriftServiceImpl.instance());
  THsHaServer.Args arg = new THsHaServer.Args(socket);
  if("compact".equalsIgnoreCase(protocol)){
   arg.protocolFactory(new TCompactProtocol.Factory());
  }else if("binary".equalsIgnoreCase(protocol)){
   arg.protocolFactory(new TBinaryProtocol.Factory());
  }else{
   arg.protocolFactory(new TBinaryProtocol.Factory());
  }
  arg.transportFactory(new TFramedTransport.Factory());
  arg.workerThreads(minWorkerThreads);
  // arg.processor(process);
  arg.processorFactory(new TProcessorFactory(process));
  TServer server = new THsHaServer(arg);
  Logger.getLogger(UCServiceServer.class).info(
    "HAHS " + UCServiceServer.class.getSimpleName() + " Listen at "
      + port);
  while(true){
   try {
    server.serve();
   } catch (Exception e) {
    logger.error(e.getMessage(),e);
    server.stop();
    Logger.getLogger(UCServiceServer.class).info(
      "HAHS " + UCServiceServer.class.getSimpleName() + " Reload");
    server = new TNonblockingServer(arg);
   }
  }
 }
 
}

4 客户端编写

public  void newThread() throws TException {
  
  
  String address = "0.0.0.0";
  int port = 5555;
  int clientTimeout = 30000;
  TTransport transport = new TFramedTransport(new TSocket(address, port,
    clientTimeout));
  TProtocol protocol = new TBinaryProtocol(transport);
  UCThriftService.Client client = new UCThriftService.Client(protocol);
  transport.open();
  try {
   long bt = System.currentTimeMillis();
   
    
    System.out.println(URLDecoder.decode(client.ucOperator("get", "29", "")));
    
   
  
   
  } catch (TApplicationException e) {
   System.out.println(e.getMessage() + " " + e.getType());
  }
  transport.close();
 }

5运行

先运行ucserver

client连接可在控制台看到输出

说明：

client连服务端有几个要注意的地方：

1  服务器的ip和端口

2 服务端和客户端用的  transport 和协议一定要一样

比如： 如果服务端用的TFrameTransport 那客户端也要用TFrameTransport

             如果服务端用的TBinaryProtocol,那客户端也要用TBinaryProtocol

否则会出一个好像是TTransportException的一个异常。