转自:http://blog.csdn.net/andy_yf/article/details/7487384

thrift做为跨语言调用的方案有高效，支持语言较多，成熟等优点；代码侵入较强是其弱点。

下面记录以C++做服务器，C++,java和python做客户端的示例，这个和本人现在工作环境吻合，使用多线程长连接的socket来建立高效分布式系统的跨语言调用平台。遗憾的是目前版本(0.7.0)的C语言还不支持Compact协议，导致在现在的环境中nginx c module调用thrift要使用binary协议。thrift开发团队似乎对C语言不太感冒。

1.定义idl文件acsuser.thrift

1 structUser{2 1: stringuid,3 2: stringuname,4 3: boolusex,5 4: i16 uage,6 }7 service UserService{8 void add(1: User u),9 User get(1: stringuid),10 }

2.生成c++,java和python代码框架

1 thrift -r --gen cpp acsuser.thrift2 thrift -r --gen java acsuser.thrift3 thrift -r --gen py acsuser.thrift

这时生成子目录gen-cpp,gen-java,gen-py

3.生成C++服务端代码

cp gen-cpp/UserService_server.skeleton.cpp UserServer.cpp

修改UserServer.cpp

1 #include "UserService.h"

2 #include

3 //#include

4 #include

5 #include

6 #include

7 #include

8 #include

9 #include

10 #include

11 #include

12

13 using namespace::apache::thrift;14 using namespace::apache::thrift::protocol;15 using namespace::apache::thrift::transport;16 using namespace::apache::thrift::server;17 using namespace::apache::thrift::concurrency;18

19 usingboost::shared_ptr;20

21 class UserServiceHandler : virtual publicUserServiceIf {22 public:23 UserServiceHandler() {24 //Your initialization goes here

25 }26

27 void add(const User&u) {28 //Your implementation goes here

29 printf("uid=%s uname=%s usex=%d uage=%d\n", u.uid.c_str(), u.uname.c_str(), u.usex, u.uage);30 }31

32 void get(User& _return, const std::string&uid) {33 //Your implementation goes here

34 _return.uid = "leo1";35 _return.uname = "yueyue";36 _return.usex = 1;37 _return.uage = 3;38 printf("uid=%s uname=%s usex=%d uage=%d\n", _return.uid.c_str(), _return.uname.c_str(), _return.usex, _return.uage);39 }40

41 };42

43 int main(int argc, char **argv) {44 shared_ptr handler(newUserServiceHandler());45 shared_ptr processor(newUserServiceProcessor(handler));46 shared_ptr protocolFactory(newTCompactProtocolFactory());47 shared_ptr transportFactory(newTBufferedTransportFactory());48 shared_ptr serverTransport(new TServerSocket(9090));49

50 shared_ptr threadManager = ThreadManager::newSimpleThreadManager(10);51 shared_ptr threadFactory = shared_ptr(newPosixThreadFactory());52 threadManager->threadFactory(threadFactory);53 threadManager->start();54 printf("start user server...\n");55

56 TThreadPoolServer server(processor, serverTransport, transportFactory, protocolFactory, threadManager);57 server.serve();58 return 0;59 }

注意这段代码使用TCompactProtocol，需要#include

另外这个是Blocking的多线程服务器

4.生成C++的client文件UserClient.cpp

1 #include "UserService.h"

2 #include

3 #include

4 #include

5 #include

6

7 using namespaceapache::thrift;8 using namespaceapache::thrift::protocol;9 using namespaceapache::thrift::transport;10

11 usingboost::shared_ptr;12

13 int main(int argc, char **argv) {14 boost::shared_ptr socket(new TSocket("localhost", 9090));15 boost::shared_ptr transport(newTBufferedTransport(socket));16 boost::shared_ptr protocol(newTCompactProtocol(transport));17

18 transport->open();19

20 User u;21 u.uid = "leo";22 u.uname = "yueyue";23 u.usex = 1;24 u.uage = 3;25

26 UserServiceClient client(protocol);27 client.add(u);28

29 User u1;30 client.get(u1,"lll");31

32 transport->close();33 printf("uid=%s uname=%s usex=%d uage=%d\n", u1.uid.c_str(), u1.uname.c_str(), u1.usex, u1.uage);34 return 0;35 }

