<dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-openfeign</artifactId>
  </dependency>
  
  <dependency>
  <groupId>io.github.openfeign</groupId>
  <artifactId>feign-httpclient</artifactId>
  </dependency>

 @EnableFeignClients
  public class App {  
}

@FeignClient(value="wl-service")
public interface WlFeignClient {
  @RequestMapping(method = RequestMethod.GET, value= "/stores")
  List<Store> getStores();
 
  @RequestMapping(method = RequestMethod.POST, value= "/stores/{storeId}", consumes = "application/json")
  Store update(@PathVariable("storeId") Long storeId, Store store);

hystrix:
   command:
    default:
     circuitBreaker：
      # 是否開啟熔斷(默認(rèn)true)
      enabled: true
      # 熔斷生效至少請求數(shù)量(默認(rèn)20),當(dāng)同一HystrixCommand請求數(shù)量低于此值時(shí),熔斷不會(huì)開啟
      requestVolumeThreshold：20
      # 失敗次數(shù)超過比例才開啟熔斷
      errorThresholdPercentage: 50
    # 強(qiáng)制開啟熔斷
      #forceOpen： true
      # 強(qiáng)制關(guān)閉熔斷
      #forceClosed: true
     execution:
      isolation:
       # THREAD:單獨(dú)開啟線程執(zhí)行;SEMAPHORE:在調(diào)用線程上執(zhí)行(由于我們現(xiàn)有框架中FeignUserContextInterceptor中使用了ThreadLocal,所以必須使用第二種方式)
18.       strategy: SEMAPHORE
19.       thread:
20.        # 執(zhí)行超時(shí)時(shí)間(這個(gè)時(shí)間設(shè)置很重要,因?yàn)镠ystrixCommand會(huì)包裝RibbonClient實(shí)例,那么這個(gè)時(shí)間就必須要大于ribbion timeout * retry,后面Ribbon章節(jié)會(huì)介紹)
        timeoutInMilliseconds: 2000
       semaphore:
        # 由于我們使用SEMAPHORE模式,當(dāng)每個(gè)feign并發(fā)發(fā)起請求超過此值時(shí),請求會(huì)被拒絕,直接調(diào)用降級方法,異常信息關(guān)鍵字:could not acquire a semaphore for execution
        maxConcurrentRequests: 1000
     fallback:
      isolation:
       semaphore:
        # 由于我們使用SEMAPHORE模式，當(dāng)每個(gè)feign并發(fā)發(fā)起請求調(diào)用降級方法超過此值,調(diào)用降級方法會(huì)被拒絕,直接拋出異常,異常信息關(guān)鍵字:fallback execution rejected
        maxConcurrentRequests: 1000

/**
 * 服務(wù)發(fā)現(xiàn)模式
 */
@FeignClient(name = "eureka-client",fallback = OpenFeignFallbackServiceImpl.class)//eureka-client工程的服務(wù)名稱
public interface OpenFeignService {
  @GetMapping("/name")//這里的請求路徑需要和eureka-client中的請求路徑一致
  public String test();//這里的方法名需要和eureka-client中的方法名一致
 }

/**
 * 服務(wù)發(fā)現(xiàn)-對應(yīng)后備模式的方法定義
 */
@Service
public class OpenFeignFallbackServiceImpl implements OpenFeignService{
  @Override
  public String test() {
    return "調(diào)用服務(wù)失?。?;
  }

/**
 * 聲明調(diào)用客戶端
 */
@FeignClient(name = "wl-sku", url = "${wl.url}", path = "wl", fallbackFactory = WlSkuFeignFallbackFactory.class)
public interface WlSkuFeign {

