thrift安裝及python和c++版本調試

一、安裝過程

1.安裝依賴庫

]# yum install boost-devel-static libboost-dev libboost-test-dev libboost-program-options-dev libevent-dev automake libtool flex bison pkg-config g++ libssl-dev ant

2.安裝thrift

先下載thrift-0.9.3.tar.gz，解壓后進入thrift-0.9.3目錄

//需要支持的語言用--with, 不需要支持的語言用--without, 像ruby等語言最好去掉，否則可能會有一些兼容問題
]# ./configure --with-cpp --with-boost --with-python --without-csharp --with-java --without-erlang --without-perl --without-php --without-php_extension --without-ruby --without-haskell  --without-go
]# make
]# make install
//成功會顯示 BUILD SUCCESSFUL，通過thrift命令查看是否安裝成功
]# thrift 

//安裝Thrift的時候遇到，如下錯誤
#./configure --prefix=/usr/local/thrift
trhift configure: error: "Error: libcrypto required."
//解決辦法：
//安裝 openssl openssl-devel (centOS)
#yum -y install openssl openssl-devel
# ./configure --prefix=/usr/local/thrift

二、調通單機版thrift，python版本

1.安裝依賴庫

]# pip install thrift==0.9.3

2.編寫schema文件

//創建schema目錄，創建一個schema文件RecSys.thrift
[root@localhost schema]# cat RecSys.thrift 
service RecSys{
    string rec_data(1:string data)
}

3.使用thrift生成python文件，產生gen-py目錄

]# thrift --gen python RecSys.thrift

4.開發python代碼

// client代碼：
#coding=utf=8

import sys
sys.path.append('../schema/gen-py')

from thrift import Thrift
from thrift.transport import TSocket
from thrift.transport import TTransport
from thrift.protocol import TBinaryProtocol

from RecSys import RecSys


try:
    # 設置端口
    transport = TSocket.TSocket('localhost', port=9090)

    # 設置傳輸層
    transport = TTransport.TBufferedTransport(transport)

    # 設置傳輸協議
    protocol = TBinaryProtocol.TBinaryProtocol(transport)

    client = RecSys.Client(protocol)

    transport.open()

    rst = client.rec_data("are you ok!!!")
    print "receive return data: ", rst

    transport.close()

except Thrift.TException, ex:
    print "%s" % (ex.message)

// server 代碼
#coding=utf=8

import sys
sys.path.append('../schema/gen-py')

from thrift.transport import TSocket
from thrift.transport import TTransport
from thrift.protocol import TBinaryProtocol
from thrift.server import TServer

from RecSys import RecSys
from RecSys.ttypes import *

class RecSysHandler(RecSys.Iface):
    def rec_data(self, a):
        print "Receive: %s" %(a)
        return "I'm OK !!!"


if __name__ == "__main__":

    # 實例化handler
    handler = RecSysHandler()

    # 設置processor
    processor = RecSys.Processor(handler)

    # 設置端口
    transport = TSocket.TServerSocket('localhost', port=9090)

    # 設置傳輸層
    tfactory = TTransport.TBufferedTransportFactory()

    # 設置傳輸協議
    pfactory = TBinaryProtocol.TBinaryProtocolFactory()

    server = TServer.TThreadedServer(processor, transport, tfactory, pfactory)

    print 'Starting the server...'
    server.serve()
    print 'done.'

三、調通單機版thrift，c++版本

1.使用thrift生成c++文件，產生gen-cpp目錄

//在schema目錄下執行
]# thrift --gen cpp RecSys.thrift

2.進入gen-cpp目錄，編譯生成server的bin文件

]# g++ -g -Wall -I/usr/local/include/thrift RecSys_constants.cpp  RecSys.cpp  RecSys_server.skeleton.cpp RecSys_types.cpp -lthrift -o server

3.修改server代碼（RecSys_server.skeleton.cpp）

 23   void rec_data(std::string& _return, const std::string& data) {
 24     // Your implementation goes here
 25     std::cout << "Recevie data: " << data << std::endl;
 26     _return = "I'm OK !!!";
 27   } 

4.執行server代碼

]# ./server

//如果執行報錯: libthrift-0.9.3.so: cannot open shared object file: No such file or directory
解決方法：
]# vim /etc/ld.so.conf
在末尾添加下面一行
/usr/local/lib/
然后再執行：
]# ldconfig

5.執行python的client端代碼

//python的client端調用c++的server端
]# python client.py

6.可以寫一個Makefile文件來編譯生成server的bin文件

在gen-cpp目錄下創建一個Makefile文件

GXX = g++
FLAGS = -g -Wall
INCLUDES = -I/usr/local/include/thrift
LIBS = -L/usr/local/lib/*.so -lthrift

SERVER_OBJECTS = RecSys_constants.cpp  RecSys.cpp RecSys_server.skeleton.cpp RecSys_types.cpp
CLIENT_OBJECTS = RecSys.cpp client.cpp

server:
	$(GXX) $(INCLUDES) $(SERVER_OBJECTS) $(LIBS) -o server

client:
	$(GXX) $(INCLUDES) $(CLIENT_OBJECTS) $(LIBS) -o client

.PHONY: clean 
clean:
	rm -rf server
//備注：.PHONY: clean 是為了防止當前目錄下有clean同名文件，導致clean刪除命令無法執行

7.編寫c++的client端代碼

#include "RecSys.h"
#include <iostream>
#include <string>

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

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


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));

    transport->open();

    RecSysClient client(protocol);

    string send_data = "can you help me ???";
    string recevie_data;
    client.rec_data(recevie_data, send_data);

    cout << "Send data:" << send_data << endl;
    cout << "Receive data:" << recevie_data << endl;

    transport->close();
}