节俭async C++示例

Question

我查看了Apache Thrift发行版，并在apache.org网站上寻找示例，但我没有成功。

我想一个人在一个示例实现异步客户端 的和经典的Apache节俭非阻塞服务器（而不是从 Facebook的较新的分支），它使用“--gen CPP”点我。

我可以看到类似的问题，标题为“apache thrift C++异步客户端”，但答案并不包含所有的部分。

我希望看到“.thrift”文件，然后填写完整的服务器和相应的客户端代码。

我真的很想相信有人已经这样做了，而我只是不如我以前那样擅长谷歌用户。

据我所知，Facebook版本（fbthrift）旨在帮助做得更好，但是我对这个版本似乎有多不稳定感到沮丧。如果任何人都可以指出我每天都没有修改过的稳定版本，我可以考虑作为替代方案。

Answer 1

不知道你是什么意思的异步客户端，但我会尽我所能根据我的理解回答这个问题。

如果通过“异步客户端”，您的意思是像node.js中那样讨论异步，其中执行遵循回调结构，AFAIK不是开源节点的一部分。但是，在fbthrift中可用。 Facebook有很多工具可以与fbthrift一起使用，包括他们流行的开源C++库folly。通过节俭的C++客户端接口调用其他节俭服务必须阻止。

这是我开始使用async非阻塞服务器时的代码。希望它有帮助！

something.thrift

#!/usr/local/bin/thrift --gen cpp 

namespace cpp something 

service Something { 
    i32 ping() 
} 

SomethingServer.cpp

#include "gen-cpp/Something.h" 
#include <thrift/protocol/TBinaryProtocol.h> 
#include <thrift/server/TSimpleServer.h> 
#include <thrift/server/TThreadedServer.h> 
#include <thrift/server/TNonblockingServer.h> 
#include <thrift/transport/TServerSocket.h> 
#include <thrift/transport/TBufferTransports.h> 
#include <thrift/concurrency/ThreadManager.h> 

#include <iostream> 

using std::cout; 
using std::endl; 

class SomethingHandler : virtual public something::SomethingIf { 
public: 
    SomethingHandler() { 
     cout << "Initialized" << endl; 
    } 

    int32_t ping() override { 
     // Your implementation goes here 
     cout << "Ping!" << endl; 
     return 1; 
    } 
}; 

int main(int argc, char **argv) { 
    using namespace ::apache::thrift; 
    using namespace ::apache::thrift::protocol; 
    using namespace ::apache::thrift::transport; 
    using namespace ::apache::thrift::server; 
    using namespace ::apache::thrift::concurrency; 
    using boost::shared_ptr; 
    using namespace ::something; 

    int port = 9090; 
    shared_ptr<SomethingHandler> handler(new SomethingHandler()); 
    shared_ptr<TProcessor> processor(new SomethingProcessor(handler)); 
    shared_ptr<TProtocolFactory> protocolFactory(new TBinaryProtocolFactory()); 

    // using thread pool with maximum 15 threads to handle incoming requests 
    shared_ptr<ThreadManager> threadManager 
     = ThreadManager::newSimpleThreadManager(15); 
    shared_ptr<PosixThreadFactory> threadFactory 
     = shared_ptr<PosixThreadFactory>(new PosixThreadFactory()); 
    threadManager->threadFactory(threadFactory); 
    threadManager->start(); 

    TNonblockingServer server(processor, protocolFactory, port, threadManager); 
    server.serve(); 

    return 0; 
} 

SomethingClient.cpp

#include "Something.h" 

#include <thrift/transport/TSocket.h> 
#include <thrift/transport/TBufferTransports.h> 
#include <thrift/protocol/TBinaryProtocol.h> 

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

using namespace Test; 

int main(int /* argc */, char** /* argv */) { 
    boost::shared_ptr<TSocket> socket(new TSocket("localhost", 9090)); 
    boost::shared_ptr<TTransport> transport(new TFramedTransport(socket)); 
    boost::shared_ptr<TProtocol> protocol(new TBinaryProtocol(transport)); 

    SomethingClient client(protocol); 
    transport->open(); 
    for (auto i = 0; i < 10000; ++i) { 
     client.ping(); 
    } 
    transport->close(); 

    return 0; 
}