通過(guò)FeignClient如何獲取文件流steam?is?close問(wèn)題

更新時(shí)間：2022年06月16日 09:27:17 作者：localhost?:8080

這篇文章主要介紹了通過(guò)FeignClient如何獲取文件流steam?is?close問(wèn)題，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教

FeignClient獲取文件流 steam is close問(wèn)題

inputstream.read 報(bào)錯(cuò) steam is close

原因

idea debug啟動(dòng)導(dǎo)致

解決辦法

直接啟動(dòng)

FeignClient注解參數(shù)

name：指定FeignClient的名稱，如果項(xiàng)目使用了Ribbon，name屬性會(huì)作為微服務(wù)的名稱，用于服務(wù)發(fā)現(xiàn)
url: url一般用于調(diào)試，可以手動(dòng)指定@FeignClient調(diào)用的地址
decode404:當(dāng)發(fā)生http 404錯(cuò)誤時(shí)，如果該字段位true，會(huì)調(diào)用decoder進(jìn)行解碼，否則拋出FeignException
configuration: Feign配置類，可以自定義Feign的Encoder、Decoder、LogLevel、Contract
fallback: 定義容錯(cuò)的處理類，當(dāng)調(diào)用遠(yuǎn)程接口失敗或超時(shí)時(shí)，會(huì)調(diào)用對(duì)應(yīng)接口的容錯(cuò)邏輯，fallback指定的類必須實(shí)現(xiàn)@FeignClient標(biāo)記的接口
fallbackFactory: 工廠類，用于生成fallback類示例，通過(guò)這個(gè)屬性我們可以實(shí)現(xiàn)每個(gè)接口通用的容錯(cuò)邏輯，減少重復(fù)的代碼
path: 定義當(dāng)前FeignClient的統(tǒng)一前綴

日志級(jí)別配置

默認(rèn)Feign是不打印任何日志的，下面我們來(lái)開(kāi)啟Feign的日志，F(xiàn)eign有四種日志級(jí)別：

NONE【性能最佳，適用于生產(chǎn)】：不記錄任何日志（默認(rèn)值）。
BASIC【適用于生產(chǎn)環(huán)境追蹤問(wèn)題】：僅記錄請(qǐng)求方法、URL、響應(yīng)狀態(tài)代碼以及執(zhí)行時(shí)間。
HEADERS：記錄BASIC級(jí)別的基礎(chǔ)上，記錄請(qǐng)求和響應(yīng)的header。
FULL【比較適用于開(kāi)發(fā)及測(cè)試環(huán)境定位問(wèn)題】：記錄請(qǐng)求和響應(yīng)的header、body和元數(shù)據(jù)。

在application.yml 中添加以下內(nèi)容，將該Feign接口的日志級(jí)別設(shè)置為DEBUG：

# 定義feign客戶端所在的路徑，需要設(shè)置日志級(jí)別為debug
logging.level: com.example.customer.service.CustomerService: debug
# user為服務(wù)名，單個(gè)配置客戶端日志級(jí)別設(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í)、重試、降級(jí)和熔斷

·超時(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
  ##同一臺(tái)實(shí)例最大重試次數(shù),不包括首次調(diào)用
  MaxAutoRetries: 0
  #重試負(fù)載均衡其他的實(shí)例最大重試次數(shù),不包括首次調(diào)用
  MaxAutoRetriesNextServer: 1
  #是否所有操作都重試,設(shè)置false時(shí)，只會(huì)對(duì)get請(qǐng)求進(jìn)行重試；如果設(shè)置為true，便會(huì)對(duì)所有的請(qǐng)求進(jìn)行重試，如果是put或post等寫(xiě)操作，如果服務(wù)器接口沒(méi)做冪等性,慎用；
  OkToRetryOnAllOperations: false

負(fù)載均衡配置

#服務(wù)名
user:
  ribbon:
    #選擇隨機(jī)算法
    NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule

Ribbon Eager加載

默認(rèn)情況下Ribbon是懶加載的——首次請(qǐng)求Ribbon相關(guān)類才會(huì)初始化，這會(huì)導(dǎo)致首次請(qǐng)求過(guò)慢的問(wèn)題，你可以配置饑餓加載，讓Ribbon在應(yīng)用啟動(dòng)時(shí)就初始化。

ribbon:
  eager-load:
    enabled: true
    # 多個(gè)用,分隔
    clients: user

降級(jí)和熔斷使用hystrix

如果重試期間，調(diào)用時(shí)間超過(guò)了 Hystrix熔斷的超時(shí)時(shí)間，便會(huì)立即熔斷，進(jìn)行FallBack

# 開(kāi)啟hystrix
feign.hystrix.enabled: true 
# hystrix的超時(shí)時(shí)間 時(shí)間設(shè)置需要根據(jù)實(shí)際業(yè)務(wù)場(chǎng)景計(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ù)降級(jí)");
    }
  }
}

@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ù)降級(jí)");
    }
  }
}

配置

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
  ##同一臺(tái)實(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的請(qǐng)求處理超時(shí)時(shí)間，默認(rèn)為60

Ribbon 超時(shí)時(shí)間

ribbon.ReadTimeout=1000 //處理請(qǐng)求的超時(shí)時(shí)間，默認(rèn)為1秒
ribbon.ConnectTimeout=1000 //連接建立的超時(shí)時(shí)長(zhǎng)，默認(rèn)1秒

Hystrix 超時(shí)時(shí)間

hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds=3000 #熔斷器的超時(shí)時(shí)長(zhǎng)默認(rèn)1秒

以上各種超時(shí)配置，如果都存在，則時(shí)間小的配置生效

小提示

Feign的底層是調(diào)用ribbon來(lái)實(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，需要開(kāi)啟feign.hystrix.enabled=true，這樣hystrix的相關(guān)配置才可以在Feign中生效。
Hystrix的超時(shí)時(shí)間=Ribbon的重試次數(shù)(包含首次) * (ribbon.ReadTimeout + ribbon.ConnectTimeout)
在Ribbon超時(shí)但Hystrix沒(méi)有超時(shí)的情況下，Ribbon便會(huì)采取重試機(jī)制；而重試期間如果時(shí)間超過(guò)了Hystrix的超時(shí)配置則會(huì)立即被熔斷（fallback）
關(guān)系圖