thrift是一個RPC框架，我們使用SpringBoot可以對外暴露http介面，但是系統內部呼叫如果需要較高的效率，需要使用RPC介面，因此我們會需要使用thrift 再暴露一些內部介面

假設我們有一個service類，裡面實現了一個login方法，如果要暴露http的介面，我們需要使用springboot做一個controller，然後在controller裡呼叫這個login，這樣完成一個http介面

但如果我們想對外暴露RPC的login介面，這就需要使用thrift 

前提：新增依賴

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

使用thrift主要分為如下幾步

1、生成thrift 介面檔案（這個介面檔案不是自己寫的java類，是需要使用thrift工具生成的）

由於這個介面檔案是thrift 工具自動生成的，因此我們需要先用thrift 的描述語言寫一下這個介面的定義，然後再用thrift 工具生成

1.1寫介面描述檔案

介面描述檔案是一個字尾名為.thrift的檔案，這面這個檔案是RPCNetAuthService.thrift，是一個介面描述檔案,namespace是最後生成的介面檔案的包名

namespace java com.xxx.mbe.thrift.rpcInterface.auth
service RPCNetAuthService{
    bool login(1:string userAccount,2:string password)
}

1.2生成介面類

根據RPCNetAuthService.thrift生成介面類有兩種方式，一種是下載thrift.exe,使用它的命令生成，另外一種是使用IEDA的thrift外掛來生成

1.2.1 使用thrift.exe生成

網上下載thrift.exe,假設放到了D:\thrift\thrift.exe,將RPCNetAuthService.thrift也放到這個目錄

開啟cmd視窗 執行

cd D:\thrift

thrift --gen java RPCNetAuthService.thrift

這樣在這個目錄下會生成RpcNetAuthService.java，這個就是生成的介面類

1.2.2使用外掛生成

開啟File->Settings->Plugins->搜尋thrift，安裝外掛

然後配置外掛（我專門建立了一個thrift專案，在這個專案裡儲存了所有的thrift檔案，在ProjectStructure裡配置了thrift和輸入路徑輸入語言型別，這樣編譯後會自動將.thrift檔案輸出為對應的java檔案）

將輸出的RpcNetAuthService.java放到一個公共地方（客戶端和伺服器端都能用到）

2、伺服器端實現thrift 介面

下面伺服器端要實現這個介面，新建一個類RPCNetAuthServiceImpl

import com.xxx.mbe.auth.service.NetAuthService;
import com.xxx.mbe.auth.service.impl.NetAuthServiceImpl;
import com.xxx.mbe.thrift.rpcInterface.auth.RPCNetAuthService;
import org.apache.thrift.TException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.stereotype.Service;

/**
 * Created by Test on 2017/7/10.
 */
@Controller
public class RPCNetAuthServiceImpl implements RPCNetAuthService.Iface {
    private static final Logger logger = LoggerFactory.getLogger(RPCNetAuthServiceImpl.class);

    @Autowired
    private NetAuthService netAuthService =new NetAuthServiceImpl();//這裡本來想用注入的方法使用，但是service啟動的時候是靜態類直接new的，所以沒法注入，所以這裡就new了
    @Override
    public boolean login(String userAccount, String password) throws TException {
  

        return netAuthService.login(userAccount,password);//這裡呼叫了Service的方法
    }
}

3、伺服器端啟動服務

啟動服務程式碼如下，在main方法中呼叫下

	private  static void   startRPCServer()
	{
		try {
			// 設定協議工廠為 TBinaryProtocol.Factory
			TBinaryProtocol.Factory proFactory = new TBinaryProtocol.Factory();
			// 關聯處理器與 Hello 服務的實現
			TMultiplexedProcessor processor = new TMultiplexedProcessor();
			TServerTransport t = new TServerSocket(9090);
			TServer server = new TThreadPoolServer(new TThreadPoolServer.Args(t).processor(processor));
			processor.registerProcessor(RPCNetAuthService.class.getSimpleName(), new RPCNetAuthService.Processor<RPCNetAuthService.Iface>(new RPCNetAuthServiceImpl()));
//         TSimpleServer server = new TSimpleServer(new Args(t).processor(processor));
			System.out.println("the serveris started and is listening at 9090...");
			server.serve();
		} catch (TTransportException e) {
			e.printStackTrace();
		}
	}

這樣服務就啟動了，下面需要客戶端呼叫

4、客戶端呼叫介面

首先先建立一個client類

import com.xxx.mbe.thrift.rpcInterface.auth.RPCAuthService;
import com.xxx.mbe.thrift.rpcInterface.auth.RPCNetAuthService;
import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.protocol.TMultiplexedProtocol;
import org.apache.thrift.transport.TSocket;
import org.apache.thrift.transport.TTransportException;
import org.springframework.boot.autoconfigure.security.SecurityProperties;

/**
 * Created by Test on 2017/7/10.
 */
public class AuthClient {

    private  RPCNetAuthService.Client rpcNetAuthService;
    private TBinaryProtocol protocol;
    private TSocket transport ;
    public RPCAuthService.Client getRpcAuthService() {
        return rpcAuthService;
    }

    public RPCNetAuthService.Client getRpcNetAuthService() {
        return rpcNetAuthService;
    }

    public  void  open() throws TTransportException {
        transport.open();
    }
    public  void  close()
    {
        transport.close();
    }
    public   AuthClient() throws TTransportException {
        transport = new TSocket("localhost",9090);
        protocol = new TBinaryProtocol(transport);  

        TMultiplexedProtocol mp2 = new TMultiplexedProtocol(protocol, RPCNetAuthService.class.getSimpleName());
        rpcNetAuthService = new RPCNetAuthService.Client(mp2);
    }
}

在使用的地方如下呼叫

        AuthClient client = new  AuthClient();
        client.open();
            boolean loginResult = client.getRpcNetAuthService().login(userEntity.getUserName(),userEntity.getPassword());
        client.close();