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

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

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

心動(dòng)不如行動(dòng)吧！

注： 本文首發(fā)于 My 公眾號(hào) CodeSheep ，可 長(zhǎng)按 或 掃描 下面的 小心心 來(lái)訂閱 ↓ ↓ ↓

Mac OS X 10.13.2

SpringBoot 2.0.1

Thrift 0.11.0

IDE：IntelliJ IDEA 2018.01

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

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

方法一：原生安裝方式，通過(guò)官方提供的步驟一步一步來(lái)安裝

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

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

brew install thrift

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

打開(kāi)IDEA的插件中心，搜索 Thrift 即可安裝

方法二：手動(dòng)下載Thrift插件安裝

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

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

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

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

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

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

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

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

OK，Thrift項(xiàng)目就緒了！

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

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

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

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

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

第三步：編譯Thrift源文件生成Java接口類(lèi)

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

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

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

pom.xml中添加thrift依賴(lài)

    
        
            org.apache.thrift
            libthrift
            0.11.0
        
    

添加RPCDateService.java

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

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

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

pom.xml中添加依賴(lài)

這里除了自動(dòng)添加好的SpringBoot依賴(lài)外，需要額外添加的就是上文的 ThriftAPI依賴(lài) 了

        com.hansonwang99
        ThriftAPI
         1.0-SNAPSHOT

創(chuàng)建Controller并實(shí)現(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點(diǎn)mm分");
        String nowTime = simpleDateFormat.format( now );
        return "Hello " + userName + "
" + nowTime;
    }
}

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

編寫(xiě)RPCThriftServer：用于啟動(dòng)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ù)啟動(dòng)成功, 端口={}", port);
            server.serve();
        } catch (Exception e) {
            logger.error("thrift服務(wù)啟動(dòng)失敗", 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端口！

啟動(dòng)RPC服務(wù)端服務(wù)

這里同樣用SpringBoot來(lái)實(shí)現(xiàn)RPC客戶(hù)端！

pom.xml中添加依賴(lài)

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

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

這里包含兩個(gè)文件：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;
    }
}

編寫(xiě)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

啟動(dòng)RPC客戶(hù)端服務(wù)

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

本文實(shí)驗(yàn)代碼已開(kāi)源，點(diǎn)擊獲取

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

My Personal Blog

作者更多的SpringBt實(shí)踐文章在此：

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

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

ElasticSearch搜索引擎在SpringBt中的實(shí)踐

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

Spring Boot日志框架實(shí)踐

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

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

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

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

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

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

RPC框架實(shí)踐之：Apache Thrift

RPC框架實(shí)踐之：Google gRPC

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

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

Docker Swarm集群初探

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