【通信框架】Apache的开源通信框架thrift概述

在阅读的过程中有不论什么问题。欢迎一起交流

QQ：1494713801

一、作用

Thrift（"Scalable Cross-Language Services Implementation”）最早是Facebook的项目，后来Facebook提供给Apache作为开源项目。

普通情况下的跨机器的通信框架都是跨软件平台的（Linux,windows）, 而Thrift最特别之处在于它是跨语言的：比如，你能够用差点儿全部流行语言（C++, Java, Python, PHP, Ruby, Erlang, Perl, Haskell, C#, Cocoa, JavaScript等等）来实现通讯过程，这样做的优点就是你不用为编程语言发愁。假设server端与client都须要编写，选择你最拿手或项目规定的语言，就能够生成一个通讯框架；假设编写一个server端程序，定义好通讯规则（在Thrift中是.thrift文件）后，你所採用的server端实现语言不会影响到client，以后使用的人能够採用其它编程语言来实现client。

二、Thrift组成

Thrift事实上应分成三个部分，一个叫做Thrift代码生成器。一个叫做Thrift应用框架（库），最后一个是它生成的代码。Thrift应用的基本流程例如以下图所看到的。

从上图，要生成一个Thrift应用，需用下面文件：

一个.thrift文件：该文件是通信接口的定义。最基本的是信息流的格式。
编程语言：这个无需解释。
Thrift代码生成器（Thrift compiler,翻译成代码生成器似乎更合适）：这个东西是安装thrift过程中生成的，它能够产生若干符合你约定通信格式的代码。
Thrift应用框架库：这个东西也是在安装过程中产生的。
其它第三方支撑库：对C++来说，最主要是boost.thread、libevent，log4cxx等，依照执行的模式。生成的代码中可能需用调用这些库。

三、Thrift的安装及使用

1、安装

安装版本号为：Thrift v0.9.1

系统版本号：Ubuntu 14.04 64位

基本安装环境：

g++ 4.2
boost 1.53.0
libssl-dev

Thrift的编译器即代码生成器是由C++编写的，所以须要g++来进行编译安装，且Thrift源代码中用到了boost库中相关实现。比如shared_ptr，所以要事先安装boost库。

Thrift通信过程中使用ssl对数据进行安全包括，假设为安装该库，会在configure时出现 configure: error: "Error: libcrypto required."

Thrift提供了。TThreadSever, TThreadPoolServer, TNonblockingServer四种server框架。TSimpleServer以单一主线程堵塞的方式进行事件处理。TThreadPoolServer以多线程堵塞的方式提供服务。TNonblockingServer以多线程非堵塞方式工作。 TNonblockingServer服务模型的使用须要事先安装libevent。libevent-dev库，libevent是异步事件处理的程序库，其包括我们经常使用的poll，select，epoll等异步处理函数。

安装步骤：

$./configure
$make
#sudo make install

configure的结果最后一部分例如以下，当中 Build TNonblockingServer .. : yes的结果对于使用异步的server模型是必须的。

anonymalias@anonymalias-Rev-1-0:~/download/thrift-0.9.1$./configure
......
thrift 0.9.1

Building C++ Library ......... : yes
Building C (GLib) Library .... : no
Building Java Library ........ : no
Building C# Library .......... : no
Building Python Library ...... : yes
Building Ruby Library ........ : no
Building Haskell Library ..... : no
Building Perl Library ........ : no
Building PHP Library ......... : no
Building Erlang Library ...... : no
Building Go Library .......... : no
Building D Library ........... : no

C++ Library:
  Build TZlibTransport ...... : yes
  Build TNonblockingServer .. : yes
  Build TQTcpServer (Qt) .... : no

Python Library:
  Using Python .............. : /usr/bin/python

If something is missing that you think should be present,
please skim the output of configure to find the missing
component.  Details are present in config.log.

在本人电脑上make的时候会出现以下的bug，
ar: .libs/ThriftTest_constants.o: No such file or directory

不知道Makefile怎样生成的，导致上面这个编译文件路径有问题，解决方法有以下两种：

