Windows平台下Thrift安装与使用

阳光穿透心脏的1/2处 2022-05-29 05:20 367阅读 0赞

参考地址：https://github.com/hongliuliao/thrift-generator

https://www.jianshu.com/p/397ac09dca43?open\_source=weibo\_search

> The Apache Thrift software framework, for scalable cross-language services development, combines a software stack with a code generation engine to build services that work efficiently and seamlessly between C++, Java, Python, PHP, Ruby, Erlang, Perl, Haskell, C\#, Cocoa, JavaScript, Node.js, Smalltalk, OCaml and Delphi and other languages.

通过官方介绍，我们可以了解到Thrift是一个软件框架，可以提供跨语言的服务开发。Thrift框架包含一个软件栈，包含生成各种语言的引擎，我们通过Thrift提供的接口定义语言（IDL）来定义接口，然后引擎会自动生成各种语言的代码。

作者：落落书生  
链接：https://www.jianshu.com/p/397ac09dca43  
來源：简书  
著作权归作者所有。商业转载请联系作者获得授权，非商业转载请注明出处。

## 四.Thrift基本概念 ##

1.数据类型

*  基本类型：
    
     *  bool：布尔值，true 或 false，对应 Java 的 boolean
     *  byte：8 位有符号整数，对应 Java 的 byte
     *  i16：16 位有符号整数，对应 Java 的 short
     *  i32：32 位有符号整数，对应 Java 的 int
     *  i64：64 位有符号整数，对应 Java 的 long
     *  double：64 位浮点数，对应 Java 的 double
     *  string：utf-8编码的字符串，对应 Java 的 String
 *  结构体类型：
    
     *  struct：定义公共的对象，类似于 C 语言中的结构体定义，在 Java 中是一个 JavaBean
 *  容器类型：
    
     *  list：对应 Java 的 ArrayList
     *  set：对应 Java 的 HashSet
     *  map：对应 Java 的 HashMap
 *  异常类型：
    
     *  exception：对应 Java 的 Exception
 *  服务类型：
    
     *  service：对应服务的类

2.服务端编码基本步骤：

*  实现服务处理接口impl
 *  创建TProcessor
 *  创建TServerTransport
 *  创建TProtocol
 *  创建TServer
 *  启动Server

3.客户端编码基本步骤：

*  创建Transport
 *  创建TProtocol
 *  基于TTransport和TProtocol创建 Client
 *  调用Client的相应方法

4.数据传输协议

*  TBinaryProtocol : 二进制格式.
 *  TCompactProtocol : 压缩格式
 *  TJSONProtocol : JSON格式
 *  TSimpleJSONProtocol : 提供JSON只写协议, 生成的文件很容易通过脚本语言解析

tips:客户端和服务端的协议要一致

二、thrift自带的测试样例

进入tutorial文件夹，shared.thrift和tutorial.thrift是接口定义文件。

thrift -r --gen java tutorial.thrift

thirft -r --gen cpp tutorial.thrift

执行这两条命令可以生成gen-java和gen-cpp两个文件夹，这些是thrift编译器自动生成的代码。

然后到java目录下，执行ant命令，编译成功后，在两个不同的窗口下执行以下命令：

./JavaServer

./JavaClient simple

进入cpp目录下，执行make命令，如果编译出错，第一个错误是

/usr/local/include/thrift/protocol/TBinaryProtocol.tcc:147:35: error: there are no arguments to ‘htons’ that depend on a template parameter, so a declaration of ‘htons’ must be available

则修改Makefile，加上编译选项-DHAVE\_NETINET\_IN\_H

server: CppServer.cpp

g++ -DHAVE\_NETINET\_IN\_H -o CppServer -I$\{THRIFT\_DIR\} -I$\{BOOST\_DIR\}  -I../gen-cpp -L$\{LIB\_DIR\} -lthrift CppServer.cpp $\{GEN\_SRC\}

client: CppClient.cpp

g++ -DHAVE\_NETINET\_IN\_H -o CppClient -I$\{THRIFT\_DIR\} -I$\{BOOST\_DIR\}  -I../gen-cpp -L$\{LIB\_DIR\} -lthrift CppClient.cpp $\{GEN\_SRC\}

编译通过生，将生成CppClient和CppServer两个可执行程序。同样，在两个不同的窗口执行以下命令：

./CppServer

./CppClient

而且java和c++的Client和Server都可以交叉运行。比如运行JavaServer和CppClient也能得到同样的结果。以此达到了多语言的相互调用。

三、Hello World

仿照tutorial，写一个简单的hello world。在tutorial平级目录下，建立目录hello，这里只是为了测试需要。

服务端用java，客户端用java和c++。

1. 编写tt.thrift

namespace java demo

namespace cpp demo

