Thrift 샘플 분석

Thrift 파일

namespace java calculator

//     
enum Operator{
	ADD,SUB,MUL,DIV
}

//     (        )
exception InvalidationOperator{
	1: i32 what,
	2: string why
}

//    
struct Work{
	1: i32 num1,
	2: i32 num2,
	3: Operator op
}

//   
service Calculator{
	
	//     ：      (num:        ) throws (num:          )
	i32 calculate(1: Work work) throws (1:InvalidationOperator e)
}

서버 코드

Thrift 파일에 정의된 서비스 인터페이스를 구현합니다.

import calculator.Work;
import calculator.Calculator.Iface;
import calculator.InvalidationOperator;

class CalHandler implements Iface{
	
	@Override
	public int calculate(Work work) throws InvalidationOperator, TException {
		switch(work.op){
		case ADD:
			return work.num1 + work.num2;
		case SUB:
			return work.num1 - work.num2;
		case MUL:
			return work.num1*work.num2;
		case DIV:
			if(work.num2 == 0){
				throw new InvalidationOperator(work.op.getValue(), "0     !");
			}
			return work.num1/work.num2;
		default:
			throw new InvalidationOperator(work.op.getValue(), "     !");
		}
	}
}

public interface Iface {

    public int calculate(Work work) throws InvalidationOperator, org.apache.thrift.TException;

  }

  public interface AsyncIface {

    public void calculate(Work work, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;

  }

public class CalServer {
	public static void main(String[] args) throws TTransportException{
		TServerTransport transport = new TServerSocket(9999);
		CalHandler cal = new CalHandler();
		Processor processor = new Processor(cal);
		TServer server = new TSimpleServer(new Args(transport).processor(processor));
		System.out.println("      ...");
		server.serve();
	}
}

  +-------------------------------------------+
  | Server                                    |
  | (single-threaded, event-driven etc)       |
  +-------------------------------------------+
  | Processor                                 |
  | (compiler generated)                      |
  +-------------------------------------------+
  | Protocol                                  |
  | (JSON, compact etc)                       |
  +-------------------------------------------+
  | Transport                                 |
  | (raw TCP, HTTP etc)                       |
  +-------------------------------------------+

  public static class Processor {
    public Processor(I iface) { }

    protected Processor(I iface, Map processMap) {  }

  }

  public static class AsyncProcessor {
    public AsyncProcessor(I iface) {  }

    protected AsyncProcessor(I iface, Map processMap) {   }
	
  }

클라이언트 코드

public class CalClient {
	public static void main(String[] args) throws InvalidationOperator, TException{
		TTransport transport = new TSocket("localhost", 9999);
		transport.open();
		TProtocol protocol = new TBinaryProtocol(transport);
		Client client = new Client(protocol);
		Work work = new Work(1,2,Operator.ADD);
		int rst = client.calculate(work);
		System.out.println("  ："+rst);
		transport.close();
	}
}