通過FeignClient如何獲取文件流steam?is?close問題
FeignClient獲取文件流 steam is close問題
inputstream.read 報(bào)錯(cuò) steam is close
原因
idea debug啟動導(dǎo)致
解決辦法
直接啟動
FeignClient注解參數(shù)
name
:指定FeignClient的名稱,如果項(xiàng)目使用了Ribbon,name屬性會作為微服務(wù)的名稱,用于服務(wù)發(fā)現(xiàn)url
: url一般用于調(diào)試,可以手動指定@FeignClient調(diào)用的地址decode404
:當(dāng)發(fā)生http 404錯(cuò)誤時(shí),如果該字段位true,會調(diào)用decoder進(jìn)行解碼,否則拋出FeignExceptionconfiguration
: Feign配置類,可以自定義Feign的Encoder、Decoder、LogLevel、Contractfallback
: 定義容錯(cuò)的處理類,當(dāng)調(diào)用遠(yuǎn)程接口失敗或超時(shí)時(shí),會調(diào)用對應(yīng)接口的容錯(cuò)邏輯,fallback指定的類必須實(shí)現(xiàn)@FeignClient標(biāo)記的接口fallbackFactory
: 工廠類,用于生成fallback類示例,通過這個(gè)屬性我們可以實(shí)現(xiàn)每個(gè)接口通用的容錯(cuò)邏輯,減少重復(fù)的代碼path
: 定義當(dāng)前FeignClient的統(tǒng)一前綴
日志級別配置
默認(rèn)Feign是不打印任何日志的,下面我們來開啟Feign的日志,F(xiàn)eign有四種日志級別:
NONE
【性能最佳,適用于生產(chǎn)】:不記錄任何日志(默認(rèn)值)。BASIC
【適用于生產(chǎn)環(huán)境追蹤問題】:僅記錄請求方法、URL、響應(yīng)狀態(tài)代碼以及執(zhí)行時(shí)間。HEADERS
:記錄BASIC級別的基礎(chǔ)上,記錄請求和響應(yīng)的header。FULL
【比較適用于開發(fā)及測試環(huán)境定位問題】:記錄請求和響應(yīng)的header、body和元數(shù)據(jù)。
在application.yml 中添加以下內(nèi)容,將該Feign接口的日志級別設(shè)置為DEBUG:
# 定義feign客戶端所在的路徑,需要設(shè)置日志級別為debug logging.level: com.example.customer.service.CustomerService: debug # user為服務(wù)名,單個(gè)配置客戶端日志級別設(shè)置,如果需要全局配置,把user更換為default feign.client.config.user.loggerLevel: FULL
調(diào)用日志信息截圖
2020-06-07 14:06:27.671 DEBUG 24961 --- [nio-8081-exec-3] c.e.customer.service.CustomerService : [CustomerService#getUser] ---> GET http://user/user HTTP/1.1
2020-06-07 14:06:27.671 DEBUG 24961 --- [nio-8081-exec-3] c.e.customer.service.CustomerService : [CustomerService#getUser] ---> END HTTP (0-byte body)
2020-06-07 14:06:27.678 DEBUG 24961 --- [nio-8081-exec-3] c.e.customer.service.CustomerService : [CustomerService#getUser] <--- HTTP/1.1 200 (7ms)
2020-06-07 14:06:27.679 DEBUG 24961 --- [nio-8081-exec-3] c.e.customer.service.CustomerService : [CustomerService#getUser] connection: keep-alive
2020-06-07 14:06:27.679 DEBUG 24961 --- [nio-8081-exec-3] c.e.customer.service.CustomerService : [CustomerService#getUser] content-type: application/json
2020-06-07 14:06:27.679 DEBUG 24961 --- [nio-8081-exec-3] c.e.customer.service.CustomerService : [CustomerService#getUser] date: Sun, 07 Jun 2020 06:06:27 GMT
2020-06-07 14:06:27.679 DEBUG 24961 --- [nio-8081-exec-3] c.e.customer.service.CustomerService : [CustomerService#getUser] keep-alive: timeout=60
2020-06-07 14:06:27.679 DEBUG 24961 --- [nio-8081-exec-3] c.e.customer.service.CustomerService : [CustomerService#getUser] transfer-encoding: chunked
2020-06-07 14:06:27.679 DEBUG 24961 --- [nio-8081-exec-3] c.e.customer.service.CustomerService : [CustomerService#getUser]
2020-06-07 14:06:27.679 DEBUG 24961 --- [nio-8081-exec-3] c.e.customer.service.CustomerService : [CustomerService#getUser] {"id":1,"name":"test","phone":"119"}
2020-06-07 14:06:27.679 DEBUG 24961 --- [nio-8081-exec-3] c.e.customer.service.CustomerService : [CustomerService#getUser] <--- END HTTP (36-byte body)
服務(wù)超時(shí)、重試、降級和熔斷
·超時(shí) Feign接口調(diào)用分兩層,Ribbon(負(fù)載均衡)和Hystrix(熔斷器)的調(diào)用,因此Feign的超時(shí)時(shí)間就是ribbon的超時(shí)時(shí)間和Hystrix的超時(shí)時(shí)間的結(jié)合
·重試 使用Ribbon
設(shè)置Ribbon重試次數(shù)
ribbon: #連接超時(shí)時(shí)間 ConnectTimeout: 1000 #讀超時(shí)時(shí)間 ReadTimeout: 1000 ##同一臺實(shí)例最大重試次數(shù),不包括首次調(diào)用 MaxAutoRetries: 0 #重試負(fù)載均衡其他的實(shí)例最大重試次數(shù),不包括首次調(diào)用 MaxAutoRetriesNextServer: 1 #是否所有操作都重試,設(shè)置false時(shí),只會對get請求進(jìn)行重試;如果設(shè)置為true,便會對所有的請求進(jìn)行重試,如果是put或post等寫操作,如果服務(wù)器接口沒做冪等性,慎用; OkToRetryOnAllOperations: false
負(fù)載均衡配置
#服務(wù)名 user: ribbon: #選擇隨機(jī)算法 NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule
Ribbon Eager加載
默認(rèn)情況下Ribbon是懶加載的——首次請求Ribbon相關(guān)類才會初始化,這會導(dǎo)致首次請求過慢的問題,你可以配置饑餓加載,讓Ribbon在應(yīng)用啟動時(shí)就初始化。
ribbon: eager-load: enabled: true # 多個(gè)用,分隔 clients: user
降級和熔斷使用hystrix
如果重試期間,調(diào)用時(shí)間超過了 Hystrix熔斷的超時(shí)時(shí)間,便會立即熔斷,進(jìn)行FallBack
# 開啟hystrix feign.hystrix.enabled: true # hystrix的超時(shí)時(shí)間 時(shí)間設(shè)置需要根據(jù)實(shí)際業(yè)務(wù)場景計(jì)算得出 hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds: 10000
Fallback配置
@FeignClient(name = "user", fallback = CustomerFeignClientFallback.class) public interface CustomerService { /** * 獲取用戶信息 * * @return 用戶信息 */ @GetMapping("/user") UserDTO getUser (); @Component public class CustomerFeignClientFallback implements CustomerService { @Override public UserDTO getUser () { //todo 回退邏輯 return new UserDTO().setName("服務(wù)降級"); } } }
@FeignClient(name = "user", fallbackFactory = CustomerFeignClientFallbackFactory.class) public interface CustomerService { /** * 獲取用戶信息 * * @return 用戶信息 */ @GetMapping("/user") UserDTO getUser (); @Component @Slf4j public class CustomerFeignClientFallbackFactory implements FallbackFactory<CustomerService> { @Override public CustomerService getUser () { //todo 回退邏輯 return new UserDTO().setName("服務(wù)降級"); } } }
配置
logging: level: com.example.customer.service.CustomerService: debug #全局配置,單個(gè)服務(wù)配置把default替換為需要設(shè)置的服務(wù)名 feign: client.config.default.loggerLevel: FULL okhttp.enabled: true #熔斷與回退 hystrix.enabled: true #重試機(jī)制 ribbon: #連接超時(shí)時(shí)間 ConnectTimeout: 2000 #讀超時(shí)時(shí)間 ReadTimeout: 2000 ##同一臺實(shí)例最大重試次數(shù),不包括首次調(diào)用 MaxAutoRetries: 0 #重試負(fù)載均衡其他的實(shí)例最大重試次數(shù),不包括首次調(diào)用 MaxAutoRetriesNextServer: 1 #是否所有操作都重試 OkToRetryOnAllOperations: false # Hystrix的超時(shí)時(shí)間 hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds: 10000
有關(guān)Feign超時(shí)時(shí)間易混淆概念
Feign超時(shí)時(shí)間
feign.client.config.default.connectTimeout=10000 //Feign的連接建立超時(shí)時(shí)間,默認(rèn)為10秒 feign.client.config.default.readTimeout=60000 //Feign的請求處理超時(shí)時(shí)間,默認(rèn)為60
Ribbon 超時(shí)時(shí)間
ribbon.ReadTimeout=1000 //處理請求的超時(shí)時(shí)間,默認(rèn)為1秒 ribbon.ConnectTimeout=1000 //連接建立的超時(shí)時(shí)長,默認(rèn)1秒
Hystrix 超時(shí)時(shí)間
hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds=3000 #熔斷器的超時(shí)時(shí)長默認(rèn)1秒
以上各種超時(shí)配置,如果都存在,則時(shí)間小的配置生效
小提示
Feign
的底層是調(diào)用ribbon來實(shí)現(xiàn)負(fù)載均衡的,為了不和ribbon的重試機(jī)制沖突不需要配置feign超時(shí)時(shí)間和重試功能,只需配置ribbon和hystrix超時(shí)時(shí)間即可。Ribbon
超時(shí)時(shí)間必須小于hysrix超時(shí)設(shè)置,這樣才能觸發(fā)ribbon重試,ribbon重試分為兩種情況,同一實(shí)例重試和負(fù)載均衡的不同實(shí)例重試,默認(rèn)為1次和0次Feign
的默認(rèn)配置,是不啟用hystrix,需要開啟feign.hystrix.enabled=true,這樣hystrix的相關(guān)配置才可以在Feign中生效。Hystrix
的超時(shí)時(shí)間=Ribbon的重試次數(shù)(包含首次) * (ribbon.ReadTimeout + ribbon.ConnectTimeout)- 在
Ribbon
超時(shí)但Hystrix沒有超時(shí)的情況下,Ribbon便會采取重試機(jī)制;而重試期間如果時(shí)間超過了Hystrix的超時(shí)配置則會立即被熔斷(fallback) - 關(guān)系圖
以上為個(gè)人經(jīng)驗(yàn),希望能給大家一個(gè)參考,也希望大家多多支持腳本之家。
相關(guān)文章
java從mysql導(dǎo)出數(shù)據(jù)的具體實(shí)例
這篇文章主要介紹了java從mysql導(dǎo)出數(shù)據(jù)的具體實(shí)例,有需要的朋友可以參考一下2013-12-12詳解Java中l(wèi)og4j.properties配置與加載應(yīng)用
這篇文章主要介紹了 log4j.properties配置與加載應(yīng)用的相關(guān)資料,需要的朋友可以參考下2018-02-02Spring Cloud Gateway全局通用異常處理的實(shí)現(xiàn)
這篇文章主要介紹了Spring Cloud Gateway全局通用異常處理的實(shí)現(xiàn),文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-05-05Java基礎(chǔ)第二篇方法與數(shù)據(jù)成員
在上一篇文章中介紹了Java基礎(chǔ) 從HelloWorld到面向?qū)ο螅覀兂醪搅私饬藢ο?object)。對象中的數(shù)據(jù)成員表示對象的狀態(tài)。對象可以執(zhí)行方法,表示特定的動作。這篇文章我們進(jìn)一步深入到對象。了解Java中方法與數(shù)據(jù)成員的一些細(xì)節(jié)。2021-09-09JAVA中通過Hibernate-Validation進(jìn)行參數(shù)驗(yàn)證
這篇文章主要介紹了JAVA中通過Hibernate-Validation進(jìn)行參數(shù)驗(yàn)證,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2019-04-04SpringBoot整合RabbitMQ處理死信隊(duì)列和延遲隊(duì)列
這篇文章將通過示例為大家詳細(xì)介紹SpringBoot整合RabbitMQ時(shí)如何處理死信隊(duì)列和延遲隊(duì)列,文中的示例代碼講解詳細(xì),需要的可以參考一下2022-05-05