HystrixCommand.Setter setter = HystrixCommand.Setter
    .withGroupKey(HystrixCommandGroupKey.Factory.asKey("strGroupCommand"))
    .andCommandKey(HystrixCommandKey.Factory.asKey("strCommand"))
    .andThreadPoolKey(HystrixThreadPoolKey.Factory.asKey("strThreadPool"));
// 配置信號量隔離
HystrixCommandProperties.Setter commandPropertiesSetter = HystrixCommandProperties.Setter().withExecutionIsolationStrategy(HystrixCommandProperties.ExecutionIsolationStrategy.SEMAPHORE);
setter.andCommandPropertiesDefaults(commandPropertiesSetter);

  @HystrixCommand(fallbackMethod = "fallbackMethod", 
      commandProperties = {
          // 設(shè)置隔離策略，THREAD 表示線程池 SEMAPHORE：信號池隔離
          @HystrixProperty(name = "execution.isolation.strategy", value = "THREAD"),
          // 當(dāng)隔離策略選擇信號池隔離的時(shí)候，用來設(shè)置信號池的大小（最大并發(fā)數(shù)）
          @HystrixProperty(name = "execution.isolation.semaphore.maxConcurrentRequests", value = "10"),
      }
  )

  <dependency>
   <groupId>org.springframework.cloud</groupId>
   <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
  </dependency>

 @HystrixCommand(fallbackMethod = "fallbackMethod")
 public String strConsumer() {
  ResponseEntity<String> result = restTemplate.getForEntity("http://cloud-eureka-client/hello", String.class);
  return result.getBody();
 }

 @HystrixCommand(fallbackMethod = "fallbackMethod", ignoreExceptions = {IllegalAccessException.class})
 public Future<String> asyncStrConsumer() {

  Future<String> asyncResult = new AsyncResult<String>() {
   @Override
   public String invoke() {
    ResponseEntity<String> result = restTemplate.getForEntity("http://cloud-eureka-client/hello", String.class);
    return result.getBody();
   }
  };
  return asyncResult;
 }

 @HystrixCommand(observableExecutionMode = ObservableExecutionMode.EAGER)
 protected Observable<String> construct() {
  ResponseEntity<String> result = restTemplate.getForEntity("http://cloud-eureka-client/hello", String.class);
  return Observable.just(result.getBody());
 }

 @HystrixCommand(observableExecutionMode = ObservableExecutionMode.LAZY)
 protected Observable<String> construct() {
  ResponseEntity<String> result = restTemplate.getForEntity("http://cloud-eureka-client/hello", String.class);
  return Observable.just(result.getBody());
 }

 @HystrixCommand(fallbackMethod = "fallbackMethod", groupKey = "strGroupCommand", commandKey = "strCommand", threadPoolKey = "strThreadPool")
 public String strConsumer(@CacheKey Long id) {
  ResponseEntity<String> result = restTemplate.getForEntity("http://cloud-eureka-client/hello", String.class);
  return result.getBody();
 }

 @CacheResult(cacheKeyMethod = "getCacheKey")
 @HystrixCommand(fallbackMethod = "fallbackMethod")
 public String strConsumer(@CacheKey Long id) {
  ResponseEntity<String> result = restTemplate.getForEntity("http://cloud-eureka-client/hello", String.class);
  return result.getBody();
 }

@RestController
public class UserConsumer {

 @Autowired
 private UserService userService;

 /**
  * 通過 id 獲取用戶接口
  *
  * @param id
  * @return
  */
 @HystrixCollapser(batchMethod = "getByIds", collapserProperties = {
   // 10ms 內(nèi)的請求合并為一次批量請求
   @HystrixProperty(name = "timerDelayInMilliseconds", value = "10"),
   // 批處理過程中是否開啟緩存
   @HystrixProperty(name = "requestCache.enabled", value = "10"),
 })
 public String getById(Long id) {
  return userService.getUserById(id);
 }

