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 tutorial

service 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