关于thrift client和server的编写方法.docxVIP

使用Thrift RPC编写程序1． 概述本文以C++语言为例介绍了thrift RPC的使用方法，包括对象序列化和反序列化，数据传输和信息交换等。本文采用了一个示例进行说明，该示例主要完成传输（上报日志或者报表）功能，该示例会贯穿本文，内容涉及thrift定义，代码生成，thrift类说明，client编写方法，server编写方法等。关于Thrift架构分析，可参考：Thrift架构介绍。关于Thrift文件编写方法，可参考：Thrift使用指南。2． 示例描述假设我们要使用thrift RPC完成一个数据传输任务，数据格式和PRC接口用一个thrift文件描述，具体如下：(1) book.thrift，用于描述书籍信息的thrift接口1234567891011121314151617//book.thrift，namespace cpp examplestructBook_Info {1: i32 book_id,2: string book_name,3: string book_author,4: double book_price,5: string book_publisher,}(2) rpc.thrift，client向server传输数据（上报日志或者报表）的RPC接口12345678910111213//rpc.thriftnamespace cpp exampleinclude book.thriftservice BookServlet {bool Sender(1: listbook.Book_Info books);oneway void Sender2(1: listbook.Book_Info books);}说明：该thrift文件定义了一个service，它包含两个接口，server端需要实现这两个接口以对client提供服务。其中，第一个接口函数是阻塞式的，即要等待server返回值以后才能继续，另外一个声明为oneway类型（返回值为void），表明该函数是非阻塞式的，将数据发给server后不必等待返回结果，但使用该函数时，需要考虑server的承受能力，适度的调整发送频率。3． Thrift文件与生成的代码对应关系每个thrift文件会产生四个文件，分别为：${thrift_name}_constants.h，${thrift_name}_constants.cpp，${thrift_name}_types.h，${thrift_name}_types.cpp对于含有service的thrift文件，会额外生成两个文件，分别为：${service_name}.h，${service_name}.cpp对于含有service的thrift文件，会生成一个可用的server桩：${service_name}._server.skeleton.cpp对于本文中的例子，会产生以下文件：book_constants.h book_constants.cppbook_types.h book_types.cpprpc_constants.h rpc_constants.cpprpc_types.h rpc_types.cppBookServlet.h BookServlet.cppBookServlet_server.skeleton.cpp4． Thrift类介绍Thrift代码包（位于thrift-0.6.1/lib/cpp/src）有以下几个目录：concurrency：并发和时钟管理方面的库processor：Processor相关类protocal：Protocal相关类transport：transport相关类server：server相关类4.1 Transport类（how is transmitted？）负责数据传输，有以下几个可用类：TFileTransport：文件（日志）传输类，允许client将文件传给server，允许server将收到的数据写到文件中。THttpTransport：采用Http传输协议进行数据传输TSocket：采用TCP Socket进行数据传输TZlibTransport：压缩后对数据进行传输，或者将收到的数据解压下面几个类主要是对上面几个类地装饰（采用了装饰模式），以提高传输效率。TBufferedTransport：对某个Transport对象操作的数据进行buffer，即从buffer中读取数据进行传输，或者将数据直接写入bufferTFramedTransport：同TBufferedTransport类似，也会对相关数据进行buffer，同时，它支持定长数据发送和接收。TMemoryBuffer：从一个缓冲区中读写数据4.2 Pr