使用RPC框架Apache Thrift在远程主机运算并返回

新建一个count.thrift文件：

#

/**
* Thrift files can namespace, package, or prefix their output in various
* target languages.
*/
namespace cpp freebird

/**
* Defining a removed class named WorkerManager
*/
service WorkerManager {

/**
* client calls ping method to make sure service process is active or dead
*/
void count(),
i32 add(1:i32 a,2:i32 b),
i32 dec(1:i32 a,2:i32 b),
i32 multi(1:i32 a,2:i32 b),
i32 div(1:i32 a,2:i32 b),
}

然后在count.thrift文件同目录下执行：

thrift -r --gen cpp count.thrift
cd gen-cpp
vim WorkerManager_server.skeleton.cpp

修改WorkerManager_server.skeleton.cpp如下：

// This autogenerated skeleton file illustrates how to build a server.
// You should copy it to another filename to avoid overwriting it.

#include "WorkerManager.h"
#include <thrift/protocol/TBinaryProtocol.h>
#include <thrift/server/TSimpleServer.h>
#include <thrift/transport/TServerSocket.h>
#include <thrift/transport/TBufferTransports.h>

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

using boost::shared_ptr;

using namespace  ::freebird;

class WorkerManagerHandler : virtual public WorkerManagerIf {
public:
WorkerManagerHandler() {
// Your initialization goes here
}

/**
* client calls ping method to make sure service process is active or dead
*/
void count() {
// Your implementation goes here
printf("count\n");
}

int32_t add(const int32_t a, const int32_t b) {
// Your implementation goes here
printf("add\n");
return a + b;
}

int32_t dec(const int32_t a, const int32_t b) {
// Your implementation goes here
printf("dec\n");
return a - b;
}

int32_t multi(const int32_t a, const int32_t b) {
// Your implementation goes here
printf("multi\n");
return a*b;
}

int32_t div(const int32_t a, const int32_t b) {
// Your implementation goes here
printf("div\n");
return a/b;
}

};

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

然后编译执行：

g++ -g -I/usr/local/include/thrif -L /usr/local/lib/*.so -lthrift WorkerManager.cpp count_types.cpp count_constants.cpp WorkerManager_server.skeleton.cpp -o serve

./serve

至此，服务端配置完成，监听也已经开启。

然后在另一台主机装好Apache Thrift，并用上面同样的方式生成客户端代码。

进入到客户端机器的gen-cpp目录，执行：

touch Client.cpp
gedit Client.cpp

键入以下代码：

#include "WorkerManager.h"  // Your .h File
#include <iostream>
#include <thrift/transport/TSocket.h>
#include <thrift/transport/TBufferTransports.h>
#include <thrift/protocol/TBinaryProtocol.h>
using namespace std;
using namespace apache::thrift;
using namespace apache::thrift::protocol;
using namespace apache::thrift::transport;
using boost::shared_ptr;
using namespace std;
using namespace  ::freebird;

int main(int argc, char **argv) {
boost::shared_ptr<TSocket> socket(new TSocket("server_ip", 9090));//替换ip
boost::shared_ptr<TTransport> transport(new TBufferedTransport(socket));
boost::shared_ptr<TProtocol> protocol(new TBinaryProtocol(transport));
WorkerManagerClient client(protocol);

transport->open();

// Your Codes
client.count();
cout << "1 + 1 = " << client.add(1, 1) << endl;
cout << "2 * 5 = " << client.multi(1, 1) << endl;
cout << "1 -10 = " << client.dec(1, 10) << endl;
cout << "6 / 2 = " << client.div(1, 1) << endl;
transport->close();
return 0;
}

然后：

g++ -g -I/usr/local/include/thrif -L /usr/local/lib -lthrift testping_constants.cpp Client.cpp WorkerManager.cpp testping_types.cpp -o client
#-I 链接include目录，-L链接lib文件
./client

就可以本机看到远程主机计算的结果了。