thrift 笔记

TProcessor

有了传输手段和编码器还是不能够实现 RPC 里面,还需要一些手段来把从编码器里面获得的输入信息,传给服务端的接口实现,并且把服务端的接口实现返回的结果,通过编码器和输入通道传回给远端的客户端。

TProcessor 就是做这个事情的。

TProcessor 接口比较简单,就定义了一个 process 方法来处理输入的 TProtocol 和输出的 TProtocol。

public interface TProcessor {
  public boolean process(TProtocol in, TProtocol out)
    throws TException;
}

也就是说,TPrecessor 负责把远程的输入输出和本地的接口实现组合在一起的模块。

links