  /**
   * 基于商品編碼獲取商品銷售屬性明細(xì)
   *
   * @param relationId 參數(shù)編碼
   * @return 
   */
  @RequestMapping(method = RequestMethod.GET, path = "/item/{relation_id}")
  ResponseBody<GoodsItemDto, EmptyMeta> getItemDetail(@PathVariable("relation_id") Integer relationId);
}

/**
 * 申明后備模式
 *
 */
@Component
public class WlSkuFeignFallbackFactory implements FallbackFactory<WlSkuFeign> {
  @Override
  public WlSkuFeign create(Throwable cause) {
    return relationId -> {
      ErrorLogger.getInstance().log("商品sku getItemDetail降級服務(wù)", cause);
      return ResponseBody.fallback(cause, new Error("getItemDetail", "商品服務(wù)不可用"));
    };
  }
}

# 全局統(tǒng)一配置
hystrix:
 command:
  default:
   execution:
    isolation:
     # 更改為THREAD,其余SEMAPHORE開頭的配置可以去掉
     strategy: THREAD
     thread:
      # 默認(rèn)1000
      timeoutInMilliseconds: 2000
 threadpool:
  default:
   # 這個(gè)屬性很重要,默認(rèn)false。當(dāng)false時(shí):maximumSize=coreSize,當(dāng)true時(shí):取值Math.max(maximumSize,coreSize),所以如果想設(shè)置最大數(shù),必須設(shè)置為true
   allowMaximumSizeToDivergeFromCoreSize: false
   # 默認(rèn)10
   coreSize: 10
   maximumSize： 10
   # 默認(rèn)1M,線程池內(nèi)超過coreSize的線程允許最大空閑時(shí)間
   keepAliveTimeMinutes: 1
   # 等待隊(duì)列,默認(rèn)-1即SynchronousQueue,直接交由線程池拒絕或者等待
   maxQueueSize： -1
   # 默認(rèn)5,這個(gè)值的出現(xiàn)是因?yàn)榫€程池的queueSize無法動(dòng)態(tài)變更,所以用這個(gè)值可以動(dòng)態(tài)變更來前置檢測是否拒絕,當(dāng)maxQueueSize為-1或者0時(shí),這個(gè)檢測直接通過后交由線程池自己處理,當(dāng)maxQueueSize大于0時(shí),由queueSize<queueSizeRejectionThreshold來決定是否拒絕請求,所以如果設(shè)置maxQueueSize,最終隊(duì)列拒絕效果是以此值為準(zhǔn)
   queueSizeRejectionThreshold: 5

ribbon:
 # 默認(rèn)相同的route不重試,可以避免一些各種重試引起的問題，簡單化(但服務(wù)提供方還是應(yīng)該盡量保證冪等性)
 MaxAutoRetries: 0
 # 默認(rèn)只重試不同route一次
 MaxAutoRetriesNextServer: 1
 # 由于在前面feign文檔中已經(jīng)講到使用自己配置的HttpClient連接池,所以不需要配置ribbon連接池相關(guān)的任何屬性(因?yàn)榭紤]到每個(gè)服務(wù)提供方的不同，后期可能會(huì)更改回來使用ribbon連接池方式)
 # 默認(rèn)5000
 ReadTimeout: 5000
 # 默認(rèn)2000
 ConnectTimeout： 2000

#  NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule #配置規(guī)則 隨機(jī)
#  NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RoundRobinRule #配置規(guī)則 輪詢
#  NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RetryRule #配置規(guī)則 重試
#  NFLoadBalancerRuleClassName: com.netflix.loadbalancer.WeightedResponseTimeRule #配置規(guī)則 響應(yīng)時(shí)間權(quán)重
 NFLoadBalancerRuleClassName: com.netflix.loadbalancer.BestAvailableRule #配置規(guī)則 最空閑連接策
 # 后續(xù)可能會(huì)自定義一些負(fù)載均衡策略,通過這里來設(shè)置
 # ribbon子容器饑餓加載,避免偶爾因?yàn)榉?wù)重啟后第一次發(fā)起請求時(shí)延遲加載耗時(shí)造成fallback,但是會(huì)增加系統(tǒng)啟動(dòng)時(shí)間(新版才支持)
 eager-load:
  enabled: true
  clients:
   - a
   - b
   - c

#一個(gè)客戶端遠(yuǎn)程多個(gè)微服務(wù)，可針對單個(gè)微服務(wù)做特殊配置
# ribbon客戶端名稱(即feign客戶端名稱)
<clientName>:
 ribbon:
  listOfServers: www.baidu.com
  xxx: xxx

@Component
public class WlFeignFallback implements WlFeign {
@Override
public ResponseBody<List<Object>, EmptyMeta> getTest() {
return ResponseBody.fail(new Error("xx", "xx"));
 }
}

/**
 * feign全局配置
 *
 * @Configuration 加上為全局，不加為自定義
 */
@Configuration
public class FeignConfiguration {
  /**
   * feign日志
   */
  @Profile({"self", "local", "dev"})
  @Bean
  public Logger.Level level() {
    return Logger.Level.FULL;
  }

  /**
   * http請求時(shí)長,最好小于hystrix時(shí)長
   */
  @Bean
  public Request.Options options() {
    return new Request.Options(2000, 3500);
  }