5.生成Makefile

1 BOOST_DIR = /usr/local/include/boost/

2 THRIFT_DIR = /usr/local/include/thrift3 LIB_DIR = /usr/local/lib4 GEN_SRC = ./gen-cpp/acsuser_types.cpp ./gen-cpp/acsuser_constants.cpp ./gen-cpp/UserService.cpp5 default: server client6 server: UserServer.cpp7 g++ -g -o UserServer -I${THRIFT_DIR} -I${BOOST_DIR} -I./gen-cpp -L${LIB_DIR} -lthrift UserServer.cpp ${GEN_SRC}8 client: UserClient.cpp9 g++ -g -o UserClient -lm -pthread -lz -lrt -lssl -I${THRIFT_DIR} -I${BOOST_DIR} -I./gen-cpp -L${LIB_DIR} -lthrift UserClient.cpp ${GEN_SRC}10 clean:11 $(RM) -r UserServer UserClient

6.启动c++ server

1 ./UserServer

7.测试c++ client

1 ./UserClient

8.写java client文件UserClient.java

1 import org.apache.thrift.TException;2 import org.apache.thrift.protocol.TCompactProtocol;3 import org.apache.thrift.protocol.TProtocol;4 import org.apache.thrift.transport.TFramedTransport;5 import org.apache.thrift.transport.TNonblockingSocket;6 import org.apache.thrift.transport.TSocket;7 import org.apache.thrift.transport.TTransport;8 import org.apache.thrift.transport.TTransportException;9

10 //import UserService.Client;

11

12 public classUserClient {13 private voidstart() {14 try{15 TTransport socket = new TSocket("localhost", 9090);16 //TTransport transport = new TFramedTransport(socket);

17 TProtocol protocol = newTCompactProtocol(socket);18

19 UserService.Client client = newUserService.Client(protocol);20 socket.open();21 System.out.println(client.get("lll"));22

23 User u = newUser();24 u.uid="leojava";25 u.uname="yueyue";26 u.usex=true;27 u.uage=3;28 client.add(u);29 socket.close();30

31 } catch(TTransportException e) {32 e.printStackTrace();33 } catch(TException e) {34 e.printStackTrace();35 }36 }37

38 public static voidmain(String[] args) {39 UserClient c = newUserClient();40 c.start();41

42 }43 }

编译和运行java client

1 javac -classpath /usr/local/lib/libthrift-0.7.0.jar:/usr/local/lib/log4j-1.2.14.jar:/usr/local/lib/commons-logging-1.1.1.jar:/usr/local/lib/slf4j-api-1.5.8.jar UserClient.java ./gen-java/*.java2 java -classpath .:./gen-java:/usr/local/lib/libthrift-0.7.0.jar:/usr/local/lib/log4j-1.2.14.jar:/usr/local/lib/commons-logging-1.1.1.jar:/usr/local/lib/slf4j-api-1.5.8.jar:/usr/local/lib/slf4j-log4j12-1.5.8.jar UserClient

9.写Python client文件PythonClient.py

1 #!/usr/bin/env python2 import sys3 sys.path.append('./gen-py')4 fromacsuser import UserService5 from acsuser.ttypes import *

6 fromthrift import Thrift7 fromthrift.transport import TSocket8 fromthrift.transport import TTransport9 fromthrift.protocol import TCompactProtocol10

11 # Make socket12 transport = TSocket.TSocket('localhost', 9090)13 # Buffering iscritical. Raw sockets are very slow14 transport =TTransport.TBufferedTransport(transport)15 # Wrap ina protocol16 protocol =TCompactProtocol.TCompactProtocol(transport)17 # Create a client to use the protocol encoder18 client =UserService.Client(protocol)19 # Connect!

20 transport.open()21 # Call Server services22 u = client.get('lll')23 print 'uid=%s uname=%s usex=%d u.uage=%d' %(u.uid,u.uname,u.usex,u.uage)24

25 u1 =User()26 u1.uid='leo'

27 u1.uname='yueyue'

28 u1.usex=1

29 u1.uage=3

30 client.add(u1)

执行python client代码

1 chmod 777PythonClient.py2 ./PythonClient.py