RPC框架實踐之：Apache Thrift

---

1、概述

RPC（Remote Procedure Call）即 遠程過程調用，說的這麼抽象，其實簡化理解就是一個節點如何請求另外一節點所提供的服務。在文章 微服務調用鏈追蹤中心搭建 一文中模擬出來的調用鏈：ServiceA ---> ServiceB ---> ServiceC 就是一個遠程調用的例子，只不過這篇文章裏是經過RestTemplate這種 同步調用方式，利用的是HTTP協議在應用層完成的，這種方法雖然奏效，但有時效率並不高。而RPC能夠不依賴於應用層協議，能夠直接基於TCP進行遠程調用，在傳輸層中便可完成通訊，所以更適於某些對效率要求更高的場景。因爲RPC調用方式依賴於客戶端與服務端之間創建Socket鏈接來實現二進制數據通訊，底層會比較複雜，因此一些RPC框架應運而生來封裝這種複雜性，讓開發者將精力聚焦於業務之上。常見的RPC框架包括：Thrift、gRPC、Finagle、Dubbo等等，從本文開始做者將選一些實踐一下，本文主要記錄做者對於Thrift框架的實踐過程。

Thrift是Apache的項目，它結合了功能強大的軟件堆棧和代碼生成引擎，能夠在諸多語言之間提供無縫支持。

心動不如行動吧！

注： 本文首發於 My 公衆號 CodeSheep ，可 長按 或 掃描 下面的 當心心 來訂閱 ↓ ↓ ↓

---

2、實驗環境

• Mac OS X 10.13.2
• SpringBoot 2.0.1
• Thrift 0.11.0
• IDE：IntelliJ IDEA 2018.01

---

爲了便於讀者理解，我先將下文內容總結一下，包含7點：

• Thrift環境搭建
• IDEA中Thrift插件配置
• 建立 Thrift 項目並編譯（目的：定義RPC接口）
• 開發Thrift API接口
• 開發RPC服務端
• 開發RPC客戶端
• RPC通訊實際實驗

---

3、Thrift環境搭建

• **方法一：**原生安裝方式，經過官方提供的步驟一步一步來安裝

參考這裏：Mac上Thrift官方安裝教程

• **方法二：**使用 brew 工具（推薦）

brew install thrift

---

4、IDEA中Thrift插件配置

方法一：直接在IDEA界面中配置

打開IDEA的插件中心，搜索 Thrift 便可安裝

方法二：手動下載Thrift插件安裝

就像文章 SpringBoot優雅編碼之：Lombok加持 一文中在IDEA中安裝Lombok插件同樣，有時因爲網絡緣由，方法一不奏效時插件裝不上，此時能夠手動下載插件並安裝。

能夠去以下地址下載Thrift插件：http://plugins.jetbrains.com/plugin/7331-thrift-support

而後去IDEA中 Install plugin from disk... 選擇下載的zip包安裝，而後重啓IDE便可

安裝完成的成功標誌是 Compiler 中出現了 Thrift編譯器！以下圖所示：

---

5、建立 Thrift 項目並編譯（定義RPC接口）

• 第一步：建立Thrift項目並配置

IDE 很智能地在 New Project 時提供 Thrift項目建立選項：

項目建立完成之後，在 Project Settings 中設置好 Facets 的 Thrift配置，以下圖所示，這裏咱們添加一個 Java的Generator

在彈出的對話框中配置好 Output folder 路徑，該路徑用於存放由 thrift文件 轉化而成的 java源文件：

OK，Thrift項目就緒了！

• 第二步：建立thrift接口文件

這裏建立一個thrift接口文件：RPCDateService.thrift

thrift文件的寫法我不贅述，跟gRPC同樣有其本身的語法，namespace是最後生成的接口文件的包名

namespace java com.hansonwang99.thrift.interface
service RPCDateService{
    string getDate(1:string userName)
}
複製代碼

在該接口文件中，咱們定義了一個 提供日期的Service，讓客戶端能經過該接口查詢到服務器當前的時間

• 第三步：編譯Thrift源文件生成Java接口類