  /**
   * 使用默認(rèn)的不重試機(jī)制,單獨(dú)feign有特殊需求單獨(dú)配置
   */
  public Retryer retryer() {
    // 最小重試間隔,最大重試間隔,最多嘗試次數(shù)(包括第一次)
    return new Retryer.Default(100L, 500L, 2);
  }

// 顯示指定方法
 @RequestMapping(method = RequestMethod.POST)

// 方式1:使用Map傳輸
@RequestMapping(path="xxx", method=GET)
ResponseBody<T> test(@RequestParam Map<String, Object> map) {
}
// 方式2:獨(dú)立設(shè)置param
@RequestMapping(path="xxx", method=GET)
ResponseBody<T> test(@RequestParam("aaa") String aa, @RequestParam("bb") int bb) {
}

// 如果接口返回類型是text/html,必須用string接受，然后手動(dòng)反序列化,如果是applicatin/json,則可以直接用對象接受
@RequestMapping(path="xxx", method=POST, consumes=MediaType.APPLICATION_FORM_URLENCODED_VALUE)
public String test(@RequestBody MultiValueMap<String, String> map) {
}
@RequestMapping(path="xxx", method=POST, consumes=MediaType.APPLICATION_FORM_URLENCODED_VALUE)
public RequestBody test(String content) {
}

#ribbon超時(shí)配置為2000，請求超時(shí)后，該實(shí)例會(huì)重試1次，更新實(shí)例會(huì)重試1次。
service-hi:
ribbon:
ReadTimeout: 2000
ConnectTimeout: 1000
MaxAutoRetries: 1
MaxAutoRetriesNextServer: 1

hystrix:
command:
default:
execution:
timeout:
enabled: true
isolation:
thread:
timeoutInMilliseconds: 8000

<!-- 使用Apache HttpClient替換Feign原生httpclient -->
    <dependency>
      <groupId>org.apache.httpcomponents</groupId>
      <artifactId>httpclient</artifactId>
    </dependency>
    <dependency>
      <groupId>com.netflix.feign</groupId>
      <artifactId>feign-httpclient</artifactId>
      <version>${feign-httpclient}</version>
    </dependency>

@Bean(destroyMethod = "close")
public CloseableHttpClient httpClient() {
  // 最終存活時(shí)間還需要看服務(wù)端的keep-alive設(shè)置,和空閑時(shí)間以及間歇的validate是否通過
  PoolingHttpClientConnectionManager pool = new PoolingHttpClientConnectionManager(30, TimeUnit.SECONDS);
  pool.setMaxTotal(2000);
  // 目前只有一個(gè)路由,默認(rèn)等于最大值,根據(jù)業(yè)務(wù)并發(fā)量設(shè)置
  pool.setDefaultMaxPerRoute(2000);
  // 檢查非活動(dòng)連接,避免服務(wù)端重啟后或者服務(wù)端keep-alive過期主動(dòng)關(guān)閉連接造成失效,對于微服務(wù)場景可能還比較普遍,但受限HTTP設(shè)計(jì)理念,這也并發(fā)完全可靠,使用re-try/re-execute機(jī)制來彌補(bǔ),考慮到可能很多Niginx配置為5秒keep-alive
  // TODO 這個(gè)值還待商榷
  pool.setValidateAfterInactivity(5 * 1000);
  return HttpClients.custom()
    .setConnectionManager(pool)
    // 連接空閑10s就回收,這個(gè)會(huì)啟動(dòng)獨(dú)立線程檢測,所以必須聲明destroy方法來關(guān)閉獨(dú)立線程
    .evictIdleConnections(10, TimeUnit.SECONDS)
    // 建立連接時(shí)間和從連接池獲取連接時(shí)間,以及數(shù)據(jù)傳輸時(shí)間
    .setDefaultRequestConfig(RequestConfig.custom()
          // http建立連接超時(shí)時(shí)間
          .setConnectTimeout(1000)
          // 從連接池獲取連接超時(shí)時(shí)間
          .setConnectionRequestTimeout(3000)
          // socket超時(shí)時(shí)間
          .setSocketTimeout(10000)
          .build())
        // 自定義重試機(jī)制
    .setRetryHandler((exception, executionCount, context) -> {
          // 目前只允許重試一次
          if (executionCount > 1) {
            return false;
          }
          // 如果是服務(wù)端主動(dòng)關(guān)閉連接的,數(shù)據(jù)并沒有被服務(wù)端接受,可以重試
          if (exception instanceof NoHttpResponseException) {
            return true;
          }
          // 不要重試SSL握手異常
          if (exception instanceof SSLHandshakeException) {
            return false;
          }
          // 超時(shí)
          if (exception instanceof InterruptedIOException) {
            return false;
          }
          // 目標(biāo)服務(wù)器不可達(dá)
          if (exception instanceof UnknownHostException) {
            return false;
          }
          // SSL握手異常
          if (exception instanceof SSLException) {
            return false;
          }
          HttpClientContext clientContext = HttpClientContext.adapt(context);
          HttpRequest request = clientContext.getRequest();
          String get = "GET";
          // GET方法是冪等的,可以重試
          if (request.getRequestLine().getMethod().equalsIgnoreCase(get)) {
            return true;
          }
          return false;
        })
    // 默認(rèn)的ConnectionKeepAliveStrategy就是動(dòng)態(tài)根據(jù)keep-alive計(jì)算的
    .build();
  }