摘要：在文章微服務(wù)調(diào)用鏈追蹤中心搭建一文中模擬出來的調(diào)用鏈就是一個遠(yuǎn)程調(diào)用的例子，只不過這篇文章里是通過這種同步調(diào)用方式，利用的是協(xié)議在應(yīng)用層完成的，這種方法雖然奏效，但有時效率并不高。

RPC（Remote Procedure Call）即 遠(yuǎn)程過程調(diào)用，說的這么抽象，其實簡化理解就是一個節(jié)點如何請求另一節(jié)點所提供的服務(wù)。在文章 微服務(wù)調(diào)用鏈追蹤中心搭建 一文中模擬出來的調(diào)用鏈：ServiceA ---> ServiceB ---> ServiceC 就是一個遠(yuǎn)程調(diào)用的例子，只不過這篇文章里是通過RestTemplate這種 同步調(diào)用方式，利用的是HTTP協(xié)議在應(yīng)用層完成的，這種方法雖然奏效，但有時效率并不高。而RPC可以不依賴于應(yīng)用層協(xié)議，可以直接基于TCP進(jìn)行遠(yuǎn)程調(diào)用，在傳輸層中即可完成通信，因此更適于某些對效率要求更高的場景。由于RPC調(diào)用方式依賴于客戶端與服務(wù)端之間建立Socket連接來實現(xiàn)二進(jìn)制數(shù)據(jù)通信，底層會比較復(fù)雜，所以一些RPC框架應(yīng)運(yùn)而生來封裝這種復(fù)雜性，讓開發(fā)者將精力聚焦于業(yè)務(wù)之上。常見的RPC框架包括：Thrift、gRPC、Finagle、Dubbo等等，從本文開始作者將選一些實踐一下，本文主要記錄作者對于Thrift框架的實踐過程。

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

心動不如行動吧！

注： 本文首發(fā)于 My 公眾號 CodeSheep ，可 長按 或 掃描 下面的 小心心 來訂閱 ↓ ↓ ↓

Mac OS X 10.13.2

SpringBoot 2.0.1

Thrift 0.11.0

IDE：IntelliJ IDEA 2018.01

為了便于讀者理解，我先將下文內(nèi)容總結(jié)一下，包含7點：

Thrift環(huán)境搭建
IDEA中Thrift插件配置
創(chuàng)建 Thrift 項目并編譯（目的：定義RPC接口）
開發(fā)Thrift API接口
開發(fā)RPC服務(wù)端
開發(fā)RPC客戶端
RPC通信實際實驗

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

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

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

brew install thrift

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

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

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

就像文章 SpringBoot優(yōu)雅編碼之：Lombok加持 一文中在IDEA中安裝Lombok插件一樣，有時由于網(wǎng)絡(luò)原因，方法一不奏效時插件裝不上，此時可以手動下載插件并安裝。

可以去如下地址下載Thrift插件：http://plugins.jetbrains.com/...

然后去IDEA中 Install plugin from disk... 選擇下載的zip包安裝，然后重啟IDE即可

安裝完成的成功標(biāo)志是 Compiler 中出現(xiàn)了 Thrift編譯器！如下圖所示：

第一步：創(chuàng)建Thrift項目并配置

IDE 很智能地在 New Project 時提供 Thrift項目創(chuàng)建選項：

項目創(chuàng)建完成以后，在 Project Settings 中設(shè)置好 Facets 的 Thrift配置，如下圖所示，這里我們添加一個 Java的Generator

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

OK，Thrift項目就緒了！

第二步：創(chuàng)建thrift接口文件

這里創(chuàng)建一個thrift接口文件：RPCDateService.thrift

thrift文件的寫法我不贅述，跟gRPC一樣有其自己的語法，namespace是最后生成的接口文件的包名

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

在該接口文件中，我們定義了一個 提供日期的Service，讓客戶端能通過該接口查詢到服務(wù)器當(dāng)前的時間

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

右擊.thrift源文件，點擊 Recompile "xxx.thrift" 即可完成 thrift接口文件 ---> java接口文件 的轉(zhuǎn)換

輸出的Java接口文件生成于上文中配置的 output 中，其 包結(jié)構(gòu)=上文.thrift文件中的namespace ，其包結(jié)構(gòu)如下圖所示，該Java接口十分重要，后續(xù)會用于實現(xiàn)Client和Server之間的RPC調(diào)用。

我們創(chuàng)建一個Maven項目：ThriftAPI，其包含的的就是上文由自定義Thrift接口生成的Java接口：RPCDateService.java 文件，該文件將用于后面的RPC服務(wù)端和RPC客戶端的代碼實現(xiàn)！

pom.xml中添加thrift依賴

    
        
            org.apache.thrift
            libthrift
            0.11.0
        
    

添加RPCDateService.java

將上文 第五步 由 RPCDateService.thrift 生成的 RPCDateService.java 原樣拷貝到該Maven項目中即可，代碼結(jié)構(gòu)如下：

再次強(qiáng)調(diào)，該 ThriftAPI項目 會服務(wù)于下文即將要創(chuàng)建的RPC服務(wù)端和RPC客戶端

我們是利用SpringBoot來實現(xiàn)RPC服務(wù)端

pom.xml中添加依賴

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

        com.hansonwang99
        ThriftAPI
         1.0-SNAPSHOT

創(chuàng)建Controller并實現(xiàn)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 + "
" + nowTime;
    }
}

這里將服務(wù)器當(dāng)前時間以字符串形式返回給調(diào)用端！

編寫RPCThriftServer：用于啟動RPC服務(wù)器

@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 );
        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服務(wù)啟動成功, 端口={}", port);
            server.serve();
        } catch (Exception e) {
            logger.error("thrift服務(wù)啟動失敗", e);
        }
    }
}

創(chuàng)建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服務(wù)起在6666端口！

啟動RPC服務(wù)端服務(wù)

這里同樣用SpringBoot來實現(xiàn)RPC客戶端！

pom.xml中添加依賴

此處同RPC服務(wù)端依賴，不贅述

編寫RPCThriftClient：用于發(fā)出RPC調(diào)用

這里包含兩個文件：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作為調(diào)用入口

@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調(diào)用失敗", e);
            return "error";
        } finally {
            rpcThriftClient.close();
        }
    }
}

創(chuàng)建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客戶端服務(wù)

我們?yōu)g覽器輸入：localhost:9999/hansonwang99/thrift 即可查看客戶端從服務(wù)端取回的服務(wù)器當(dāng)前時間，說明RPC通信過程打通！

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

作者更多的原創(chuàng)文章在此，歡迎觀賞

My Personal Blog

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

Spring Boot應(yīng)用監(jiān)控實戰(zhàn)

SpringBoot應(yīng)用部署于外置Tomcat容器

ElasticSearch搜索引擎在SpringBt中的實踐

初探Kotlin+SpringBoot聯(lián)合編程

Spring Boot日志框架實踐

SpringBoot優(yōu)雅編碼之：Lombok加持

如果有興趣，也可以抽點時間看看作者一些關(guān)于容器化、微服務(wù)化方面的文章：

利用K8S技術(shù)棧打造個人私有云 連載文章

從一份配置清單詳解Nginx服務(wù)器配置

Docker容器可視化監(jiān)控中心搭建

利用ELK搭建Docker容器化應(yīng)用日志中心

RPC框架實踐之：Apache Thrift

RPC框架實踐之：Google gRPC

微服務(wù)調(diào)用鏈追蹤中心搭建

Docker容器跨主機(jī)通信

Docker Swarm集群初探

高效編寫Dockerfile的幾條準(zhǔn)則