右擊.thrift源文件，點擊 Recompile 'xxx.thrift' 便可完成 thrift接口文件 ---> java接口文件 的轉換

輸出的Java接口文件生成於上文中配置的 output 中，其 包結構=上文.thrift文件中的namespace ，其包結構以下圖所示，該Java接口十分重要，後續會用於實現Client和Server之間的RPC調用。

---

6、開發Thrift API接口

咱們建立一個Maven項目：ThriftAPI，其包含的的就是上文由自定義Thrift接口生成的Java接口：RPCDateService.java 文件，該文件將用於後面的RPC服務端和RPC客戶端的代碼實現！

• pom.xml中添加thrift依賴

<dependencies>
        <dependency>
            <groupId>org.apache.thrift</groupId>
            <artifactId>libthrift</artifactId>
            <version>0.11.0</version>
        </dependency>
    </dependencies>
複製代碼

• 添加RPCDateService.java

將上文 第五步 由 RPCDateService.thrift 生成的 RPCDateService.java 原樣拷貝到該Maven項目中便可，代碼結構以下：

再次強調，該 ThriftAPI項目 會服務於下文即將要建立的RPC服務端和RPC客戶端

---

7、開發RPC服務端

咱們是利用SpringBoot來實現RPC服務端

• pom.xml中添加依賴

這裏除了自動添加好的SpringBoot依賴外，須要額外添加的就是上文的 ThriftAPI依賴 了

<dependency>
        <groupId>com.hansonwang99</groupId>
        <artifactId>ThriftAPI</artifactId>
         <version>1.0-SNAPSHOT</version>
</dependency>
複製代碼

• 建立Controller並實現RPC接口

@Controller
public class RPCDateServiceImpl implements RPCDateService.Iface {
    @Override
    public String getDate(String userName) throws TException {
        Date now=new Date();
        SimpleDateFormat simpleDateFormat = new SimpleDateFormat("今天是"+"yyyy年MM月dd日 E kk點mm分");
        String nowTime = simpleDateFormat.format( now );
        return "Hello " + userName + "\n" + nowTime;
    }
}
複製代碼

這裏將服務器當前時間以字符串形式返回給調用端！

• 編寫RPCThriftServer：用於啓動RPC服務器

@Component
public class RPCThriftServer {
    protected final Logger logger = LoggerFactory.getLogger(this.getClass());
    @Value("${thrift.port}")
    private int port;
    @Value("${thrift.minWorkerThreads}")
    private int minThreads;
    @Value("${thrift.maxWorkerThreads}")
    private int maxThreads;

    private TBinaryProtocol.Factory protocolFactory;
    private TTransportFactory transportFactory;

    @Autowired
    private RPCDateServiceImpl rpcDateService;

    public void init() {
        protocolFactory = new TBinaryProtocol.Factory();
        transportFactory = new TTransportFactory();
    }

    public void start() {
        RPCDateService.Processor processor = new RPCDateService.Processor<RPCDateService.Iface>( rpcDateService );
        init();
        try {
            TServerTransport transport = new TServerSocket(port);
            TThreadPoolServer.Args tArgs = new TThreadPoolServer.Args(transport);
            tArgs.processor(processor);
            tArgs.protocolFactory(protocolFactory);
            tArgs.transportFactory(transportFactory);
            tArgs.minWorkerThreads(minThreads);
            tArgs.maxWorkerThreads(maxThreads);
            TServer server = new TThreadPoolServer(tArgs);
            logger.info("thrift服務啓動成功, 端口={}", port);
            server.serve();
        } catch (Exception e) {
            logger.error("thrift服務啓動失敗", e);
        }
    }
}
複製代碼

• 建立SpringBootApplication

