概述

Thirft是一个轻量级的RPC框架，现在还是0.13版本，算起来比较年轻了。但该有的都有，他也定义了IDL语言，使用thrift编译生成各个编程语言的接口定义。

环境

基于IDEA、maven来构建。相关环境如下：

总体来说，Thrift上手很快。但是有一些潜在的点，可能会造成一些歧义：

1. IDL定义语言Thrift，需要掌握。这里有一些约定的规则，比如服务方法名与类名不要重合，比如一些关键字index之类的，如果出现，估计会一头雾水。
2. Thrift依赖S4FJ
3. 基于maven构建时，这里是使用手工编译IDL文件，在拷贝到对应目录。

Hello World

这里使用IDEA、MAVEN来作为编辑和编译环境，其步骤与ICE的https://github.com/gaussgao/ice-idea-maven-study基本一致。

1. IDEA生成maven项目，添加相关依赖
2. 编写IDL
3. 编译IDL并将产生的文件拷贝到代码目录
4. 编写Server的实现类，从IDL生成的Iface实现
5. 编写Server的入口类
6. 编写Client的入口类
7. 编译调试
8. 打包，增加pom.xml关于构建的配置
9. 测试

第一步：IDEA生成maven项目，添加thrift依赖

<dependencies>
        <dependency>
            <groupId>org.apache.thrift</groupId>
            <artifactId>libthrift</artifactId>
            <version>0.13.0</version>
        </dependency>

        <!-- https://mvnrepository.com/artifact/ch.qos.logback/logback-classic -->
        <dependency>
            <groupId>ch.qos.logback</groupId>
            <artifactId>logback-classic</artifactId>
            <version>1.2.3</version>
        </dependency>
    </dependencies>

第二步：编写IDL文件

namespace将指定java的目录结构

 namespace java service.demo
 service HelloWorld{
     string helloWorld(1:string para)
 }

第三步：编译IDL文件，并拷贝到src/main/java目录下

thrift-0.13.0 -gen java src\main\idl\HelloWorld.thrift
#将gen-java目录下的server目录拷贝到src.main.java下

第四步：实现Iface接口

public class HelloWorldImpl implements HelloWorld.Iface{
    @Override
    public String helloWorld(String para) throws TException {
        System.out.println("Hello World:"+para);
        return para + ",good day!";
    }
}

第五步：编写Server入口类

public class HWServer {
    /**
     * 启动 Thrift 服务器
     * @param args
     */
    public static void main(String[] args) {
        try {
            TNonblockingServerSocket socket = new TNonblockingServerSocket(7911);
            HelloWorld.Processor processor = new HelloWorld.Processor(new HelloWorldImpl());
            TNonblockingServer.Args arg = new TNonblockingServer.Args(socket);
            arg.protocolFactory(new TBinaryProtocol.Factory());
            arg.transportFactory(new TFramedTransport.Factory());
            arg.processorFactory(new TProcessorFactory(processor));
            TServer server = new TNonblockingServer(arg);
            server.serve();
        } catch (TTransportException e) {
            e.printStackTrace();
        }
    }
}

第六步：编写Client入口类

第七步：开始调试

IDEA内分别启动Server和Client类，可跟踪到网络处理成，看如何实现。F8调试下去，可看到主要是如下类在处理相关信息。

• HelloWorld 这个是thrift生成的
• ProcessFunction.java 处理报文格式等等
• TNonblockingServer.java 具体处理网络请求，发送应答报文，接受通讯事件。

第八步：打包

添加如下代码到pom.xml,将HWServer作为主类放到jar包。

 <build>
        <plugins>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-shade-plugin</artifactId>
                <executions>
                    <execution>
                        <phase>package</phase>
                        <goals>
                            <goal>shade</goal>
                        </goals>
                        <configuration>
                            <transformers>
                                <transformer implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer">
                                    <mainClass>HWServer</mainClass>
                                </transformer>
                            </transformers>
                        </configuration>
                    </execution>
                </executions>
            </plugin>
        </plugins>
        <finalName>thrift-beginner</finalName>
    </build>

第九步：测试

java -cp target\thrift-beginner.jar HWServer
java -cp target\thrift-beginner.jar HWClient

代码

https://github.com/gaussgao/thrift-study