service Hello\{

string helloString(1:string para)

2. 编译生成代码

thrift -r --gen java tt.thrift

thrift -r --gen cpp tt.thrift

生成gen-java和gen-cpp两个文件夹

gen-cpp下有如下文件

Hello.cpp  Hello.h  Hello\_server.skeleton.cpp  tt\_constants.cpp  tt\_constants.h  tt\_types.cpp  tt\_types.h

其中Hello.h,Hello.cpp中定义了远程调用的接口，实现了底层通信。可以在Hello.h中找到客户端远程调用需要用到的类HelloClient，调用方法：

void helloString(std::string& \_return, const std::string& para);

这个跟thrift文件中申明的方法有点不一定，返回参数是通过引用传回来的。

Hello\_server.skeleton.cpp将实现Hello.h的服务端接口，如果要用c++作为服务端，还需要将这个文件拷出去，重命名，实现类HelloHandler的方法helloString，远程调用方法的业务逻辑也就写在helloString中。可能还需要改main函数中的端口信息。

gen-java/demo下只有Hello.java一个文件，它定义了服务端和客户端的接口，实现了底层的通信。

3. 编写java服务端和客户端

仿照tutorial，在hello目录下建立java目录，将tutorial/java/下的一些文件和目录拷到hello/java下

build.xml JavaClient  JavaServer  src

删除src下所有文件，在src下编写代码。

1） HelloImpl.java 远程过程调用的业务逻辑

import demo.\*;

import org.apache.thrift.TException;

class HelloImpl implements Hello.Iface \{

public HelloImpl() \{\}

public String helloString(String para) throws org.apache.thrift.TException \{

//各种业务逻辑

return "hello " + para;

2) Server.java  服务端程序

import demo.\*;

import java.io.IOException;

import org.apache.thrift.protocol.TBinaryProtocol;

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

import org.apache.thrift.server.TServer;

import org.apache.thrift.server.TThreadPoolServer.Args;

import org.apache.thrift.server.TThreadPoolServer;

import org.apache.thrift.transport.TServerSocket;

import org.apache.thrift.transport.TTransportException;

public class Server \{

private void start() \{

try \{

TServerSocket serverTransport = new TServerSocket( 7911);

Hello.Processor processor = new Hello.Processor(new HelloImpl());

Factory protFactory = new TBinaryProtocol.Factory(true, true);

Args args = new Args(serverTransport);

args.processor(processor);

args.protocolFactory(protFactory);

TServer server = new TThreadPoolServer(args);

//TServer server = new TThreadPoolServer(processor, serverTransport, protFactory);

System.out.println("Starting server on port 7911 ...");

server.serve();

\} catch (TTransportException e) \{

e.printStackTrace();

\} catch (Exception e) \{

e.printStackTrace();

public static void main(String args\[\]) \{

Server srv = new Server();

srv.start();

3) Client.java 客户端程序

import demo.\*;

import java.io.IOException;

import org.apache.thrift.\*;

import org.apache.thrift.protocol.\*;

import org.apache.thrift.transport.\*;

public class Client \{

public static void main(String \[\] args) \{

try \{

TTransport transport = new TSocket(" localhost",  7911);

TProtocol protocol = new TBinaryProtocol(transport);

Hello.Client client = new Hello.Client(protocol);

transport.open();

System.out.println (" Client calls hello ");

System.out.println(client.helloString("world"));

transport.close();

\} catch (TException x) \{

x.printStackTrace();

4) 修改 build.xml

<description> Thrift Hello</description>

</fileset>

</fileset>

</path>

</path>

</target>

</target>

</target>

</target>

</project>

5) 编译

ant

将生成build文件夹

Client.class  demo  hello  HelloImpl.class  hello.jar  Server.class

6) 修改执行脚本

JavaClient

java -cp http://www.cnblogs.com/lib/java/build/lib/\*:http://www.cnblogs.com/lib/java/build/\*: hello.jar Client

JavaServer

java -cp http://www.cnblogs.com/lib/java/build/lib/\*:http://www.cnblogs.com/lib/java/build/\*: hello.jar Server

4. 编写c++客户端

同样仿照tutorial，将tutorial/cpp中的Makefile和CppClient.cpp拷到hello/cpp下。

1) 将CppClient.cpp重命名为Client.cpp，并修改

\#include <stdio.h>

\#include <unistd.h>

\#include <sys/time.h>

\#include <protocol/TBinaryProtocol.h>

\#include <transport/TSocket.h>

\#include <transport/TTransportUtils.h>

\#include "../gen-cpp/Hello.h"

\#include <string>

using namespace std;

using namespace apache::thrift;

using namespace apache::thrift::protocol;

using namespace apache::thrift::transport;

using namespace demo;

using namespace boost;

int main(int argc, char\*\* argv) \{

shared\_ptr<TTransport> socket(new TSocket(" localhost",  7911));

shared\_ptr<TTransport> transport(new TBufferedTransport(socket));

shared\_ptr<TProtocol> protocol(new TBinaryProtocol(transport));

HelloClient client(protocol);

try \{

transport->open();

string ret;

client.helloString(ret, "world");

printf("%s\\n", ret.c\_str());

transport->close();

\} catch (TException &tx) \{

printf("ERROR: %s\\n", tx.what());

2). 修改Makefile

BOOST\_DIR = /usr/local/boost/include/boost-1\_33\_1/

THRIFT\_DIR = /usr/local/include/thrift

LIB\_DIR = /usr/local/lib

GEN\_SRC =  ../gen-cpp/tt\_types.cpp ../gen-cpp/Hello.cpp

default: client

client: Client.cpp

g++  \-DHAVE\_NETINET\_IN\_H  \-o client -I$\{THRIFT\_DIR\} -I$\{BOOST\_DIR\}  -I../gen-cpp -L$\{LIB\_DIR\} -lthrift Client.cpp $\{GEN\_SRC\}

clean:

$(RM) -r client

3). 编译

make

生成可执行文件client

5. 运行程序

运行服务端程序，java目录下：./JavaServer

运行客户端程序，cpp目录下：./client

这样c++程序通过 client.helloString(ret, "client") 可以调用服务端的java接口String helloString(String para)。

从而实现了远程多语言调用。

一个不会敲代码的程序员

Windows平台下Thrift安装与使用

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关 Thrift在Windows下安装

相关 Windows 平台下使用ffmepg

相关 Windows平台下安装MongoDB

相关 Windows平台下Thrift安装与使用

相关 Windows平台下Java,tomcat安装与环境配置，

相关【Apache Thrift】windows下thrift的安装(一)

相关 Windows平台下SVN安装配置及使用

相关 gitbook安装与使用之windows下搭建gitbook平台

相关 windows安装thrift

相关 thrift多平台安装