@SpringBootApplication
public class RPCThriftServerApplication {
    private static RPCThriftServer rpcThriftServer;
    public static void main(String[] args) {
        ApplicationContext context = SpringApplication.run(RPCThriftServerApplication.class, args);
        try {
            rpcThriftServer = context.getBean(RPCThriftServer.class);
            rpcThriftServer.start();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}
複製代碼

• 添加配置文件application.properties

thrift.port=6666
thrift.minWorkerThreads=10
thrift.maxWorkerThreads=100
複製代碼

咱們讓thrift服務起在6666端口！

• 啓動RPC服務端服務

---

8、開發RPC客戶端

這裏一樣用SpringBoot來實現RPC客戶端！

• pom.xml中添加依賴

  此處同RPC服務端依賴，不贅述

• 編寫RPCThriftClient：用於發出RPC調用

這裏包含兩個文件：RPCThriftClient.java 和 RPCThriftClientConfig.java

RPCThriftClient.java以下：

public class RPCThriftClient {
    private RPCDateService.Client client;
    private TBinaryProtocol protocol;
    private TSocket transport;
    private String host;
    private int port;

    public String getHost() {
        return host;
    }
    public void setHost(String host) {
        this.host = host;
    }
    public int getPort() {
        return port;
    }
    public void setPort(int port) {
        this.port = port;
    }

    public void init() {
        transport = new TSocket(host, port);
        protocol = new TBinaryProtocol(transport);
        client = new RPCDateService.Client(protocol);
    }

    public RPCDateService.Client getRPCThriftService() {
        return client;
    }

    public void open() throws TTransportException {
        transport.open();
    }

    public void close() {
        transport.close();
    }
}
複製代碼

而RPCThriftClientConfig.java是利用config生成bean

@Configuration
public class RPCThriftClientConfig {
    @Value("${thrift.host}")
    private String host;
    @Value("${thrift.port}")
    private int port;

    @Bean(initMethod = "init")
    public RPCThriftClient rpcThriftClient() {
        RPCThriftClient rpcThriftClient = new RPCThriftClient();
        rpcThriftClient.setHost(host);
        rpcThriftClient.setPort(port);
        return rpcThriftClient;
    }
}
複製代碼

• 編寫Restful的Controller做爲調用入口

@RestController
@RequestMapping("/hansonwang99")
public class RPCThriftContoller {
    protected final Logger logger = LoggerFactory.getLogger(this.getClass());
    @Autowired
    private RPCThriftClient rpcThriftClient;

    @RequestMapping(value = "/thrift", method = RequestMethod.GET)
    public String thriftTest(HttpServletRequest request, HttpServletResponse response) {
        try {
            rpcThriftClient.open();
            return rpcThriftClient.getRPCThriftService().getDate("hansonwang99");
        } catch (Exception e) {
            logger.error("RPC調用失敗", e);
            return "error";
        } finally {
            rpcThriftClient.close();
        }
    }
}
複製代碼

• 建立SpringBootApplication

@SpringBootApplication
public class RPCThriftClientApplication {
    public static void main(String[] args) {
        SpringApplication.run(RPCThriftClientApplication.class, args);
    }
}
複製代碼

• 添加配置文件application.properties

thrift.host=localhost
thrift.port=6666
server.port=9999
複製代碼

• 啓動RPC客戶端服務

---

9、RPC通訊實驗

咱們瀏覽器輸入：localhost:9999/hansonwang99/thrift 便可查看客戶端從服務端取回的服務器當前時間，說明RPC通訊過程打通！

---

10、後記

本文實驗代碼已開源，點擊獲取

• 做者更多的原創文章在此，歡迎觀賞

• My Personal Blog

做者更多的SpringBt實踐文章在此：

• Spring Boot應用監控實戰
• SpringBoot應用部署於外置Tomcat容器
• ElasticSearch搜索引擎在SpringBt中的實踐
• 初探Kotlin+SpringBoot聯合編程
• Spring Boot日誌框架實踐
• SpringBoot優雅編碼之：Lombok加持

---

若是有興趣，也能夠抽點時間看看做者一些關於容器化、微服務化方面的文章：

• 利用K8S技術棧打造我的私有云 連載文章
• 從一份配置清單詳解Nginx服務器配置
• Docker容器可視化監控中心搭建
• 利用ELK搭建Docker容器化應用日誌中心
• RPC框架實踐之：Apache Thrift
• RPC框架實踐之：Google gRPC
• 微服務調用鏈追蹤中心搭建
• Docker容器跨主機通訊
• Docker Swarm集羣初探
• 高效編寫Dockerfile的幾條準則

---