Apache Thrift 使用教程

2024-09-02 11:24:12作者：瞿蔚英Wynne

项目介绍

Apache Thrift 是一个高效、跨语言的服务开发框架，由 Facebook 开发并贡献给 Apache 基金会。它通过定义一个简单的服务接口和数据类型，可以生成不同编程语言的代码，实现不同系统之间的通信。Thrift 支持多种传输协议和序列化格式，使得它在分布式系统中广泛应用。

项目快速启动

安装 Thrift 编译器

首先，你需要安装 Thrift 编译器。以下是在 Ubuntu 系统上的安装命令：

sudo apt-get update
sudo apt-get install thrift-compiler

定义 Thrift 文件

创建一个名为 example.thrift 的文件，内容如下：

namespace cpp tutorial
namespace java tutorial

typedef i32 int
typedef string String

struct Example {
    1: int id,
    2: String name
}

service ExampleService {
    Example getExample(1: int id)
}

生成代码

使用 Thrift 编译器生成代码：

thrift --gen cpp --gen java example.thrift

编写服务端和客户端代码

以下是一个简单的 C++ 服务端和客户端示例：

服务端代码

#include <thrift/protocol/TBinaryProtocol.h>
#include <thrift/server/TSimpleServer.h>
#include <thrift/transport/TServerSocket.h>
#include <thrift/transport/TBufferTransports.h>
#include "gen-cpp/ExampleService.h"

using namespace apache::thrift;
using namespace apache::thrift::protocol;
using namespace apache::thrift::transport;
using namespace apache::thrift::server;

using namespace tutorial;

class ExampleServiceHandler : public ExampleServiceIf {
public:
    Example getExample(int32_t id) override {
        Example example;
        example.id = id;
        example.name = "Example Name";
        return example;
    }
};

int main(int argc, char **argv) {
    int port = 9090;
    shared_ptr<ExampleServiceHandler> handler(new ExampleServiceHandler());
    shared_ptr<TProcessor> processor(new ExampleServiceProcessor(handler));
    shared_ptr<TServerTransport> serverTransport(new TServerSocket(port));
    shared_ptr<TTransportFactory> transportFactory(new TBufferedTransportFactory());
    shared_ptr<TProtocolFactory> protocolFactory(new TBinaryProtocolFactory());

    TSimpleServer server(processor, serverTransport, transportFactory, protocolFactory);
    server.serve();
    return 0;
}

客户端代码

#include <thrift/protocol/TBinaryProtocol.h>
#include <thrift/transport/TSocket.h>
#include <thrift/transport/TTransportUtils.h>
#include "gen-cpp/ExampleService.h"

using namespace apache::thrift;
using namespace apache::thrift::protocol;
using namespace apache::thrift::transport;

using namespace tutorial;

int main(int argc, char **argv) {
    shared_ptr<TTransport> socket(new TSocket("localhost", 9090));
    shared_ptr<TTransport> transport(new TBufferedTransport(socket));
    shared_ptr<TProtocol> protocol(new TBinaryProtocol(transport));
    ExampleServiceClient client(protocol);

    try {
        transport->open();
        Example example = client.getExample(1);
        std::cout << "Got example: " << example.name << std::endl;
        transport->close();
    } catch (TException& tx) {
        std::cerr << "ERROR: " << tx.what() << std::endl;
    }
}