您好,登錄后才能下訂單哦!
這篇文章給大家分享的是有關(guān)Java中Feign怎么用的內(nèi)容。小編覺得挺實(shí)用的,因此分享給大家做個(gè)參考,一起跟隨小編過來看看吧。
一,簡(jiǎn)介
Feign使得 Java HTTP 客戶端編寫更方便。Feign 靈感來源于Retrofit、JAXRS-2.0和WebSocket。Feign最初是為了降低統(tǒng)一綁定Denominator到HTTP API的復(fù)雜度,不區(qū)分是否支持Restful。Feign旨在通過最少的資源和代碼來實(shí)現(xiàn)和HTTP API的連接。通過可定制的解碼器和錯(cuò)誤處理,可以編寫任意的HTTP API。
Maven依賴:
<!-- https://mvnrepository.com/artifact/com.netflix.feign/feign-core --> <dependency> <groupId>com.netflix.feign</groupId> <artifactId>feign-core</artifactId> <version>8.18.0</version> <scope>runtime</scope> </dependency>
二,為什么選擇Feign而不是其他
你可以使用 Jersey 和 CXF 這些來寫一個(gè) Rest 或 SOAP 服務(wù)的java客服端。你也可以直接使用 Apache HttpClient 來實(shí)現(xiàn)。但是 Feign 的目的是盡量的減少資源和代碼來實(shí)現(xiàn)和 HTTP API 的連接。通過自定義的編碼解碼器以及錯(cuò)誤處理,你可以編寫任何基于文本的 HTTP API。
Feign工作機(jī)制
Feign通過注解注入一個(gè)模板化請(qǐng)求進(jìn)行工作。只需在發(fā)送之前關(guān)閉它,參數(shù)就可以被直接的運(yùn)用到模板中。然而這也限制了Feign,只支持文本形式的API,它在響應(yīng)請(qǐng)求等方面極大的簡(jiǎn)化了系統(tǒng)。同時(shí),它也是十分容易進(jìn)行單元測(cè)試的。
三,Feign使用簡(jiǎn)介
3.1,基本用法
基本的使用如下所示,一個(gè)對(duì)于canonical Retrofit sample的適配。
interface GitHub { // RequestLine注解聲明請(qǐng)求方法和請(qǐng)求地址,可以允許有查詢參數(shù) @RequestLine("GET /repos/{owner}/{repo}/contributors") List<Contributor> contributors(@Param("owner") String owner, @Param("repo") String repo); } static class Contributor { String login; int contributions; } public static void main(String... args) { GitHub github = Feign.builder() .decoder(new GsonDecoder()) .target(GitHub.class, "https://api.github.com"); // Fetch and print a list of the contributors to this library. List<Contributor> contributors = github.contributors("OpenFeign", "feign"); for (Contributor contributor : contributors) { System.out.println(contributor.login + " (" + contributor.contributions + ")"); } }
3.2,自定義
Feign 有許多可以自定義的方面。舉個(gè)簡(jiǎn)單的例子,你可以使用 Feign.builder() 來構(gòu)造一個(gè)擁有你自己組件的API接口。如下:
interface Bank { @RequestLine("POST /account/{id}") Account getAccountInfo(@Param("id") String id); } ... // AccountDecoder() 是自己實(shí)現(xiàn)的一個(gè)Decoder Bank bank = Feign.builder().decoder(new AccountDecoder()).target(Bank.class, https://api.examplebank.com);
3.3,多種接口
Feign可以提供多種API接口,這些接口都被定義為 Target<T> (默認(rèn)的實(shí)現(xiàn)是 HardCodedTarget<T>), 它允許在執(zhí)行請(qǐng)求前動(dòng)態(tài)發(fā)現(xiàn)和裝飾該請(qǐng)求。
舉個(gè)例子,下面的這個(gè)模式允許使用當(dāng)前url和身份驗(yàn)證token來裝飾每個(gè)發(fā)往身份驗(yàn)證中心服務(wù)的請(qǐng)求。
CloudDNS cloudDNS = Feign.builder().target(new CloudIdentityTarget<CloudDNS>(user, apiKey));
示例
Feign 包含了 GitHub 和 Wikipedia 客戶端的實(shí)現(xiàn)樣例.相似的項(xiàng)目也同樣在實(shí)踐中運(yùn)用了Feign。尤其是它的示例后臺(tái)程序。
四,Feign集成模塊
Feign 可以和其他的開源工具集成工作。你可以將這些開源工具集成到 Feign 中來。目前已經(jīng)有的一些模塊如下:
4.1,Gson
Gson 包含了一個(gè)編碼器和一個(gè)解碼器,這個(gè)可以被用于JSON格式的API。
添加 GsonEncoder 以及 GsonDecoder 到你的 Feign.Builder 中, 如下:
GsonCodec codec = new GsonCodec(); GitHub github = Feign.builder() .encoder(new GsonEncoder()) .decoder(new GsonDecoder()) .target(GitHub.class, https://api.github.com);
Maven依賴:
<!-- https://mvnrepository.com/artifact/com.netflix.feign/feign-gson --> <dependency> <groupId>com.netflix.feign</groupId> <artifactId>feign-gson</artifactId> <version>8.18.0</version> </dependency>
4.2,Jackson
Jackson 包含了一個(gè)編碼器和一個(gè)解碼器,這個(gè)可以被用于JSON格式的API。
添加 JacksonEncoder 以及 JacksonDecoder 到你的 Feign.Builder 中, 如下:
GitHub github = Feign.builder() .encoder(new JacksonEncoder()) .decoder(new JacksonDecoder()) .target(GitHub.class, https://api.github.com);
Maven依賴:
<!-- https://mvnrepository.com/artifact/com.netflix.feign/feign-gson --> <dependency> <groupId>com.netflix.feign</groupId> <artifactId>feign-jackson</artifactId> <version>8.18.0</version> </dependency>
4.3,Sax
SaxDecoder 用于解析XML,并兼容普通JVM和Android。下面是一個(gè)配置sax來解析響應(yīng)的例子:
api = Feign.builder()
.decoder(SAXDecoder.builder()
.registerContentHandler(UserIdHandler.class)
.build())
.target(Api.class, https://apihost);
Maven依賴:
<dependency> <groupId>com.netflix.feign</groupId> <artifactId>feign-sax</artifactId> <version>8.18.0</version> </dependency>
4.4,JAXB
JAXB 包含了一個(gè)編碼器和一個(gè)解碼器,這個(gè)可以被用于XML格式的API。
添加 JAXBEncoder 以及 JAXBDecoder 到你的 Feign.Builder 中, 如下:
api = Feign.builder() .encoder(new JAXBEncoder()) .decoder(new JAXBDecoder()) .target(Api.class, https://apihost);
Maven依賴:
<!-- https://mvnrepository.com/artifact/com.netflix.feign/feign-gson --> <dependency> <groupId>com.netflix.feign</groupId> <artifactId>feign-jaxb</artifactId> <version>8.18.0</version> </dependency>
4.5,JAX-RS
JAXRSContract 使用 JAX-RS 規(guī)范重寫覆蓋了默認(rèn)的注解處理。下面是一個(gè)使用 JAX-RS 的例子:
interface GitHub { @GET @Path("/repos/{owner}/{repo}/contributors") List<Contributor> contributors(@PathParam("owner") String owner, @PathParam("repo") String repo); } // contract 方法配置注解處理器,注解處理器定義了哪些注解和值是可以作用于接口的 GitHub github = Feign.builder() .contract(new JAXRSContract()) .target(GitHub.class, https://api.github.com);
Maven依賴:
<!-- https://mvnrepository.com/artifact/com.netflix.feign/feign-gson --> <dependency> <groupId>com.netflix.feign</groupId> <artifactId>feign-jaxrs</artifactId> <version>8.18.0</version> </dependency>
4.5,OkHttp
OkHttpClient 使用 OkHttp 來發(fā)送 Feign 的請(qǐng)求,OkHttp 支持 SPDY (SPDY是Google開發(fā)的基于TCP的傳輸層協(xié)議,用以最小化網(wǎng)絡(luò)延遲,提升網(wǎng)絡(luò)速度,優(yōu)化用戶的網(wǎng)絡(luò)使用體驗(yàn)),并有更好的控制http請(qǐng)求。
要讓 Feign 使用 OkHttp ,你需要將 OkHttp 加入到你的環(huán)境變量中區(qū),然后配置 Feign 使用 OkHttpClient,如下:
GitHub github = Feign.builder() .client(new OkHttpClient()) .target(GitHub.class, "https://api.github.com"); Maven依賴: <!-- https://mvnrepository.com/artifact/com.netflix.feign/feign-gson --> <dependency> <groupId>com.netflix.feign</groupId> <artifactId>feign-okhttp</artifactId> <version>8.18.0</version> </dependency>
4.6,Ribbon
RibbonClient 重寫了 Feign 客戶端的對(duì)URL的處理,其添加了 智能路由以及一些其他由Ribbon提供的彈性功能。
集成Ribbon需要你將ribbon的客戶端名稱當(dāng)做url的host部分來傳遞,如下:
// myAppProd是你的ribbon client name MyService api = Feign.builder().client(RibbonClient.create()).target(MyService.class, "https://myAppProd"); Maven依賴: <!-- https://mvnrepository.com/artifact/com.netflix.feign/feign-gson --> <dependency> <groupId>com.netflix.feign</groupId> <artifactId>feign-ribbon</artifactId> <version>8.18.0</version> </dependency>
4.7,Hystrix
HystrixFeign 配置了 Hystrix 提供的熔斷機(jī)制。
要在 Feign 中使用 Hystrix ,你需要添加Hystrix模塊到你的環(huán)境變量,然后使用 HystrixFeign 來構(gòu)造你的API:
MyService api = HystrixFeign.builder().target(MyService.class, "https://myAppProd"); Maven依賴: <!-- https://mvnrepository.com/artifact/com.netflix.feign/feign-gson --> <dependency> <groupId>com.netflix.feign</groupId> <artifactId>feign-hystrix</artifactId> <version>8.18.0</version> </dependency>
4.8,SLF4J
SLF4JModule 允許你使用 SLF4J 作為 Feign 的日志記錄模塊,這樣你就可以輕松的使用 Logback, Log4J , 等 來記錄你的日志.
要在 Feign 中使用 SLF4J ,你需要添加SLF4J模塊和對(duì)應(yīng)的日志記錄實(shí)現(xiàn)模塊(比如Log4J)到你的環(huán)境變量,然后配置 Feign使用Slf4jLogger :
GitHub github = Feign.builder() .logger(new Slf4jLogger()) .target(GitHub.class, "https://api.github.com"); Maven依賴: <!-- https://mvnrepository.com/artifact/com.netflix.feign/feign-gson --> <dependency> <groupId>com.netflix.feign</groupId> <artifactId>feign-slf4j</artifactId> <version>8.18.0</version> </dependency>
五,Feign 組成
5.1,Decoders
Feign.builder() 允許你自定義一些額外的配置,比如說如何解碼一個(gè)響應(yīng)。假如有接口方法返回的消息不是 Response, String, byte[] 或者 void 類型的,那么你需要配置一個(gè)非默認(rèn)的解碼器。
下面是一個(gè)配置使用JSON解碼器(使用的是feign-gson擴(kuò)展)的例子:
GitHub github = Feign.builder() .decoder(new GsonDecoder()) .target(GitHub.class, https://api.github.com);
假如你想在將響應(yīng)傳遞給解碼器處理前做一些額外的處理,那么你可以使用mapAndDecode方法。一個(gè)用例就是使用jsonp服務(wù)的時(shí)候:
// 貌似1.8.0版本中沒有mapAndDecode這個(gè)方法。。。 JsonpApi jsonpApi = Feign.builder() .mapAndDecode((response, type) -> jsopUnwrap(response, type), new GsonDecoder()) .target(JsonpApi.class, https://some-jsonp-api.com);
5.2,Encoders
發(fā)送一個(gè)Post請(qǐng)求最簡(jiǎn)單的方法就是傳遞一個(gè) String 或者 byte[] 類型的參數(shù)了。你也許還需添加一個(gè)Content-Type請(qǐng)求頭,如下:
interface LoginClient { @RequestLine("POST /") @Headers("Content-Type: application/json") void login(String content); } ... client.login("{\"user_name\": \"denominator\", \"password\": \"secret\"}");
通過配置一個(gè)解碼器,你可以發(fā)送一個(gè)安全類型的請(qǐng)求體,如下是一個(gè)使用 feign-gson 擴(kuò)展的例子:
static class Credentials { final String user_name; final String password; Credentials(String user_name, String password) { this.user_name = user_name; this.password = password; } } interface LoginClient { @RequestLine("POST /") void login(Credentials creds); } ... LoginClient client = Feign.builder() .encoder(new GsonEncoder()) .target(LoginClient.class, "https://foo.com"); client.login(new Credentials("denominator", "secret"));
5.3,@Body templates
@Body注解申明一個(gè)請(qǐng)求體模板,模板中可以帶有參數(shù),與方法中 @Param 注解申明的參數(shù)相匹配,使用方法如下:
interface LoginClient { @RequestLine("POST /") @Headers("Content-Type: application/xml") @Body("<login \"user_name\"=\"{user_name}\" \"password\"=\"{password}\"/>") void xml(@Param("user_name") String user, @Param("password") String password); @RequestLine("POST /") @Headers("Content-Type: application/json") // json curly braces must be escaped! // 這里JSON格式需要的花括號(hào)居然需要轉(zhuǎn)碼,有點(diǎn)蛋疼了。 @Body("%7B\"user_name\": \"{user_name}\", \"password\": \"{password}\"%7D") void json(@Param("user_name") String user, @Param("password") String password); } ... client.xml("denominator", "secret"); // <login "user_name"="denominator" "password"="secret"/> client.json("denominator", "secret"); // {"user_name": "denominator", "password": "secret"}
5.4,Headers
Feign 支持給請(qǐng)求的api設(shè)置或者請(qǐng)求的客戶端設(shè)置請(qǐng)求頭,如下:
給API設(shè)置請(qǐng)求頭
使用 @Headers 設(shè)置靜態(tài)請(qǐng)求頭
// 給BaseApi中的所有方法設(shè)置Accept請(qǐng)求頭 @Headers("Accept: application/json") interface BaseApi<V> { // 單獨(dú)給put方法設(shè)置Content-Type請(qǐng)求頭 @Headers("Content-Type: application/json") @RequestLine("PUT /api/{key}") void put(@Param("key") String, V value); }
設(shè)置動(dòng)態(tài)值的請(qǐng)求頭
@RequestLine("POST /") @Headers("X-Ping: {token}") void post(@Param("token") String token);
設(shè)置key和value都是動(dòng)態(tài)的請(qǐng)求頭
有些API需要根據(jù)調(diào)用時(shí)動(dòng)態(tài)確定使用不同的請(qǐng)求頭(e.g. custom metadata header fields such as “x-amz-meta-“ or “x-goog-meta-“),
這時(shí)候可以使用 @HeaderMap 注解,如下:
// @HeaderMap 注解設(shè)置的請(qǐng)求頭優(yōu)先于其他方式設(shè)置的 @RequestLine("POST /") void post(@HeaderMap Map<String, Object> headerMap);
給Target設(shè)置請(qǐng)求頭
有時(shí)我們需要在一個(gè)API實(shí)現(xiàn)中根據(jù)不同的endpoint來傳入不同的Header,這個(gè)時(shí)候我們可以使用自定義的RequestInterceptor 或 Target來實(shí)現(xiàn).
通過自定義的 RequestInterceptor 來實(shí)現(xiàn)請(qǐng)查看 Request Interceptors 章節(jié).
下面是一個(gè)通過自定義Target來實(shí)現(xiàn)給每個(gè)Target設(shè)置安全校驗(yàn)信息Header的例子:
static class DynamicAuthTokenTarget<T> implements Target<T> { public DynamicAuthTokenTarget(Class<T> clazz, UrlAndTokenProvider provider, ThreadLocal<String> requestIdProvider); ... @Override public Request apply(RequestTemplate input) { TokenIdAndPublicURL urlAndToken = provider.get(); if (input.url().indexOf("http") != 0) { input.insert(0, urlAndToken.publicURL); } input.header("X-Auth-Token", urlAndToken.tokenId); input.header("X-Request-ID", requestIdProvider.get()); return input.request(); } } ... Bank bank = Feign.builder() .target(new DynamicAuthTokenTarget(Bank.class, provider, requestIdProvider));
這種方法的實(shí)現(xiàn)依賴于給Feign 客戶端設(shè)置的自定義的RequestInterceptor 或 Target。可以被用來給一個(gè)客戶端的所有api請(qǐng)求設(shè)置請(qǐng)求頭。比如說可是被用來在header中設(shè)置身份校驗(yàn)信息。這些方法是在線程執(zhí)行api請(qǐng)求的時(shí)候才會(huì)執(zhí)行,所以是允許在運(yùn)行時(shí)根據(jù)上下文來動(dòng)態(tài)設(shè)置header的。
比如說可以根據(jù)線程本地存儲(chǔ)(thread-local storage)來為不同的線程設(shè)置不同的請(qǐng)求頭。
六,高級(jí)用法
6.1,Base APIS
有些請(qǐng)求中的一些方法是通用的,但是可能會(huì)有不同的參數(shù)類型或者返回類型,這個(gè)時(shí)候可以這么用:
// 通用API interface BaseAPI { @RequestLine("GET /health") String health(); @RequestLine("GET /all") List<Entity> all(); } // 繼承通用API interface CustomAPI extends BaseAPI { @RequestLine("GET /custom") String custom(); } // 各種類型有相同的表現(xiàn)形式,定義一個(gè)統(tǒng)一的API @Headers("Accept: application/json") interface BaseApi<V> { @RequestLine("GET /api/{key}") V get(@Param("key") String key); @RequestLine("GET /api") List<V> list(); @Headers("Content-Type: application/json") @RequestLine("PUT /api/{key}") void put(@Param("key") String key, V value); } // 根據(jù)不同的類型來繼承 interface FooApi extends BaseApi<Foo> { } interface BarApi extends BaseApi<Bar> { }
6.2,Logging
你可以通過設(shè)置一個(gè) Logger 來記錄http消息,如下:
GitHub github = Feign.builder() .decoder(new GsonDecoder()) .logger(new Logger.JavaLogger().appendToFile("logs/http.log")) .logLevel(Logger.Level.FULL) .target(GitHub.class, https://api.github.com);
也可以參考上面的 SLF4J 章節(jié)的說明
6.3,Request Interceptors
當(dāng)你希望修改所有的的請(qǐng)求的時(shí)候,你可以使用Request Interceptors。比如說,你作為一個(gè)中介,你可能需要為每個(gè)請(qǐng)求設(shè)置 X-Forwarded-For
static class ForwardedForInterceptor implements RequestInterceptor { @Override public void apply(RequestTemplate template) { template.header("X-Forwarded-For", "origin.host.com"); } } ... Bank bank = Feign.builder() .decoder(accountDecoder) .requestInterceptor(new ForwardedForInterceptor()) .target(Bank.class, https://api.examplebank.com);
或者,你可能需要實(shí)現(xiàn)Basic Auth,這里有一個(gè)內(nèi)置的基礎(chǔ)校驗(yàn)攔截器
BasicAuthRequestInterceptor Bank bank = Feign.builder() .decoder(accountDecoder) .requestInterceptor(new BasicAuthRequestInterceptor(username, password)) .target(Bank.class, https://api.examplebank.com);
6.4,Custom @Param Expansion
在使用 @Param 注解給模板中的參數(shù)設(shè)值的時(shí)候,默認(rèn)的是使用的對(duì)象的 toString() 方法的值,通過聲明 自定義的Param.Expander,用戶可以控制其行為,比如說格式化 Date 類型的值:
// 通過設(shè)置 @Param 的 expander 為 DateToMillis.class 可以定義Date類型的值 @RequestLine("GET /?since={date}") Result list(@Param(value = "date", expander = DateToMillis.class) Date date);
6.5,Dynamic Query Parameters
動(dòng)態(tài)查詢參數(shù)支持,通過使用 @QueryMap 可以允許動(dòng)態(tài)傳入請(qǐng)求參數(shù),如下:
@RequestLine("GET /find") V find(@QueryMap Map<String, Object> queryMap);
6.6,Static and Default Methods
如果你使用的是JDK 1.8+ 的話,那么你可以給接口設(shè)置統(tǒng)一的默認(rèn)方法和靜態(tài)方法,這個(gè)事JDK8的新特性,如下:
interface GitHub { @RequestLine("GET /repos/{owner}/{repo}/contributors") List<Contributor> contributors(@Param("owner") String owner, @Param("repo") String repo); @RequestLine("GET /users/{username}/repos?sort={sort}") List<Repo> repos(@Param("username") String owner, @Param("sort") String sort); default List<Repo> repos(String owner) { return repos(owner, "full_name"); } /** * Lists all contributors for all repos owned by a user. */ default List<Contributor> contributors(String user) { MergingContributorList contributors = new MergingContributorList(); for(Repo repo : this.repos(owner)) { contributors.addAll(this.contributors(user, repo.getName())); } return contributors.mergeResult(); } static GitHub connect() { return Feign.builder() .decoder(new GsonDecoder()) .target(GitHub.class, "https://api.github.com"); } }
感謝各位的閱讀!關(guān)于“Java中Feign怎么用”這篇文章就分享到這里了,希望以上內(nèi)容可以對(duì)大家有一定的幫助,讓大家可以學(xué)到更多知識(shí),如果覺得文章不錯(cuò),可以把它分享出去讓更多的人看到吧!
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。