 /**
  * 通過 ids 批量獲取用戶信息接口
  *
  * @param ids id 集合
  * @return
  */
 @HystrixCommand
 public Set<String> getByIds(List<Long> ids) {
  return userService.getUserByIds(ids);
 }
}

 @HystrixCommand(fallbackMethod = "fallbackMethod", groupKey = "strGroupCommand", commandKey = "strCommand", threadPoolKey = "strThreadPool",
   commandProperties = {
     // 設(shè)置隔離策略，THREAD 表示線程池 SEMAPHORE：信號池隔離
     @HystrixProperty(name = "execution.isolation.strategy", value = "THREAD"),
     // 當(dāng)隔離策略選擇信號池隔離的時(shí)候，用來設(shè)置信號池的大?。ㄗ畲蟛l(fā)數(shù)）
     @HystrixProperty(name = "execution.isolation.semaphore.maxConcurrentRequests", value = "10"),
     // 配置命令執(zhí)行的超時(shí)時(shí)間
     @HystrixProperty(name = "execution.isolation.thread.timeoutinMilliseconds", value = "10"),
     // 是否啟用超時(shí)時(shí)間
     @HystrixProperty(name = "execution.timeout.enabled", value = "true"),
     // 執(zhí)行超時(shí)的時(shí)候是否中斷
     @HystrixProperty(name = "execution.isolation.thread.interruptOnTimeout", value = "true"),
     // 執(zhí)行被取消的時(shí)候是否中斷
     @HystrixProperty(name = "execution.isolation.thread.interruptOnCancel", value = "true"),

     // 允許回調(diào)方法執(zhí)行的最大并發(fā)數(shù)
     @HystrixProperty(name = "fallback.isolation.semaphore.maxConcurrentRequests", value = "10"),
     // 服務(wù)降級是否啟用，是否執(zhí)行回調(diào)函數(shù)
     @HystrixProperty(name = "fallback.enabled", value = "true"),

     // 是否啟用斷路器
     @HystrixProperty(name = "circuitBreaker.enabled", value = "true"),
     // 該屬性用來設(shè)置在滾動(dòng)時(shí)間窗中，斷路器熔斷的最小請求數(shù)。例如，默認(rèn)該值為 20 的時(shí)候，如果滾動(dòng)時(shí)間窗（默認(rèn)10秒）內(nèi)僅收到了19個(gè)請求， 即使這19個(gè)請求都失敗了，斷路器也不會打開。
     @HystrixProperty(name = "circuitBreaker.requestVolumeThreshold", value = "20"),
     // 該屬性用來設(shè)置在滾動(dòng)時(shí)間窗中，表示在滾動(dòng)時(shí)間窗中，在請求數(shù)量超過 circuitBreaker.requestVolumeThreshold 的情況下，如果錯(cuò)誤請求數(shù)的百分比超過50, 就把斷路器設(shè)置為 "打開" 狀態(tài)，否則就設(shè)置為 "關(guān)閉" 狀態(tài)。
     @HystrixProperty(name = "circuitBreaker.errorThresholdPercentage", value = "50"),
     // 該屬性用來設(shè)置當(dāng)斷路器打開之后的休眠時(shí)間窗。 休眠時(shí)間窗結(jié)束之后，會將斷路器置為 "半開" 狀態(tài)，嘗試熔斷的請求命令，如果依然失敗就將斷路器繼續(xù)設(shè)置為 "打開" 狀態(tài)，如果成功就設(shè)置為 "關(guān)閉" 狀態(tài)。
     @HystrixProperty(name = "circuitBreaker.sleepWindowinMilliseconds", value = "5000"),
     // 斷路器強(qiáng)制打開
     @HystrixProperty(name = "circuitBreaker.forceOpen", value = "false"),
     // 斷路器強(qiáng)制關(guān)閉
     @HystrixProperty(name = "circuitBreaker.forceClosed", value = "false"),

     // 滾動(dòng)時(shí)間窗設(shè)置，該時(shí)間用于斷路器判斷健康度時(shí)需要收集信息的持續(xù)時(shí)間
     @HystrixProperty(name = "metrics.rollingStats.timeinMilliseconds", value = "10000"),
     // 該屬性用來設(shè)置滾動(dòng)時(shí)間窗統(tǒng)計(jì)指標(biāo)信息時(shí)劃分"桶"的數(shù)量，斷路器在收集指標(biāo)信息的時(shí)候會根據(jù)設(shè)置的時(shí)間窗長度拆分成多個(gè) "桶" 來累計(jì)各度量值，每個(gè)"桶"記錄了一段時(shí)間內(nèi)的采集指標(biāo)。
     // 比如 10 秒內(nèi)拆分成 10 個(gè)"桶"收集這樣，所以 timeinMilliseconds 必須能被 numBuckets 整除。否則會拋異常
     @HystrixProperty(name = "metrics.rollingStats.numBuckets", value = "10"),
     // 該屬性用來設(shè)置對命令執(zhí)行的延遲是否使用百分位數(shù)來跟蹤和計(jì)算。如果設(shè)置為 false, 那么所有的概要統(tǒng)計(jì)都將返回 -1。
     @HystrixProperty(name = "metrics.rollingPercentile.enabled", value = "false"),
     // 該屬性用來設(shè)置百分位統(tǒng)計(jì)的滾動(dòng)窗口的持續(xù)時(shí)間，單位為毫秒。
     @HystrixProperty(name = "metrics.rollingPercentile.timeInMilliseconds", value = "60000"),
     // 該屬性用來設(shè)置百分位統(tǒng)計(jì)滾動(dòng)窗口中使用 “ 桶 ”的數(shù)量。
     @HystrixProperty(name = "metrics.rollingPercentile.numBuckets", value = "60000"),
     // 該屬性用來設(shè)置在執(zhí)行過程中每個(gè) “桶” 中保留的最大執(zhí)行次數(shù)。如果在滾動(dòng)時(shí)間窗內(nèi)發(fā)生超過該設(shè)定值的執(zhí)行次數(shù)，
     // 就從最初的位置開始重寫。例如，將該值設(shè)置為100, 滾動(dòng)窗口為10秒，若在10秒內(nèi)一個(gè) “桶 ”中發(fā)生了500次執(zhí)行，
     // 那么該 “桶” 中只保留 最后的100次執(zhí)行的統(tǒng)計(jì)。另外，增加該值的大小將會增加內(nèi)存量的消耗，并增加排序百分位數(shù)所需的計(jì)算時(shí)間。
     @HystrixProperty(name = "metrics.rollingPercentile.bucketSize", value = "100"),
     // 該屬性用來設(shè)置采集影響斷路器狀態(tài)的健康快照（請求的成功、 錯(cuò)誤百分比）的間隔等待時(shí)間。
     @HystrixProperty(name = "metrics.healthSnapshot.intervalinMilliseconds", value = "500"),

     // 是否開啟請求緩存
     @HystrixProperty(name = "requestCache.enabled", value = "true"),
     // HystrixCommand的執(zhí)行和事件是否打印日志到 HystrixRequestLog 中
     @HystrixProperty(name = "requestLog.enabled", value = "true"),

   },
   threadPoolProperties = {
     // 該參數(shù)用來設(shè)置執(zhí)行命令線程池的核心線程數(shù)，該值也就是命令執(zhí)行的最大并發(fā)量
     @HystrixProperty(name = "coreSize", value = "10"),
     // 該參數(shù)用來設(shè)置線程池的最大隊(duì)列大小。當(dāng)設(shè)置為 -1 時(shí)，線程池將使用 SynchronousQueue 實(shí)現(xiàn)的隊(duì)列，否則將使用 LinkedBlockingQueue 實(shí)現(xiàn)的隊(duì)列。
     @HystrixProperty(name = "maxQueueSize", value = "-1"),
     // 該參數(shù)用來為隊(duì)列設(shè)置拒絕閾值。 通過該參數(shù)， 即使隊(duì)列沒有達(dá)到最大值也能拒絕請求。
     // 該參數(shù)主要是對 LinkedBlockingQueue 隊(duì)列的補(bǔ)充,因?yàn)?LinkedBlockingQueue 隊(duì)列不能動(dòng)態(tài)修改它的對象大小，而通過該屬性就可以調(diào)整拒絕請求的隊(duì)列大小了。
     @HystrixProperty(name = "queueSizeRejectionThreshold", value = "5"),
   }
 )
 public String strConsumer() {
  ResponseEntity<String> result = restTemplate.getForEntity("http://cloud-eureka-client/hello", String.class);
  return result.getBody();
 }