Thrift安裝與使用

代碼示例

• thrift轉Java： thrift-0.9.1.exe -r -gen java ./demoHello.thrift

• 實現服務端接口( 接口實現類 )

public class HelloWorldImpl implements HelloWorldService.Iface{
    private static final Logger logger = Logger.getLogger(HelloWorldImpl.class);
    @Override
    public String sayHello(String username) throws TException {
        return "Hi,"+username+" welcome to my Server....";
    }
}

• 編寫服務端

public class HelloServerDemo {
    public static final int SERVER_PORT = 8090;
    private static final Logger logger = Logger.getLogger(HelloServerDemo.class);

    public static void main(String[] args){
        HelloServerDemo serverDemo = new HelloServerDemo();
        serverDemo.startServer();
    }
    public void startServer(){
        // TServer --> TServer.Args: 1. TServerSocket( port )
        //                           2. interface
        //                           3. TBinaryProtocol.Factory()
        try {
            System.out.println("HelloWorld TSimpleServer start....");
            //TProcessor tProcessor = new HelloWorldService.Processor<HelloWorldService.Iface>(new HelloWorldImpl());
            HelloWorldService.Processor<HelloWorldService.Iface> tprocessor = new HelloWorldService.Processor<HelloWorldService.Iface>(new HelloWorldImpl());

            //簡單地單線程服務模型，一般用于測試
            TServerSocket serverTransport = new TServerSocket(SERVER_PORT);
            TServer.Args tArgs = new TServer.Args(serverTransport);
            tArgs.processor(tprocessor);
            tArgs.protocolFactory(new TBinaryProtocol.Factory());
            //tArgs.protocolFactory(new TCompactProtocol.Factory());
            //tArgs.protocolFactory(new TJSONProtocol.Factory());
            TServer server = new TSimpleServer(tArgs);
            server.serve();
        } catch (TTransportException e) {
            e.printStackTrace();
        }
    }
}

• 編寫Client

public class HelloClientDemo {
    public static final String SERVER_IP = "localhost";
    public static final int SERVER_PORT = 8090;
    public static final int TIME_OUT = 30000;

    public static void main(String[] args){
        try {
            new HelloClientDemo().startClient("Tanzhen");
        } catch (TException e) {
            e.printStackTrace();
        }
    }
    public static void startClient(String usrname) throws TException {
        TTransport transport = null;
        transport = new TSocket(SERVER_IP,SERVER_PORT,TIME_OUT);
        TProtocol protocol = new TBinaryProtocol(transport);
        HelloWorldService.Client client = new HelloWorldService.Client(protocol);
        transport.open();
        String result = client.sayHello(usrname);
        System.out.println("Thrift client result="+result);
    }
}

基本類型

• bool: 布爾值，true或false，對應Java的boolean

• byte：8位有符號數，對應Java的byte

• i16：16位有符號數，對應Java的short

• i32：32位有符號數，對應Java的int

• i64：對應Java的long

• double：對應Java的double

• string：utf-8編碼的字符串，對應Java的String

• list：對應Java中ArrayList

• set：對應Java的HashSet

• map：對應Java的HashMap

• exception：對應Java的Exception

• service：對應服務的類

結構體

• struct：定義公共對象，類似于C語言中的結構體定義，在Java中是一個JavaBean

原理詳解

http://www.cnblogs.com/brucewoo/archive/2012/06/03/2532788.html

是什么：

為什么：

怎么做：