Thrift在C++中的使用

简介: Thrift在C++中的使用

thrift优缺点

优点

官网:https://thrift.apache.org/

Thrift是一个跨语言的服务部署框架,最初由Facebook于2007年开发,2008年进入Apache开源项目。

Thrift通过一个中间语言(IDL, 接口定义语言)来定义RPC的接口和数据类型,然后通过一个编译器生成不同语言的代码(目前支持C++,Java, Python, PHP, Ruby, Erlang, Perl, Haskell, C#, Cocoa, Smalltalk和OCaml),并由生成的代码负责RPC协议层和传输层的实现。

Thrift实际上是实现了C/S模式,通过代码生成工具将接口定义文件生成服务器端和客户端代码(可以为不同语言),从而实现服务端和客户端跨语言的支持。用户在Thirft描述文件中声明自己的服务,这些服务经过编译后会生成相应语言的代码文件,然后用户实现服务(客户端调用服务,服务器端提服务)便可以了。其中protocol(协议层, 定义数据传输格式,可以为二进制或者XML等)和transport(传输层,定义数据传输方式,可以为TCP/IP传输,内存共享或者文件共享等)被用作运行时库。

Thrift支持二进制,压缩格式,以及json格式数据的序列化和反序列化。这让用户可以更加灵活的选择协议的具体形式。更完美的是,协议是可自由扩展的,新版本的协议,完全兼容老的版本!

缺点

极其缺少文档,只能通过读thrift代码充分的使用thrift,洽洽这是一件有乐趣的事情。

性能

image.png

在CompactProtocol情况下性能和ProtoBuffer相当,

BinaryProtocol情况下性能是ProtoBuffer的60%左右。

thrift文件定义

namespace cpp example
struct Book_Info {
       1: i32 book_id,
       2: string book_name,
       3: string book_author,
       4: double book_price,
       5: string book_publisher,
}
namespace cpp example
include "book.thrift"
service BookServlet {
        bool Sender(1: list<book.Book_Info> books);
        oneway void Sender2(1: list<book.Book_Info> books);
}

代码生成

book.thrift

/usr/bin/thrift --gen cpp book.thrift

thrift会在gen-cpp下面生成对应的cpp文件:

├── book_constants.cpp
├── book_constants.h
├── book_types.cpp
└── book_types.h

rpc.thrift

/usr/bin/thrift --gen cpp rpc.thrift

thrift会在gen-cpp下面生成对应的cpp文件:

├── BookServlet.cpp
├── BookServlet.h
├── BookServlet_server.skeleton.cpp
├── rpc_constants.cpp
├── rpc_constants.h
├── rpc_types.cpp
└── rpc_types.h

client端代码

#include "gen-cpp/BookServlet.h"
#include <thrift/transport/TSocket.h>
#include <thrift/transport/TBufferTransports.h>
#include <thrift/protocol/TBinaryProtocol.h>
using namespace apache::thrift;
using namespace apache::thrift::transport;
using namespace apache::thrift::protocol;
using namespace example;
int main(int argc, char** argv) {
  boost::shared_ptr<TTransport> socket(new TSocket("localhost", 9090));
  boost::shared_ptr<TTransport> transport(new TBufferedTransport(socket));
  boost::shared_ptr<TProtocol> protocol(new TBinaryProtocol(transport));
  example::BookServletClient client(protocol);
  try {
      transport->open();
      std::vector<Book_Info> books;
      books.push_back(Book_Info());
      Book_Info &t0 = *books.rbegin();
      t0.book_name = "bookname0";
      books.push_back(Book_Info());
      Book_Info &t1 = *books.rbegin();
      t1.book_name = "bookname1";
      client.Sender(books);
      transport->close();
  } catch (TException &tx) {
      printf("ERROR: %s\n", tx.what());
  }
  printf("the end\n");
  return 0;
}

server端代码

#include <thrift/protocol/TBinaryProtocol.h>
#include <thrift/server/TSimpleServer.h>
#include <thrift/transport/TServerSocket.h>
#include <thrift/transport/TBufferTransports.h>
#include <iostream>
#include "gen-cpp/BookServlet.h"
using namespace ::apache::thrift;
using namespace ::apache::thrift::protocol;
using namespace ::apache::thrift::transport;
using namespace ::apache::thrift::server;
using namespace example;
class BookServletHandler : virtual public BookServletIf {
public:
    BookServletHandler() {}
    bool Sender(const std::vector<Book_Info> & books) {
        typedef  std::vector<Book_Info>::const_iterator Itr;
        for (Itr i = books.begin(); i != books.end(); ++i) {
            std::cout<<i->book_name<<std::endl;
        }
    }
    void Sender2(const std::vector<Book_Info> & books) {
        printf("Sender2\n");
    }
};
int main(int argc, char **argv) {
  boost::shared_ptr<BookServletHandler> handler(new BookServletHandler());
  boost::shared_ptr<TProcessor> processor(new BookServletProcessor(handler));
  boost::shared_ptr<TServerTransport> serverTransport(new TServerSocket(9090));
  boost::shared_ptr<TTransportFactory> transportFactory(new TBufferedTransportFactory());
  boost::shared_ptr<TProtocolFactory> protocolFactory(new TBinaryProtocolFactory());
  TSimpleServer server(processor, serverTransport, transportFactory, protocolFactory);
  server.serve();
  return 0;
}

编译和运行

g++ client.cpp gen-cpp/book_constants.cpp gen-cpp/BookServlet.cpp gen-cpp/book_types.cpp -lthrift  -o client
g++ server.cpp gen-cpp/book_constants.cpp gen-cpp/BookServlet.cpp gen-cpp/book_types.cpp -lthrift  -o server
相关文章
|
分布式计算 分布式数据库 Apache
HBase &amp; thrift &amp; C++编程
目录 目录 1 1. 前言 1 2. 启动和停止thrift2 1 2.1. 启动thrift2 1 2.2. 停止thrift2 1 2.3. 启动参数 2 3. hbase.thrift 2 3.1. 编译hbase.thrift 2 4. thrift_helper.h 3 5. 示例代码 4   1. 前言 本文目的是介绍使用C++如何操作HBase。
1685 0
|
分布式计算 分布式数据库 Apache
HBase & thrift & C++编程
HBase & thrift & C++编程.pdf 目录 目录 1 1. 前言 1 2. 启动和停止thrift2 1 2.
1594 0
|
Java Shell Apache
使用thrift做c++,java和python的相互调用
linux上安装thrift见 http://jinghong.iteye.com/blog/1102535 thrift做为跨语言调用的方案有高效,支持语言较多,成熟等优点;代码侵入较强是其弱点。
1142 0
|
10月前
|
编译器 C++ 开发者
【C++篇】深度解析类与对象(下)
在上一篇博客中,我们学习了C++的基础类与对象概念,包括类的定义、对象的使用和构造函数的作用。在这一篇,我们将深入探讨C++类的一些重要特性,如构造函数的高级用法、类型转换、static成员、友元、内部类、匿名对象,以及对象拷贝优化等。这些内容可以帮助你更好地理解和应用面向对象编程的核心理念,提升代码的健壮性、灵活性和可维护性。
|
6月前
|
人工智能 机器人 编译器
c++模板初阶----函数模板与类模板
class 类模板名private://类内成员声明class Apublic:A(T val):a(val){}private:T a;return 0;运行结果:注意:类模板中的成员函数若是放在类外定义时,需要加模板参数列表。return 0;
168 0
|
6月前
|
存储 编译器 程序员
c++的类(附含explicit关键字,友元,内部类)
本文介绍了C++中类的核心概念与用法,涵盖封装、继承、多态三大特性。重点讲解了类的定义(`class`与`struct`)、访问限定符(`private`、`public`、`protected`)、类的作用域及成员函数的声明与定义分离。同时深入探讨了类的大小计算、`this`指针、默认成员函数(构造函数、析构函数、拷贝构造、赋值重载)以及运算符重载等内容。 文章还详细分析了`explicit`关键字的作用、静态成员(变量与函数)、友元(友元函数与友元类)的概念及其使用场景,并简要介绍了内部类的特性。
261 0
|
8月前
|
编译器 C++ 容器
【c++11】c++11新特性(上)(列表初始化、右值引用和移动语义、类的新默认成员函数、lambda表达式)
C++11为C++带来了革命性变化,引入了列表初始化、右值引用、移动语义、类的新默认成员函数和lambda表达式等特性。列表初始化统一了对象初始化方式,initializer_list简化了容器多元素初始化;右值引用和移动语义优化了资源管理,减少拷贝开销;类新增移动构造和移动赋值函数提升性能;lambda表达式提供匿名函数对象,增强代码简洁性和灵活性。这些特性共同推动了现代C++编程的发展,提升了开发效率与程序性能。
303 12
|
9月前
|
设计模式 安全 C++
【C++进阶】特殊类设计 && 单例模式
通过对特殊类设计和单例模式的深入探讨,我们可以更好地设计和实现复杂的C++程序。特殊类设计提高了代码的安全性和可维护性,而单例模式则确保类的唯一实例性和全局访问性。理解并掌握这些高级设计技巧,对于提升C++编程水平至关重要。
180 16
|
10月前
|
编译器 C语言 C++
类和对象的简述(c++篇)
类和对象的简述(c++篇)