Spring Boot 中的 RestTemplate不好用?試試 Retrofit !
點擊上方藍色“小哈學Java”,選擇“設(shè)為星標”
回復“資源”獲取獨家整理的學習資料!


大家都知道okhttp是一款由square公司開源的java版本http客戶端工具。實際上,square公司還開源了基于okhttp進一步封裝的retrofit工具,用來支持通過接口的方式發(fā)起http請求。
如果你的項目中還在直接使用RestTemplate或者okhttp,或者基于它們封裝的HttpUtils,那么你可以嘗試使用Retrofit。
retrofit-spring-boot-starter實現(xiàn)了Retrofit與spring-boot框架快速整合,并且支持了部分功能增強,從而極大的簡化spring-boot項目下http接口調(diào)用開發(fā)。接下來我們直接通過retrofit-spring-boot-starter,來看看spring-boot項目發(fā)送http請求有多簡單。
retrofit官方并沒有提供與spring-boot快速整合的starter。retrofit-spring-boot-starter是筆者封裝的,已在生產(chǎn)環(huán)境使用,非常穩(wěn)定。喜歡的話給個star。
https://github.com/LianjiaTech/retrofit-spring-boot-starter
引入依賴
<dependency>
????<groupId>com.github.lianjiatechgroupId>
????<artifactId>retrofit-spring-boot-starterartifactId>
????<version>2.0.2version>
dependency>
配置@RetrofitScan注解
你可以給帶有 @Configuration 的類配置@RetrofitScan,或者直接配置到spring-boot的啟動類上,如下:
@SpringBootApplication
@RetrofitScan("com.github.lianjiatech.retrofit.spring.boot.test")
public?class?RetrofitTestApplication?{
????public?static?void?main(String[]?args)?{
????????SpringApplication.run(RetrofitTestApplication.class,?args);
????}
}
定義http接口
接口必須使用@RetrofitClient注解標記!推薦:一百期面試題匯總
http相關(guān)注解可參考官方文檔:
https://square.github.io/retrofit/
@RetrofitClient(baseUrl?=?"${test.baseUrl}")
public?interface?HttpApi?{
????@GET("person")
????Result?getPerson(@Query("id")?Long?id) ;
}
注入使用
將接口注入到其它Service中即可使用。
@Service
public?class?TestService?{
????@Autowired
????private?HttpApi?httpApi;
????public?void?test()?{
????????//?通過httpApi發(fā)起http請求
????}
}
只要通過上述幾個步驟,就能實現(xiàn)通過接口發(fā)送http請求了,真的很簡單。如果你在spring-boot項目里面使用過mybatis,相信你對這種使用方式會更加熟悉。
接下來我們繼續(xù)介紹一下retrofit-spring-boot-starter更高級一點的功能。
注解式攔截器
很多時候,我們希望某個接口下的某些http請求執(zhí)行統(tǒng)一的攔截處理邏輯。這個時候可以使用注解式攔截器。使用的步驟主要分為2步:
繼承BasePathMatchInterceptor編寫攔截處理器; 接口上使用@Intercept進行標注。
下面以給指定請求的url后面拼接timestamp時間戳為例,介紹下如何使用注解式攔截器。
繼承BasePathMatchInterceptor編寫攔截處理器
@Component
public?class?TimeStampInterceptor?extends?BasePathMatchInterceptor?{
????@Override
????public?Response?doIntercept(Chain?chain)?throws?IOException?{
????????Request?request?=?chain.request();
????????HttpUrl?url?=?request.url();
????????long?timestamp?=?System.currentTimeMillis();
????????HttpUrl?newUrl?=?url.newBuilder()
????????????????.addQueryParameter("timestamp",?String.valueOf(timestamp))
????????????????.build();
????????Request?newRequest?=?request.newBuilder()
????????????????.url(newUrl)
????????????????.build();
????????return?chain.proceed(newRequest);
????}
}
接口上使用@Intercept進行標注
@RetrofitClient(baseUrl?=?"${test.baseUrl}")
@Intercept(handler?=?TimeStampInterceptor.class,?include?=?{"/api/**"},?exclude?=?"/api/test/savePerson")
public?interface?HttpApi?{
????@GET("person")
????Result?getPerson(@Query("id")?Long?id) ;
????@POST("savePerson")
????Result?savePerson(@Body?Person?person) ;
}
上面的@Intercept配置表示:攔截HttpApi接口下/api/**路徑下(排除/api/test/savePerson)的請求,攔截處理器使用TimeStampInterceptor。推薦:一百期面試題匯總
擴展注解式攔截器
有的時候,我們需要在攔截注解動態(tài)傳入一些參數(shù),然后再執(zhí)行攔截的時候需要使用這個參數(shù)。這種時候,我們可以擴展實現(xiàn)自定義攔截注解。
自定義攔截注解必須使用@InterceptMark標記,并且注解中必須包括include()、exclude()、handler()屬性信息。使用的步驟主要分為3步:
自定義攔截注解 繼承BasePathMatchInterceptor編寫攔截處理器 接口上使用自定義攔截注解;
例如我們需要在請求頭里面動態(tài)加入accessKeyId、accessKeySecret簽名信息才能正常發(fā)起http請求,這個時候可以自定義一個加簽攔截器注解@Sign來實現(xiàn)。下面以自定義@Sign攔截注解為例進行說明。
自定義@Sign注解
@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.TYPE)
@Documented
@InterceptMark
public?@interface?Sign?{
????/**
?????*?密鑰key
?????*?支持占位符形式配置。
?????*
?????*?@return
?????*/
????String?accessKeyId();
????/**
?????*?密鑰
?????*?支持占位符形式配置。
?????*
?????*?@return
?????*/
????String?accessKeySecret();
????/**
?????*?攔截器匹配路徑
?????*
?????*?@return
?????*/
????String[]?include()?default?{"/**"};
????/**
?????*?攔截器排除匹配,排除指定路徑攔截
?????*
?????*?@return
?????*/
????String[]?exclude()?default?{};
????/**
?????*?處理該注解的攔截器類
?????*?優(yōu)先從spring容器獲取對應的Bean,如果獲取不到,則使用反射創(chuàng)建一個!
?????*
?????*?@return
?????*/
????Class?extends?BasePathMatchInterceptor>?handler()?default?SignInterceptor.class;
}
擴展自定義攔截注解有以下2點需要注意:
自定義攔截注解必須使用@InterceptMark標記。 注解中必須包括include()、exclude()、handler()屬性信息。
實現(xiàn)SignInterceptor
@Component
public?class?SignInterceptor?extends?BasePathMatchInterceptor?{
????private?String?accessKeyId;
????private?String?accessKeySecret;
????public?void?setAccessKeyId(String?accessKeyId)?{
????????this.accessKeyId?=?accessKeyId;
????}
????public?void?setAccessKeySecret(String?accessKeySecret)?{
????????this.accessKeySecret?=?accessKeySecret;
????}
????@Override
????public?Response?doIntercept(Chain?chain)?throws?IOException?{
????????Request?request?=?chain.request();
????????Request?newReq?=?request.newBuilder()
????????????????.addHeader("accessKeyId",?accessKeyId)
????????????????.addHeader("accessKeySecret",?accessKeySecret)
????????????????.build();
????????return?chain.proceed(newReq);
????}
}
上述accessKeyId和accessKeySecret字段值會依據(jù)@Sign注解的accessKeyId()和accessKeySecret()值自動注入,如果@Sign指定的是占位符形式的字符串,則會取配置屬性值進行注入。
另外,accessKeyId和accessKeySecret字段必須提供setter方法。Java知音公眾號內(nèi)回復“后端面試”,送你一份Java面試題寶典
接口上使用@Sign
@RetrofitClient(baseUrl?=?"${test.baseUrl}")
@Sign(accessKeyId?=?"${test.accessKeyId}",?accessKeySecret?=?"${test.accessKeySecret}",?exclude?=?{"/api/test/person"})
public?interface?HttpApi?{
????@GET("person")
????Result?getPerson(@Query("id")?Long?id) ;
????@POST("savePerson")
????Result?savePerson(@Body?Person?person) ;
}
這樣就能在指定url的請求上,自動加上簽名信息了。
連接池管理
默認情況下,所有通過Retrofit發(fā)送的http請求都會使用max-idle-connections=5 keep-alive-second=300的默認連接池。
當然,我們也可以在配置文件中配置多個自定義的連接池,然后通過@RetrofitClient的poolName屬性來指定使用。比如我們要讓某個接口下的請求全部使用poolName=test1的連接池,代碼實現(xiàn)如下:
1.配置連接池。
retrofit:
????#?連接池配置
????pool:
????????test1:
????????max-idle-connections:?3
????????keep-alive-second:?100
????????test2:
????????max-idle-connections:?5
????????keep-alive-second:?50
2.通過@RetrofitClient的poolName屬性來指定使用的連接池。
@RetrofitClient(baseUrl?=?"${test.baseUrl}",?poolName="test1")
public?interface?HttpApi?{
????@GET("person")
????Result?getPerson(@Query("id")?Long?id) ;
}
日志打印
很多情況下,我們希望將http請求日志記錄下來。通過@RetrofitClient的logLevel和logStrategy屬性,您可以指定每個接口的日志打印級別以及日志打印策略。
retrofit-spring-boot-starter支持了5種日志打印級別(ERROR, WARN, INFO, DEBUG, TRACE),默認INFO;支持了4種日志打印策略(NONE, BASIC, HEADERS, BODY),默認BASIC。
4種日志打印策略含義如下:
NONE:No logs. BASIC:Logs request and response lines. HEADERS:Logs request and response lines and their respective headers. BODY:Logs request and response lines and their respective headers and bodies (if present).
retrofit-spring-boot-starter默認使用了DefaultLoggingInterceptor執(zhí)行真正的日志打印功能,其底層就是okhttp原生的HttpLoggingInterceptor。
當然,你也可以自定義實現(xiàn)自己的日志打印攔截器,只需要繼承BaseLoggingInterceptor(具體可以參考DefaultLoggingInterceptor的實現(xiàn)),然后在配置文件中進行相關(guān)配置即可。
retrofit:
??#?日志打印攔截器
??logging-interceptor:?com.github.lianjiatech.retrofit.spring.boot.interceptor.DefaultLoggingInterceptor
Http異常信息格式化器
當出現(xiàn)http請求異常時,原始的異常信息可能閱讀起來并不友好,因此retrofit-spring-boot-starter提供了Http異常信息格式化器,用來美化輸出http請求參數(shù),默認使用DefaultHttpExceptionMessageFormatter進行請求數(shù)據(jù)格式化。Java知音公眾號內(nèi)回復“后端面試”,送你一份Java面試題寶典
你也可以進行自定義,只需要繼承BaseHttpExceptionMessageFormatter,再進行相關(guān)配置即可。
retrofit:
??#?Http異常信息格式化器
??http-exception-message-formatter:?com.github.lianjiatech.retrofit.spring.boot.interceptor.DefaultHttpExceptionMessageFormatter
調(diào)用適配器 CallAdapter
Retrofit可以通過調(diào)用適配器CallAdapterFactory將Call對象適配成接口方法的返回值類型。retrofit-spring-boot-starter擴展2種CallAdapterFactory實現(xiàn):
BodyCallAdapterFactory
默認啟用,可通過配置retrofit.enable-body-call-adapter=false關(guān)閉 同步執(zhí)行http請求,將響應體內(nèi)容適配成接口方法的返回值類型實例。 除了 Retrofit.Call、Retrofit.Response、java.util.concurrent.CompletableFuture之外,其它返回類型都可以使用該適配器。
ResponseCallAdapterFactory
默認啟用,可通過配置 retrofit.enable-response-call-adapter=false關(guān)閉同步執(zhí)行http請求,將響應體內(nèi)容適配成 Retrofit.Response返回。如果方法的返回值類型為 Retrofit.Response,則可以使用該適配器。
Retrofit自動根據(jù)方法返回值類型選用對應的CallAdapterFactory執(zhí)行適配處理!加上Retrofit默認的CallAdapterFactory,可支持多種形式的方法返回值類型:
Call: 不執(zhí)行適配處理,直接返回Call對象CompletableFuture: 將響應體內(nèi)容適配成CompletableFuture對象返回Void: 不關(guān)注返回類型可以使用Void。如果http狀態(tài)碼不是2xx,直接拋錯! Response: 將響應內(nèi)容適配成Response對象返回其他任意Java類型:將響應體內(nèi)容適配成一個對應的Java類型對象返回,如果http狀態(tài)碼不是2xx,直接拋錯!
????/**
?????*?Call
?????*?不執(zhí)行適配處理,直接返回Call對象
?????*?@param?id
?????*?@return
?????*/
????@GET("person")
????Call>?getPersonCall(@Query("id")?Long?id);
????/**
?????*??CompletableFuture
?????*??將響應體內(nèi)容適配成CompletableFuture對象返回
?????*?@param?id
?????*?@return
?????*/
????@GET("person")
????CompletableFuture>?getPersonCompletableFuture(@Query("id")?Long?id);
????/**
?????*?Void
?????*?不關(guān)注返回類型可以使用Void。如果http狀態(tài)碼不是2xx,直接拋錯!
?????*?@param?id
?????*?@return
?????*/
????@GET("person")
????Void?getPersonVoid(@Query("id")?Long?id);
????/**
?????*??Response
?????*??將響應內(nèi)容適配成Response對象返回
?????*?@param?id
?????*?@return
?????*/
????@GET("person")
????Response>?getPersonResponse(@Query("id")?Long?id);
????/**
?????*?其他任意Java類型
?????*?將響應體內(nèi)容適配成一個對應的Java類型對象返回,如果http狀態(tài)碼不是2xx,直接拋錯!
?????*?@param?id
?????*?@return
?????*/
????@GET("person")
????Result?getPerson(@Query("id")?Long?id) ;
我們也可以通過繼承CallAdapter.Factory擴展實現(xiàn)自己的CallAdapter;然后將自定義的CallAdapterFactory配置成spring的bean!
自定義配置的CallAdapter.Factory優(yōu)先級更高!
數(shù)據(jù)轉(zhuǎn)碼器 Converter
Retrofi使用Converter將@Body注解標注的對象轉(zhuǎn)換成請求體,將響應體數(shù)據(jù)轉(zhuǎn)換成一個Java對象,可以選用以下幾種Converter:
Gson: com.squareup.Retrofit:converter-gson Jackson: com.squareup.Retrofit:converter-jackson Moshi: com.squareup.Retrofit:converter-moshi Protobuf: com.squareup.Retrofit:converter-protobuf Wire: com.squareup.Retrofit:converter-wire Simple XML: com.squareup.Retrofit:converter-simplexml
retrofit-spring-boot-starter默認使用的是jackson進行序列化轉(zhuǎn)換!如果需要使用其它序列化方式,在項目中引入對應的依賴,再把對應的ConverterFactory配置成spring的bean即可。
我們也可以通過繼承Converter.Factory擴展實現(xiàn)自己的Converter;然后將自定義的Converter.Factory配置成spring的bean!
自定義配置的Converter.Factory優(yōu)先級更高!
全局攔截器 BaseGlobalInterceptor
如果我們需要對整個系統(tǒng)的的http請求執(zhí)行統(tǒng)一的攔截處理,可以自定義實現(xiàn)全局攔截器BaseGlobalInterceptor, 并配置成spring中的bean!例如我們需要在整個系統(tǒng)發(fā)起的http請求,都帶上來源信息。
@Component
public?class?SourceInterceptor?extends?BaseGlobalInterceptor?{
????@Override
????public?Response?doIntercept(Chain?chain)?throws?IOException?{
????????Request?request?=?chain.request();
????????Request?newReq?=?request.newBuilder()
????????????????.addHeader("source",?"test")
????????????????.build();
????????return?chain.proceed(newReq);
????}
}
結(jié)語
至此,spring-boot項目下最優(yōu)雅的http客戶端工具介紹就結(jié)束了,更多詳細信息可以參考官方文檔:retrofit以及retrofit-spring-boot-starter。
https://github.com/LianjiaTech/retrofit-spring-boot-starter
END
有熱門推薦?
最近面試BAT,整理一份面試資料《Java面試BATJ通關(guān)手冊》,覆蓋了Java核心技術(shù)、JVM、Java并發(fā)、SSM、微服務、數(shù)據(jù)庫、數(shù)據(jù)結(jié)構(gòu)等等。
獲取方式:點“在看”,關(guān)注公眾號并回復?Java?領(lǐng)取,更多內(nèi)容陸續(xù)奉上。
文章有幫助的話,在看,轉(zhuǎn)發(fā)吧。
謝謝支持喲 (*^__^*)

