c++ - 使用 Apache Thrift 使用 HTTP 协议(protocol)实现服务器/客户端

Question

我是 apache thrift 的新手。我想用它来帮助我实现一个服务器，该服务器接受来自客户端的输入，对其进行解析并基于此将其定向到正确的函数，而该函数又会返回对该特定请求的响应。

例如:

1. 客户端发送:/get_list/1(这应该从服务器返回列表#1 中的值)
2. 服务器将输入解析为:get_list && 1
3. 服务器将其映射到 get_list_req，这是一个只有一个参数的结构:i32_t id(在本例中为 1)
4. 服务器将此发送到 getListReq 函数，该函数应返回具有 1 个参数的 get_list_resp 结构:list list_content。

现在我已经在 mylist.thrift 中定义了必要的结构:

struct TGetListRequest {
    1: i32_t id,
}
struct TGetListResponse {
    1: string response_code, //FAIL or SUCCESS
    2: list<string> nodes, 
}

service TmyListService {

    TGetListResponse getListReq( 1:TGetListRequest arg ),
}

现在这会生成必要的文件:

TmyListService_server.skeleton.cpp 
TmyListService.cpp
TmyListService.h
mylistconstants.cpp
mylistconstants.h
mylisttypes.cpp
mylisttypes.h

第一个文件的内容被复制到 TmyListService_server.cpp，其中该类使用其方法实现:getListReq，如下所示:

class TGetListRequestHandler: public TGetListRequestIf {
public:
    TGetListResponse getListReq(TGetListRequest arg){
        ...
    }
};

我在其中提供了以下代码以在 main() 函数中启动服务器:

int main(int argc, char **argv)  {
  int port = 9090;
  shared_ptr<TmyListServiceHandler> handler(new TmyListServiceHandler());
  shared_ptr<TProcessor> processor(new TmyListServiceProcessor(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;
}

现在对我来说是棘手的部分:

1. 我在哪里实现对从客户端到服务器的输入的解析？有人告诉我这是使用 thrift 的简单实现，无需编写您的解析器或使用解析器生成器？我似乎无法弄清楚这个？我在哪里告诉我的服务器如何处理输入，即要将其定向到哪个 Req 函数？

2. 在实现客户端方面，我有以下几点:

   int main(int argc, char **argv) {
    boost::shared_ptr<TSocket> socket(new TSocket("localhost", 9090));
    boost::shared_ptr<TTransport> transport(new TBufferedTransport(socket));
    boost::shared_ptr<TProtocol> protocol(new TBinaryProtocol(transport));
   
    TmyListServiceClient client(protocol);
    TGetListRequest arg;
    arg.id = 1;
    TGetListResponse argz;
    transport->open();
    client.send_getListReq( arg );
    printf("DONE SEDNING");
    client.recv_getListReq( argz );
    transport->close();
   
   return 0;
   }
   

除了打开客户端连接外，这基本上什么都不做。它根本不接受任何输入。我确信这也首先与服务器内处理逻辑的实现有关，但我应该在这里做什么才能让客户端准备好针对服务器进行测试？

Answer 1

你快完成了!

在您的服务器上显示此代码:

shared_ptr<TProcessor> processor(new TmyListServiceProcessor(handler));

处理程序在哪里？!这是实现您的服务的类。

类似于:


class TmyListServiceHandler: public TmyListServiceIf {
public:
virtual TGetListResponse getListReq(TGetListRequest arg) override {
}
};


您的服务 (TmyListServiceIf) 的基础生成于:TmyListService.h

>

查看您对问题所做的编辑，我认为您仍然有处理程序问题。声明处理程序类:TGetListRequestHandler在您添加的新代码中。

然而你正在构造 TmyListServiceHandler 的 main 函数中服务器。当人们改变 IDL 中的东西时，我已经看到这种情况发生并在不删除旧输出的情况下重新生成代码。你最终有两个事物的不同定义。您需要使用 TmyListServiceHandler到处。

根据您的 IDL，TGetListRequest 是一个结构，不应有处理程序。