Java thrift服務器和客戶端創建實例

首先環境介紹一下：

1.IntelliJ IDEA 2017.1

2.thrift-0.9.3

相信大家在看我這篇文章的時候已經對thrift通信框架已有所調研，這里就不再贅述了，直接進入正題：

<1>創建HelloWorld.thrift

namespace java com.thrift.demo

service HelloWorldService{
string sayHello(1:string username)
}

 <2>利用thrift生成HelloWorld.java文件，cmd指令下進入thrift當前目錄下輸入命令

thrift.exe -gen java HelloWorld.thrift

java為要生成文件的類型,HelloWorld.thrift為前面的文件。

<3>創建IDEA 下的maven項目，其中的好處就不一一說明了，最重要的一條就是可以在pom.xml文件中添加dependency，能夠在項目中自行下載庫文件，方便協同開發中出現的開發包不對應的情況。

<dependency>
            <groupId>javax.servlet</groupId>
            <artifactId>javax.servlet-api</artifactId>
            <version>3.1.0</version>
        </dependency>
        <dependency>
            <groupId>jstl</groupId>
            <artifactId>jstl</artifactId>
            <version>1.2</version>
        </dependency>
        <dependency>
            <groupId>org.apache.thrift</groupId>
            <artifactId>libthrift</artifactId>
            <version>0.9.3</version>
        </dependency>
        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-log4j12</artifactId>
            <version>1.7.5</version>
        </dependency>

上述pom引入相應的依賴項就可以讓它自行下載。

<4>項目的結構圖當前如下所示：

File--Project Structure--Modules，在main文件夾下新建java文件夾並設為Soueces類型（因為在Sources文件下可以新建java class文件）

同時將thrift生成的HelloWorld.java文件復制到該目錄下

<5>實現接口Iface

java代碼：HelloWorldImpl.java

package com.jmust.thrift.demo;

import org.apache.thrift.TException;

/**
 * Created by Administrator on 2017/3/31.
 */
public class HelloWorldImpl implements HelloWorldService.Iface {

    public HelloWorldImpl() {
    }

    @Override
    public String sayHello(String username) throws TException {
        return "Hi,"+username+"Welcome to my blog http://www.cnblogs.com/zfygiser";
    }
}

<6>服務端TSimpleServer

java代碼：HelloServer.java

/**
 * Created by Administrator on 2017/3/31.
 */
package com.jmust.thrift.demo;

import org.apache.thrift.TProcessor;
import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.server.TServer;
import org.apache.thrift.server.TSimpleServer;
import org.apache.thrift.transport.TServerSocket;

public class HelloServer {
    public final static int SERVER_PORT = 7099;
    private static String SERVER_IP = "localhost";

    public void startServer() {
        try {
            System.out.println("HelloWorld Server start...");

            TServerSocket serverTransport = new TServerSocket(SERVER_PORT);
            TServer.Args args = new TServer.Args(serverTransport);
            TProcessor process = new HelloWorldService.Processor(new HelloWorldImpl());
            TBinaryProtocol.Factory portFactory = new TBinaryProtocol.Factory(true, true);
            args.processor(process);
            args.protocolFactory(portFactory);

            TServer server = new TSimpleServer(args);
            server.serve();

        } catch (Exception e) {
            System.out.println("Server start error");
            e.printStackTrace();
        }
    }

    public static void main(String[] args) {
        HelloServer server = new HelloServer();
        server.startServer();
    }
}

<7>編寫客戶端代碼

java代碼：Client.java

package com.jmust.thrift.demo;

import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.protocol.TProtocol;
import org.apache.thrift.transport.TSocket;
import org.apache.thrift.transport.TTransport;

/**
 * Created by Administrator on 2017/4/1.
 */
public class Client {
    public static final int SERVER_PORT = 7099;
    public static final String SERVER_IP = "localhost";

    public void startClient(String username) {
        TTransport tTransport = null;
        try {
            tTransport = new TSocket(SERVER_IP, SERVER_PORT);
            //協議要和服務端一致
            TProtocol protocol = new TBinaryProtocol(tTransport);
            HelloWorldService.Client client = new HelloWorldService.Client(protocol);
            tTransport.open();

            String result = client.sayHello(username);
            System.out.println("Thrift client result=" + result);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public static void main(String[] args) {
        Client client = new Client();
        client.startClient("zfy");
    }
}

客戶端測試成功，截圖如下：