method1：
解决办法时直接从Github(git://git.apache.org/thrift.git)上git clone 源代码。先执行./bootstrap.sh。在依照configure安装。

method2：
能够将已经编译的test/cpp/*.o拷贝到test/cpp/.libs后，继续编译就能够了
cp test/cpp/*.o test/cpp/.libs/

2、使用

1. thrift生成代码

创建Thrift文件：G: est hriftdemoHello.thrift ,内容例如以下：

1
namespace java com.micmiu.thrift.demo

2
 
3
service  HelloWorldService {

4
  string sayHello(1:string username)

5
}

文件夹结构例如以下：

G:	est	hrift>tree /F
卷 other 的目录 PATH 列表
卷序列号为 D238-BE47
G:.
    demoHello.thrift
    demouser.thrift
    thrift-0.8.0.exe

没有子目录

thrift-0.8.0.exe 是官网提供的windows下编译工具。运用这个工具生成相关代码：

1
thrift-0.8.0.exe -r -gen java ./demoHello.thrift

生成后的文件夹结构例如以下：

G:	est	hrift>tree /F
卷 other 的目录 PATH 列表
卷序列号为 D238-BE47
G:.
│  demoHello.thrift
│  demouser.thrift
│  thrift-0.8.0.exe
│
└─gen-java
    └─com
        └─micmiu
            └─thrift
                └─demo
                        HelloWorldService.java

2. 实现接口Iface

java代码：HelloWorldImpl.java

1
package com.micmiu.thrift.demo;

2
 
3
import org.apache.thrift.TException;

4
 
5
/**

6
 * bloghttp://www.micmiu.com

7
 *

8
 * @author Michael

9
 *

10
 */

11
public classHelloWorldImplimplementsHelloWorldService.Iface {

12
 
13
    publicHelloWorldImpl() {

14
    }

15
 
16
    @Override

17
    publicString sayHello(String username)throwsTException {

18
        return"Hi,"+ username +" welcome to my blog www.micmiu.com";

19
    }

20
 
21
}

3.TSimpleServer服务端

简单的单线程服务模型，一般用于測试。

编写服务端server代码：HelloServerDemo.java

1
package com.micmiu.thrift.demo;

2
 
3
import org.apache.thrift.TProcessor;

4
import org.apache.thrift.protocol.TBinaryProtocol;

5
import org.apache.thrift.protocol.TCompactProtocol;

6
import org.apache.thrift.protocol.TJSONProtocol;

7
import org.apache.thrift.protocol.TSimpleJSONProtocol;

8
import org.apache.thrift.server.TServer;

9
import org.apache.thrift.server.TSimpleServer;

10
import org.apache.thrift.transport.TServerSocket;

11
 
12
/**

13
 * bloghttp://www.micmiu.com

14
 *

15
 * @author Michael

16
 *

17
 */

18
public classHelloServerDemo {

19
    publicstaticfinalint
SERVER_PORT = 8090;

20
 
21
    publicvoidstartServer() {

22
        try{

23
            System.out.println("HelloWorld TSimpleServer start ....");

24
 
25
            TProcessor tprocessor =newHelloWorldService.Processor<HelloWorldService.Iface>(

26
                    newHelloWorldImpl());

27
            // HelloWorldService.Processor<HelloWorldService.Iface> tprocessor =

28
            // new HelloWorldService.Processor<HelloWorldService.Iface>(

29
            // new HelloWorldImpl());

30
 
31
            // 简单的单线程服务模型。一般用于測试

32
            TServerSocket serverTransport =newTServerSocket(SERVER_PORT);

33
            TServer.Args tArgs =newTServer.Args(serverTransport);

34
            tArgs.processor(tprocessor);

35
            tArgs.protocolFactory(newTBinaryProtocol.Factory());

36
            // tArgs.protocolFactory(new TCompactProtocol.Factory());

37
            // tArgs.protocolFactory(new TJSONProtocol.Factory());

38
            TServer server =newTSimpleServer(tArgs);

39
            server.serve();

40
 
41
        } 
catch (Exception e) {

42
            System.out.println("Server start error!!!");

43
            e.printStackTrace();

44
        }

45
    }

46
 
47
    /**

48
     * @param args

49
     */

50
    publicstaticvoidmain(String[] args) {

51
        HelloServerDemo server =newHelloServerDemo();

52
        server.startServer();

53
    }

54
 
55
}

编写clientClient代码：HelloClientDemo.java

1
package com.micmiu.thrift.demo;

2
 
3
import org.apache.thrift.TException;

4
import org.apache.thrift.protocol.TBinaryProtocol;

5
import org.apache.thrift.protocol.TCompactProtocol;

6
import org.apache.thrift.protocol.TJSONProtocol;

7
import org.apache.thrift.protocol.TProtocol;

8
import org.apache.thrift.transport.TSocket;

9
import org.apache.thrift.transport.TTransport;

10
import org.apache.thrift.transport.TTransportException;

11
 
12
/**

13
 * bloghttp://www.micmiu.com

14
 *

15
 * @author Michael

16
 *

17
 */

18
public classHelloClientDemo {

19
 
20
    publicstaticfinalString SERVER_IP =
"localhost";

21
    publicstaticfinalint
SERVER_PORT = 8090;

22
    publicstaticfinalint
TIMEOUT = 30000;

23
 
24
    /**

25
     *

26
     * @param userName

27
     */

28
    publicvoidstartClient(String userName) {

29
        TTransport transport =null;

30
        try{

31
            transport =newTSocket(SERVER_IP, SERVER_PORT, TIMEOUT);

32
            // 协议要和服务端一致

33
            TProtocol protocol =newTBinaryProtocol(transport);

34
            // TProtocol protocol = new TCompactProtocol(transport);

35
            // TProtocol protocol = new TJSONProtocol(transport);

36
            HelloWorldService.Client client =newHelloWorldService.Client(

37
                    protocol);

38
            transport.open();

39
            String result = client.sayHello(userName);

40
            System.out.println("Thrify client result =: "+ result);

41
        } 
catch (TTransportException e) {

42
            e.printStackTrace();

43
        } 
catch (TException e) {

44
            e.printStackTrace();

45
        } 
finally {

46
            if(null!= transport) {

47
                transport.close();

48
            }

49
        }

50
    }

51
 
52
    /**

53
     * @param args

54
     */

55
    publicstaticvoidmain(String[] args) {

56
        HelloClientDemo client =newHelloClientDemo();

57
        client.startClient("Michael");

58
 
59
    }

60
 
61
}

先执行服务端程序。日志例如以下：

HelloWorld TSimpleServer start ....

再执行client调用程序。日志例如以下：

Thrify client result =: Hi,Michael welcome to my blog www.micmiu.com

測试成功，和预期的返回信息一致。

參考： http://blog.csdn.net/guxch/article/details/12157151

http://blog.csdn.net/anonymalias/article/details/26154405

http://www.micmiu.com/soa/rpc/thrift-sample/