Feign常見(jiàn)問(wèn)題總結(jié)
FeignClient接口如使用@PathVariable
,必須指定value屬性
//在一些早期版本中, @PathVariable("id") 中的 "id" ,也就是value屬性,必須指定,不能省略。
@FeignClient("microservice-provider-user")
public interface UserFeignClient {
@RequestMapping(value = "/simple/{id}", method = RequestMethod.GET)
public User findById(@PathVariable("id") Long id);
...
}
Java代碼自定義Feign Client的注意點(diǎn)與坑
@FeignClient(name = "microservice-provider-user", configuration = UserFeignConfig.class)
public interface UserFeignClient {
@GetMapping("/users/{id}")
User findById(@PathVariable("id") Long id);
}
/**
* 該Feign Client的配置類(lèi),注意:
* 1. 該類(lèi)可以獨(dú)立出去;
* 2. 該類(lèi)上也可添加@Configuration聲明是一個(gè)配置類(lèi);
* 配置類(lèi)上也可添加@Configuration注解,聲明這是一個(gè)配置類(lèi);
* 但此時(shí)千萬(wàn)別將該放置在主應(yīng)用程序上下文@ComponentScan所掃描的包中,
* 否則,該配置將會(huì)被所有Feign Client共享,無(wú)法實(shí)現(xiàn)細(xì)粒度配置!
* 個(gè)人建議:像我一樣,不加@Configuration注解
*
* @author zhouli
*/
class UserFeignConfig {
@Bean
public Logger.Level logger() {
return Logger.Level.FULL;
}
}
- 配置類(lèi)上也可添加@Configuraiton 注解,聲明這是一個(gè)配置類(lèi);但此時(shí)千萬(wàn)別將該放置在主應(yīng)用程序上下文@ComponentScan 所掃描的包中,否則,該配置將會(huì)被所有Feign Client共享(相當(dāng)于變成了通用配置,其實(shí)本質(zhì)還是Spring父子上下文掃描包重疊導(dǎo)致的問(wèn)題),無(wú)法實(shí)現(xiàn)細(xì)粒度配置!
- 個(gè)人建議:像我一樣,不加@Configuration注解,省得進(jìn)坑。
- 最佳實(shí)踐:盡量用配置屬性自定義Feign的配置!!!
@FeignClient 注解屬性
//@FeignClient(name = "microservice-provider-user")
//在早期的Spring Cloud版本中,無(wú)需提供name屬性,從Brixton版開(kāi)始,@FeignClient必須提供name屬性,否則應(yīng)用將無(wú)法正常啟動(dòng)!
//另外,name、url等屬性支持占位符。例如:
@FeignClient(name = "${feign.name}", url = "${feign.url}")
類(lèi)級(jí)別的@RequestMapping會(huì)被Spring MVC加載
@RequestMapping("/users")
@FeignClient(name = "microservice-user")
public class TestFeignClient {
// ...
}
類(lèi)上的@RequestMapping
注解也會(huì)被Spring MVC加載。該問(wèn)題現(xiàn)已經(jīng)被解決,早期的版本有兩種解決方案:
方案1:不在類(lèi)上加@RequestMapping 注解;
方案2:添加如下代碼:
@Configuration
@ConditionalOnClass({ Feign.class })
public class FeignMappingDefaultConfiguration {
@Bean
public WebMvcRegistrations feignWebRegistrations() {
return new WebMvcRegistrationsAdapter() {
@Override
public RequestMappingHandlerMapping getRequestMappingHandlerMapping() {
return new FeignFilterRequestMappingHandlerMapping();
}
};
}
private static class FeignFilterRequestMappingHandlerMapping extends RequestMappingHandlerMapping {
@Override
protected boolean isHandler(Class beanType) {
return super.isHandler(beanType) && !beanType.isInterface();
}
}
}
首次請(qǐng)求失敗
Ribbon的饑餓加載(eager-load)模式
如需產(chǎn)生Hystrix Stream監(jiān)控信息,需要做一些額外操作
Feign本身已經(jīng)整合了Hystrix,可直接使用@FeignClient(value = "microservice-provider-user", fallback = XXX.class)
來(lái)指定fallback類(lèi),fallback類(lèi)繼承@FeignClient
所標(biāo)注的接口即可。
但是假設(shè)如需使用Hystrix Stream進(jìn)行監(jiān)控,默認(rèn)情況下,訪(fǎng)問(wèn)http://IP:PORT/actuator/hystrix.stream 是會(huì)返回404,這是因?yàn)镕eign雖然整合了Hystrix,但并沒(méi)有整合Hystrix的監(jiān)控。如何添加監(jiān)控支持呢?需要以下幾步:
第一步:添加依賴(lài),示例:
org.springframework.cloudspring-cloud-starter-hystrix
第二步:在啟動(dòng)類(lèi)上添加@EnableCircuitBreaker 注解,示例:
@SpringBootApplication
@EnableFeignClients
@EnableDiscoveryClient
@EnableCircuitBreaker
public class MovieFeignHystrixApplication {
public static void main(String[] args) {
SpringApplication.run(MovieFeignHystrixApplication.class, args);
}
}
第三步:在application.yml中添加如下內(nèi)容,暴露hystrix.stream端點(diǎn):
management:
endpoints:
web:
exposure:
include: 'hystrix.stream'
這樣,訪(fǎng)問(wèn)任意Feign Client接口的API后,再訪(fǎng)問(wèn)http://IP:PORT/actuator/hystrix.stream ,就會(huì)展示一大堆Hystrix監(jiān)控?cái)?shù)據(jù)了。
原文鏈接:http://www.itmuch.com/spring-...
Feign 上傳文件
加依賴(lài)
io.github.openfeign.formfeign-form3.0.3io.github.openfeign.formfeign-form-spring3.0.3
編寫(xiě)Feign Client
@FeignClient(name = "ms-content-sample", configuration = UploadFeignClient.MultipartSupportConfig.class)
public interface UploadFeignClient {
@RequestMapping(value = "/upload", method = RequestMethod.POST,
produces = {MediaType.APPLICATION_JSON_UTF8_VALUE},
consumes = MediaType.MULTIPART_FORM_DATA_VALUE)
@ResponseBody
String handleFileUpload(@RequestPart(value = "file") MultipartFile file);
class MultipartSupportConfig {
@Bean
public Encoder feignFormEncoder() {
return new SpringFormEncoder();
}
}
}
如代碼所示,在這個(gè)Feign Client中,我們引用了配置類(lèi)MultipartSupportConfig
,在MultipartSupportConfig
中,我們實(shí)例化了SpringFormEncoder
。這樣這個(gè)Feign Client就能夠上傳啦。
注意點(diǎn)
//RequestMapping注解中的produeces 、consumes 不能少;
@RequestMapping(value = "/upload", method = RequestMethod.POST,
produces = {MediaType.APPLICATION_JSON_UTF8_VALUE},
consumes = MediaType.MULTIPART_FORM_DATA_VALUE)
-
接口定義中的注解
@RequestPart(value = "file")
不能寫(xiě)成@RequestParam(value = "file")
。 - 最好將Hystrix的超時(shí)時(shí)間設(shè)長(zhǎng)一點(diǎn),例如5秒,否則可能文件還沒(méi)上傳完,Hystrix就超時(shí)了,從而導(dǎo)致客戶(hù)端側(cè)的報(bào)錯(cuò)。
原文鏈接:http://www.itmuch.com/spring-...
Feign實(shí)現(xiàn)Form表單提交
添加依賴(lài):
io.github.openfeign.formfeign-form3.2.2io.github.openfeign.formfeign-form-spring3.2.2
Feign Client示例:
@FeignClient(name = "xxx", url = "http://www.itmuch.com/", configuration = TestFeignClient.FormSupportConfig.class)
public interface TestFeignClient {
@PostMapping(value = "/test",
consumes = {MediaType.APPLICATION_FORM_URLENCODED_VALUE},
produces = {MediaType.APPLICATION_JSON_UTF8_VALUE}
)
void post(Map queryParam);
class FormSupportConfig {
@Autowired
private ObjectFactory messageConverters;
// new一個(gè)form編碼器,實(shí)現(xiàn)支持form表單提交
@Bean
public Encoder feignFormEncoder() {
return new SpringFormEncoder(new SpringEncoder(messageConverters));
}
// 開(kāi)啟Feign的日志
@Bean
public Logger.Level logger() {
return Logger.Level.FULL;
}
}
},>
調(diào)用示例:
@GetMapping("/user/{id}")
public User findById(@PathVariable Long id) {
HashMap param = Maps.newHashMap();
param.put("username","zhangsan");
param.put("password","pwd");
this.testFeignClient.post(param);
return new User();
},>
日志:
...[TestFeignClient#post] ---> POST http://www.baidu.com/test HTTP/1.1
...[TestFeignClient#post] Accept: application/json;charset=UTF-8
...[TestFeignClient#post] Content-Type: application/x-www-form-urlencoded; charset=UTF-8
...[TestFeignClient#post] Content-Length: 30
...[TestFeignClient#post]
...[TestFeignClient#post] password=pwd&username=zhangsan
...[TestFeignClient#post] ---> END HTTP (30-byte body)
由日志可知,此時(shí)Feign已能使用Form表單方式提交數(shù)據(jù)。
原文鏈接:http://www.itmuch.com/spring-...
Feign GET請(qǐng)求如何構(gòu)造多參數(shù)
假設(shè)需請(qǐng)求的URL包含多個(gè)參數(shù),例如http://microservice-provider-... ,該如何使用Feign構(gòu)造呢?
我們知道,Spring Cloud為Feign添加了Spring MVC的注解支持,那么我們不妨按照Spring MVC的寫(xiě)法嘗試一下:
@FeignClient("microservice-provider-user")
public interface UserFeignClient {
@RequestMapping(value = "/get", method = RequestMethod.GET)
public User get0(User user);
}
然而,這種寫(xiě)法并不正確,控制臺(tái)會(huì)輸出類(lèi)似如下的異常。
feign.FeignException: status 405 reading UserFeignClient#get0(User); content:
{"timestamp":1482676142940,"status":405,"error":"Method Not Allowed","exception":"org.springframework.web.HttpRequestMethodNotSupportedException","message":"Request method 'POST' not supported","path":"/get"}
由異常可知,盡管我們指定了GET方法,F(xiàn)eign依然會(huì)使用POST方法發(fā)送請(qǐng)求。于是導(dǎo)致了異常。正確寫(xiě)法如下
方法一[推薦]
注意:使用該方法無(wú)法使用Fegin的繼承模式
@FeignClient("microservice-provider-user")
public interface UserFeignClient {
@GetMapping("/get")
public User get0(@SpringQueryMap User user);
}
方法二[推薦]
@FeignClient(name = "microservice-provider-user")
public interface UserFeignClient {
@RequestMapping(value = "/get", method = RequestMethod.GET)
public User get1(@RequestParam("id") Long id, @RequestParam("username") String username);
}
這是最為直觀(guān)的方式,URL有幾個(gè)參數(shù),F(xiàn)eign接口中的方法就有幾個(gè)參數(shù)。使用@RequestParam注解指定請(qǐng)求的參數(shù)是什么。
方法三[不推薦]
多參數(shù)的URL也可使用Map來(lái)構(gòu)建。當(dāng)目標(biāo)URL參數(shù)非常多的時(shí)候,可使用這種方式簡(jiǎn)化Feign接口的編寫(xiě)。
@FeignClient(name = "microservice-provider-user")
public interface UserFeignClient {
@RequestMapping(value = "/get", method = RequestMethod.GET)
public User get2(@RequestParam Map map);
},>
在調(diào)用時(shí),可使用類(lèi)似以下的代碼。
public User get(String username, String password) {
HashMap map = Maps.newHashMap();
map.put("id", "1");
map.put("username", "張三");
return this.userFeignClient.get2(map);
},>
注意:這種方式不建議使用。主要是因?yàn)榭勺x性不好,而且如果參數(shù)為空的時(shí)候會(huì)有一些問(wèn)題,例如map.put("username", null);
會(huì)導(dǎo)致服務(wù)調(diào)用方(消費(fèi)者服務(wù))接收到的username是"" ,而不是null。
原文鏈接:http://www.itmuch.com/spring-...
切換為 Okhttp3 提升 QPS 性能優(yōu)化
加依賴(lài)引入okhttp3
io.github.openfeignfeign-okhttp${version}
寫(xiě)配置
feign:
# feign啟用hystrix,才能熔斷、降級(jí)
# hystrix:
# enabled: true
# 啟用 okhttp 關(guān)閉默認(rèn) httpclient
httpclient:
enabled: false #關(guān)閉httpclient
# 配置連接池
max-connections: 200 #feign的最大連接數(shù)
max-connections-per-route: 50 #fegin單個(gè)路徑的最大連接數(shù)
okhttp:
enabled: true
# 請(qǐng)求與響應(yīng)的壓縮以提高通信效率
compression:
request:
enabled: true
min-request-size: 2048
mime-types: text/xml,application/xml,application/json
response:
enabled: true
參數(shù)配置
/**
* 配置 okhttp 與連接池
* ConnectionPool 默認(rèn)創(chuàng)建5個(gè)線(xiàn)程,保持5分鐘長(zhǎng)連接
*/
@Configuration
@ConditionalOnClass(Feign.class)
@AutoConfigureBefore(FeignAutoConfiguration.class) //SpringBoot自動(dòng)配置
public class OkHttpConfig {
// 默認(rèn)老外留給你彩蛋中文亂碼,加上它就 OK
@Bean
public Encoder encoder() {
return new FormEncoder();
}
@Bean
public okhttp3.OkHttpClient okHttpClient() {
return new okhttp3.OkHttpClient.Builder()
//設(shè)置連接超時(shí)
.connectTimeout(10, TimeUnit.SECONDS)
//設(shè)置讀超時(shí)
.readTimeout(10, TimeUnit.SECONDS)
//設(shè)置寫(xiě)超時(shí)
.writeTimeout(10, TimeUnit.SECONDS)
//是否自動(dòng)重連
.retryOnConnectionFailure(true)
.connectionPool(new ConnectionPool(10, 5L, TimeUnit.MINUTES))
.build();
}
}
-
Linux
+關(guān)注
關(guān)注
87文章
11296瀏覽量
209353 -
JAVA
+關(guān)注
關(guān)注
19文章
2966瀏覽量
104704 -
數(shù)據(jù)庫(kù)
+關(guān)注
關(guān)注
7文章
3795瀏覽量
64364 -
python
+關(guān)注
關(guān)注
56文章
4793瀏覽量
84631
發(fā)布評(píng)論請(qǐng)先 登錄
相關(guān)推薦
評(píng)論