Spring Cloud实战小贴士：turbine如何聚合设置了context-path的hystrix数据

management.context-path=/xxx

INFO 7812 --- [        Timer-0] c.n.t.monitor.instance.InstanceMonitor   : Url for host: http://172.15.0.18:9020/hystrix.stream default
ERROR 7812 --- [InstanceMonitor] c.n.t.monitor.instance.InstanceMonitor   : Could not initiate connection to host, giving up: [{"timestamp":1499941336284,"status":404,"error":"Not Found","message":"No message available","path":"/hystrix.stream"}]
WARN 7812 --- [InstanceMonitor] c.n.t.monitor.instance.InstanceMonitor   : Stopping InstanceMonitor for: 172.15.0.18:9020 default
com.netflix.turbine.monitor.instance.InstanceMonitor$MisconfiguredHostException: [{"timestamp":1499941336284,"status":404,"error":"Not Found","message":"No message available","path":"/hystrix.stream"}]
  at com.netflix.turbine.monitor.instance.InstanceMonitor.init(InstanceMonitor.java:318) ~[turbine-core-1.0.0.jar:na]
  at com.netflix.turbine.monitor.instance.InstanceMonitor.access$100(InstanceMonitor.java:103) ~[turbine-core-1.0.0.jar:na]
  at com.netflix.turbine.monitor.instance.InstanceMonitor$2.call(InstanceMonitor.java:235) [turbine-core-1.0.0.jar:na]
  at com.netflix.turbine.monitor.instance.InstanceMonitor$2.call(InstanceMonitor.java:229) [turbine-core-1.0.0.jar:na]
  at java.util.concurrent.FutureTask.run(FutureTask.java:266) [na:1.8.0_91]
  at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [na:1.8.0_91]
  at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [na:1.8.0_91]
  at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91]

public static InstanceUrlClosure ClusterConfigBasedUrlClosure = new InstanceUrlClosure() {
  private final DynamicStringProperty defaultUrlClosureConfig = DynamicPropertyFactory
          .getInstance().getStringProperty("turbine.instanceUrlSuffix",
              "hystrix.stream");
  private final DynamicBooleanProperty instanceInsertPort = DynamicPropertyFactory
        .getInstance().getBooleanProperty("turbine.instanceInsertPort", true);
  @Override
  public String getUrlPath(Instance host) {
    if (host.getCluster() == null) {
      throw new RuntimeException(
          "Host must have cluster name in order to use ClusterConfigBasedUrlClosure");
    }
    // find url
    String key = "turbine.instanceUrlSuffix." + host.getCluster();
    DynamicStringProperty urlClosureConfig = DynamicPropertyFactory.getInstance()
          .getStringProperty(key, null);
    String url = urlClosureConfig.get();
    if (url == null) {
      url = this.defaultUrlClosureConfig.get();
    }
    if (url == null) {
      throw new RuntimeException("Config property: "
          + urlClosureConfig.getName() + " or "
          + this.defaultUrlClosureConfig.getName() + " must be set");
    }
    // find port and scheme
    String port;
    String scheme;
    if (host.getAttributes().containsKey("securePort")) {
      port = host.getAttributes().get("securePort");
      scheme = "https";
    } else {
      port = host.getAttributes().get("port");
      scheme = "http";
    }
    if (host.getAttributes().containsKey("fusedHostPort")) {
      return String.format("%s://%s/%s", scheme, host.getAttributes().get("fusedHostPort"), url);
    }
    // determine if to insert port
    String insertPortKey = "turbine.instanceInsertPort." + host.getCluster();
    DynamicStringProperty insertPortProp = DynamicPropertyFactory.getInstance()
          .getStringProperty(insertPortKey, null);
    boolean insertPort;
    if (insertPortProp.get() == null) {
      insertPort = this.instanceInsertPort.get();
    }
    else {
      insertPort = Boolean.parseBoolean(insertPortProp.get());
    }
    // format url with port
    if (insertPort) {
      if (url.startsWith("/")) {
        url = url.substring(1);
      }
      if (port == null) {
        throw new RuntimeException(
            "Configured to use port, but port or securePort is not in host attributes");
      }
      return String.format("%s://%s:%s/%s", scheme, host.getHostname(), port, url);
    }
    //format url without port
    return scheme + "://" + host.getHostname() + url;
  }
};

turbine.instanceUrlSuffix=/xxx/hystrix.stream