我的桌面

一吞歼、概述

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

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

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

注： 本文原載于 My Personal Blog：口糕， CodeSheep · 程序羊 缅阳！

二、實(shí)驗(yàn)環(huán)境

• 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接口）
• 開發(fā)Thrift API接口
• 開發(fā)RPC服務(wù)端
• 開發(fā)RPC客戶端
• RPC通信實(shí)際實(shí)驗(yàn)

三、Thrift環(huán)境搭建

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

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

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

brew install thrift

brew install thrift

四向族、IDEA中Thrift插件配置

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

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

利用插件中心安裝Thrift

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

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

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

手動(dòng)下載Thrift插件

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

Install plugin from disk

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

成功安裝Thrift插件

五候引、創(chuàng)建 Thrift 項(xiàng)目并編譯（定義RPC接口）

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

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

Thrift項(xiàng)目創(chuàng)建選項(xiàng)

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

添加一個(gè)Java的Generator

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

配置好Output folder

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

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

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

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

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

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

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

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

Recompile 'xxx.thrift'

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

輸出的.java文件

六、開發(fā)Thrift API接口

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

• 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項(xiàng)目中即可，代碼結(jié)構(gòu)如下：

ThriftAPI代碼結(jié)構(gòu)

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

七履婉、開發(fā)RPC服務(wù)端

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

• pom.xml中添加依賴

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

<dependency>
        <groupId>com.hansonwang99</groupId>
        <artifactId>ThriftAPI</artifactId>
         <version>1.0-SNAPSHOT</version>
</dependency>

• 創(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 + "\n" + nowTime;
    }
}

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

• 編寫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.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服務(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ù)

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

八辑奈、開發(fā)RPC客戶端

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

• pom.xml中添加依賴

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

• 編寫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;
    }
}

• 編寫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客戶端服務(wù)

RPC客戶端啟動(dòng)成功

九鸠窗、RPC通信實(shí)驗(yàn)

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

客戶端成功從服務(wù)端取回結(jié)果

十稍计、后記

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

由于能力有限，若有錯(cuò)誤或者不當(dāng)之處臣嚣，還請大家批評指正净刮，一起學(xué)習(xí)交流！

• My Personal Blog
• 我的半年技術(shù)博客之路