小菜鸟

@Order(0)
public class ConfigServicePropertySourceLocator implements PropertySourceLocator {

   @Override
   @Retryable(interceptor = "configServerRetryInterceptor")
   public org.springframework.core.env.PropertySource<?> locate(
         org.springframework.core.env.Environment environment) {
      ConfigClientProperties properties = this.defaultProperties.override(environment);
      CompositePropertySource composite = new OriginTrackedCompositePropertySource(
            "configService");
      RestTemplate restTemplate = this.restTemplate == null
            ? getSecureRestTemplate(properties) : this.restTemplate;
      Exception error = null;
      String errorBody = null;
      try {
         String[] labels = new String[] { "" };
         if (StringUtils.hasText(properties.getLabel())) {
            labels = StringUtils
                  .commaDelimitedListToStringArray(properties.getLabel());
         }
         String state = ConfigClientStateHolder.getState();
         // Try all the labels until one works
         for (String label : labels) {
           // 获取远程配置，这里就是使用restTemplate访问spring.cloud.config.uri对应的配置中心server地址/{name}/{profile}/{label}
            Environment result = getRemoteEnvironment(restTemplate, properties,
                  label.trim(), state);
            if (result != null) {
               log(result);

               // result.getPropertySources() can be null if using xml
               if (result.getPropertySources() != null) {
                  for (PropertySource source : result.getPropertySources()) {
                     @SuppressWarnings("unchecked")
                     Map<String, Object> map = translateOrigins(source.getName(),
                           (Map<String, Object>) source.getSource());
                     composite.addPropertySource(
                           new OriginTrackedMapPropertySource(source.getName(),
                                 map));
                  }
               }

               if (StringUtils.hasText(result.getState())
                     || StringUtils.hasText(result.getVersion())) {
                  HashMap<String, Object> map = new HashMap<>();
                  putValue(map, "config.client.state", result.getState());
                  putValue(map, "config.client.version", result.getVersion());
                  composite.addFirstPropertySource(
                        new MapPropertySource("configClient", map));
               }
               return composite;
            }
         }
         errorBody = String.format("None of labels %s found", Arrays.toString(labels));
      }
      catch (HttpServerErrorException e) {
         error = e;
         if (MediaType.APPLICATION_JSON
               .includes(e.getResponseHeaders().getContentType())) {
            errorBody = e.getResponseBodyAsString();
         }
      }
      catch (Exception e) {
         error = e;
      }
      if (properties.isFailFast()) {
         throw new IllegalStateException(
               "Could not locate PropertySource and the fail fast property is set, failing"
                     + (errorBody == null ? "" : ": " + errorBody),
               error);
      }
      
      return null;

   }

}

// 服务分组  配置全局唯一标识服务分组的名称，在进行监控时，相同分组的服务会聚合在一起
protected final HystrixCommandGroupKey groupKey;
// 服务标识，配置全局唯一标识服务的名称，默认是类名
protected HystrixCommandKey commandKey;
// 线程池名称，相同线程池名称的线程池是同一个，如果不配置，默认是分组名，此时一个group共用一个线程池
protected HystrixThreadPoolKey threadPoolKey;
// 命令属性配置
protected HystrixCommandProperties.Setter commandPropertiesDefaults;
// 线程池配置
protected HystrixThreadPoolProperties.Setter threadPoolPropertiesDefaults;


public TestCommand(){
        super(Setter.withGroupKey(HystrixCommandGroupKey.Factory.asKey("testGroup"))
                .andCommandKey(HystrixCommandKey.Factory.asKey("command"))
                .andThreadPoolKey(HystrixThreadPoolKey.Factory.asKey("testGroupPool"))
                .andThreadPoolPropertiesDefaults(HystrixThreadPoolProperties.Setter().withCoreSize(10).withMaxQueueSize(10)));
    }

HystrixCommandProperties.Setter().withExecutionIsolationStrategy(
        HystrixCommandProperties.ExecutionIsolationStrategy.SEMAPHORE
).withExecutionIsolationSemaphoreMaxConcurrentRequests(200); // 限制200并发