對于曾經使用過thrift來開發RPC服務的同學來講，經常碰到就是client去連server端的時候，程序首先要聲明連接協議，我們以socket為例。然后開始連接到服務端，調用遠端的方法，關閉連接。

代碼片斷如下：

伴隨著服務越來越多，如果我們的代碼中充斥這些duplicate code，心里總是癢癢的，非得把它干掉。聯想到當初最開始寫 jdbc常用的crud方法那段時間，代碼里面也是挺多的open,close種種。其實想想，如果能有連接池，這個問題也就好解決了。于是，首先在github上找找，有沒有現成的實現。果然，有一位前輩已經實現了。于是果斷下載，地址是https://github.com/PhantomThief/thrift-pool-client。

下面是這個客戶端所實現的功能，感覺還是相當不錯的。

A Thrift Client pool for Java

raw and type safe TServiceClient pool

Multi backend servers support

Backend servers replace on the fly

Backend route by hash or random

Failover and failback support

jdk 1.8 only

不過，看了md之后，發現only support jdk8。心里涼了半截，難道老外都在用jdk8了？于是花了半天時 間，熟讀了新的語法之后，準備改造前輩的代碼。通讀代碼之后，發現里面有好幾個類使用lambda語法,flatmap,collection,filter.另外就是函數是編程function.最后還有Supplier。好在guava已經實現了后兩者，我只需要改改lambda的語法。

核心類說明：

ThriftClientImpl：它是客戶端的實現類，主要是業務方經常用到的iface方法，先看圖：

里面有兩段代碼需要改動。第一個就是設置執行的方法過濾，第二個是代理方法里面調用，實際就是業務方真正調用的方法塊。關鍵點是javassist它是一種字節碼處理技術，可以動態改變方法塊。本段代碼其實類似一個代理工廠，它代理了所有業務服務的執行片斷

DefaultThriftConnectionPoolImpl，ThriftConnectionFactory：thrift連接池實現，基本是apache pool的通用連接池處理。

其中sokcet.open對應著makeobject.socket.close對應著destroyobject

ThriftClientUtils:這個類有一個獲取接口中所有方法的名稱集合的方法，把lambda的語法改成熟悉的方式。

其它類也是做了相關調整，這里就不一一說明了。最后講一下調用。

1連接池初始化

2 構建單例的rpc服務，因為rpc服務可能在多臺機器上，所以會有分片

3 協議的聲明

4 調用

5結果，因為我有一個簡單的計算服務，已經發布在測試機器了，這里就是1+99的結果。

主體寫完了，改天會把github的地址貼上來，請隨時關注。