RPC远程过程调用--Thrift

RPC远程过程调用–Thrift

简介

• Thrift是一个由Facebook开发的轻量级、跨语言的远程服务调用框架，后进入Apache开源项目。支持通过自身接口定义语言IDL定义RPC接口和数据类型，然后通过编译器生成不同语言代码，用于构建抽象易用、可互操作的RPC客户端和服务器。
• Thrift软件栈分层从下向上分别为：传输层(Transport Layer)、协议层(Protocol Layer)、处理层(Processor Layer)和服务层(Server Layer)。
• 具有开发速度快、易维护、高效、跨语言（C++、 Java、Python、PHP、Ruby、C#、、JavaScript、Node.js、等）优点
• 应用广泛：hadFacebook和

安装（源码编译安装）

• 下载源码
  https://github.com/apache/thrift

• 安装编译工具和依赖项

sudo apt install build-essential automake bison flex libtool pkg-config

• 解压后配置和编译

./bootstrap.sh
./configure
make

• 安装

sudo make instal

• 配置环境变量和映射库

echo 'export PATH="/usr/local/bin:$PATH"' >> ~/.bashrc
source ~/.bashrc

• 更新库缓存
  sudo ldconfig

• 查看安装结果

thrift --version
Thrift version 0.21.0

远程过程调用服务器客户端Demo

• 编写Thrift IDL 文件<calculator.thrift>定义服务或数据类型

namespace cpp tutorialservice Calculator {i32 add(1:i32 num1, 2:i32 num2)
}

• 使用thrift编译器生成C++代码

thrift --gen cpp test.thrift

- 编写服务器和客户端应用代码

/* Server.cpp */
#include <iostream>
#include <thrift/server/TSimpleServer.h>
#include <thrift/transport/TServerSocket.h>
#include <thrift/protocol/TBinaryProtocol.h>
#include <thrift/transport/TBufferTransports.h>
#include "gen-cpp/Calculator.h" // 根据实际生成的目录结构包含正确的头文件using namespace apache::thrift;
using namespace apache::thrift::server;
using namespace apache::thrift::transport;
using namespace apache::thrift::protocol;
using namespace tutorial;class CalculatorHandler : public CalculatorIf
{
public:CalculatorHandler() {}int32_t add(const int32_t num1, const int32_t num2) override{std::cout << "Adding " << num1 << " and " << num2 << std::endl;return num1 + num2;}
};int main()
{int port = 9090;std::shared_ptr<CalculatorHandler> handler = std::make_shared<CalculatorHandler>();std::shared_ptr<TProcessor> processor = std::make_shared<CalculatorProcessor>(handler);std::shared_ptr<TServerTransport> serverTransport = std::make_shared<TServerSocket>(port);std::shared_ptr<TTransportFactory> transportFactory = std::make_shared<TBufferedTransportFactory>();std::shared_ptr<TProtocolFactory> protocolFactory = std::make_shared<TBinaryProtocolFactory>();TSimpleServer server(processor,serverTransport,transportFactory,protocolFactory);std::cout << "Starting the server..." << std::endl;server.serve();std::cout << "Server stopped" << std::endl;return 0;
}

/* Client.cpp */
#include <iostream>
#include <thrift/protocol/TBinaryProtocol.h>
#include <thrift/transport/TSocket.h>
#include <thrift/transport/TTransportUtils.h>
#include "gen-cpp/Calculator.h" // 根据实际生成的目录结构包含正确的头文件using namespace apache::thrift;
using namespace apache::thrift::protocol;
using namespace apache::thrift::transport;
using namespace tutorial;int main()
{// 连接到 Thrift 服务器std::shared_ptr<TTransport> socket = std::make_shared<TSocket>("localhost", 9090);std::shared_ptr<TTransport> transport = std::make_shared<TBufferedTransport>(socket);std::shared_ptr<TProtocol> protocol = std::make_shared<TBinaryProtocol>(transport);CalculatorClient client(protocol);try{// 打开连接transport->open();// 调用远程方法int num1 = 10;int num2 = 5;int result = client.add(num1, num2);std::cout << "Result of adding " << num1 << " and " << num2 << " is: " << result << std::endl;// 关闭连接transport->close();}catch (const TException &tx){std::cerr << "Thrift exception: " << tx.what() << std::endl;}return 0;
}

• 编译

g++ -o Server Server.cpp gen-cpp/Calculator.cpp -I/usr/local/include/thrift -lthrift
g++ -o Client Client.cpp gen-cpp/Calculator.cpp -I/usr/local/include/thrift -lthrift

• 执行

./Server 
Starting the server...Adding 10 and 5

./Client 
Result of adding 10 and 5 is: 15

附件

• 文档
  https://thrift.apache.org/tutorial/
• 源码
  https://github.com/apache/thrift