分类导航
程序笔记程序问答

Spring Boot + Eureka Server +带涡轮的Hystrix：空turbo.stream

程序问答   发布时间：2022-06-02  发布网站：大佬教程  code.js-code.com
大佬教程收集整理的这篇文章主要介绍了Spring Boot + Eureka Server +带涡轮的Hystrix：空turbo.stream，大佬教程大佬觉得挺不错的，现在分享给大家，也给大家做个参考。

如何解决Spring Boot + Eureka Server +带涡轮的HyStrix：空turbo.stream？

开发过程中遇到Spring Boot + Eureka Server +带涡轮的HyStrix：空turbo.stream的问题如何解决？下面主要结合日常开发的经验，给出你关于Spring Boot + Eureka Server +带涡轮的HyStrix：空turbo.stream的解决方法建议，希望对你解决Spring Boot + Eureka Server +带涡轮的HyStrix：空turbo.stream有所启发或帮助；

如果为群集添加一些配置，例如，它对我有用

turbine:
  appConfig: customers,stores
  clusternameExpression: new String('default')

涡轮必须知道如何构造“集群”名称（应用程序集合的聚合密钥）。默认值为使用应用程序名称，因此，如果未设置，则clusternameExpression需要在流URL中使用查询参数，例如/turbine.stream?cluster=CUSTOMERS（大写的应用程序名称）。

解决方法

我正在尝试运行Spring Boot（带有Spring Cloud）+ Eureka Server +
HyStrix仪表板和Turbine流，但是遇到一个问题，到目前为止我找不到任何解决方案。我使用Spring Boot 1.2.1.RELEASE
和Spring Cloud 1.0.0.RC2 。这是我所拥有的：

第一个实例正在运行Eureka服务器和HyStrix仪表板：

@Configuration
@EnableAutoConfiguration
@EnableEurekaServer
@EnableHyStrixDashboard
@EnableDiscoveryClient
class Application {

    public static void main(String[] args) {
        SpringApplication.run Application,args
    }
}

在这里您可以找到build.gradle该实例-https:
//gist.github.com/wololock/570272ad7cf2d14a4d3c

尤里卡服务器运行正常，我可以在尤里卡服务器仪表板上看到注册的实例，我也可以LoadBalancer使用其ID获取注册实例的URL。到目前为止，一切正常。

我有一些使用@EnableHyStrix批注运行的实例，@HyStrixCommand用于定义HyStrix必须监视的方法。当我将单个实例的hyStrix.stream的URL传递到HyStrix仪表板时，我可以看到它运行正常。

我也有单独的Turbine服务器，并不复杂：

@EnableAutoConfiguration
@EnableTurbine
@Configuration
@EnableDiscoveryClient
class Application {

    public static void main(String[] args) {
        SpringApplication.run Application,args
    }
}

在这里您可以找到build.gradleTurbine服务器实例-https:
//gist.github.com/wololock/ff0d855b8a890232851e

它使用非常简单的配置，主要是在示例涡轮应用程序提供的配置基础上构建-https: //github.com/spring-cloud-
samples/turbine

info:
  component: Turbine

endpoints:
  restart:
    enabled: true
  shutdown:
    enabled: true

turbine:
  appConfig: pdf-creator-service

InstanceDiscovery:
  impl: io.spring.platform.netflix.turbine.EureKainstanceDiscovery

server:
  port: 8989

management:
  port: 8990

eureka:
  instance:
    leaseRenewalIntervalInSeconds: 10
  client:
    serviceUrl:
      defaultZone: ${vcap.services.${PREFIX:}eureka.credentialS.Uri:http://user:password@localhost:8761}/eureka/

按顺序运行这些实例后：

  1. 尤里卡服务器
  2. 涡轮服务器
  3. 发现客户端实例，

我在eureka服务器中注册了第2个和第3个实例，涡轮服务器日志显示，有一个实例：

[2015-02-06 12:35:04.162] boot - 20495  INFO [Timer-0] --- EureKainstanceDiscovery: Fetching instance list for apps: [pdf-creator-service]
[2015-02-06 12:35:04.162] boot - 20495  INFO [Timer-0] --- EureKainstanceDiscovery: Fetching instances for app: pdf-creator-service
[2015-02-06 12:35:04.162] boot - 20495  INFO [Timer-0] --- EureKainstanceDiscovery: Received instance list for app: pdf-creator-service = 1
[2015-02-06 12:35:04.162] boot - 20495  INFO [Timer-0] --- InstanceObservable: Retrieved hosts from InstanceDiscovery: 1
[2015-02-06 12:35:04.162] boot - 20495  INFO [Timer-0] --- InstanceObservable: Found hosts that have been previously terminated: 0
[2015-02-06 12:35:04.162] boot - 20495  INFO [Timer-0] --- InstanceObservable: Hosts up:1,hosts down: 0
[2015-02-06 12:36:04.162] boot - 20495  INFO [Timer-0] --- EureKainstanceDiscovery: Fetching instance list for apps: [pdf-creator-service]
[2015-02-06 12:36:04.162] boot - 20495  INFO [Timer-0] --- EureKainstanceDiscovery: Fetching instances for app: pdf-creator-service
[2015-02-06 12:36:04.162] boot - 20495  INFO [Timer-0] --- EureKainstanceDiscovery: Received instance list for app: pdf-creator-service = 1
[2015-02-06 12:36:04.162] boot - 20495  INFO [Timer-0] --- InstanceObservable: Retrieved hosts from InstanceDiscovery: 1
[2015-02-06 12:36:04.162] boot - 20495  INFO [Timer-0] --- InstanceObservable: Found hosts that have been previously terminated: 0
[2015-02-06 12:36:04.162] boot - 20495  INFO [Timer-0] --- InstanceObservable: Hosts up:1,hosts down: 0

从单个实例调用hyStrix.stream有效，例如curl http://localhost:8885/hyStrix.stream返回：

data: {"type":"HyStrixCommand","name":"post","group":"PdfController","currentTime":1423223614259,"isCircuitBreakerOpen":false,"errorPercentage":0,"errorCount":0,"requestCount":0,"rollingCountCollapsedrequests":0,"rollingCountexceptionsThrown":0,"rollingCountFailure":0,"rollingCountfallBACkFailure":0,"rollingCountfallBACkRejection":0,"rollingCountfallBACksuccess":0,"rollingCountResponsesFromCache":0,"rollingCountSemaphoreRejected":0,"rollingCountShortCircuited":0,"rollingCountsuccess":0,"rollingCountThreadPoolRejected":0,"rollingCountTimeout":0,"currentConcurrentexecutionCount":0,"latencyExecute_mean":0,"latencyExecute":{"0":0,"25":0,"50":0,"75":0,"90":0,"95":0,"99":0,"99.5":0,"100":0},"latency@R_309_10586@l_mean":0,"latency@R_309_10586@l":{"0":0,"propertyValue_circuitBreakerrequestVolumeThreshold":20,"propertyValue_circuitBreakerSleepWindowInMilliseconds":5000,"propertyValue_circuitBreakerErrorThresholdPercentage":50,"propertyValue_circuitBreakerForceOpen":false,"propertyValue_circuitBreakerForceClosed":false,"propertyValue_circuitBreakerEnabled":true,"propertyValue_executionisolationStrategy":"THREAD","propertyValue_executionisolationThreadTimeoutInMilliseconds":8000,"propertyValue_executionisolationThreadInterruptOnTimeout":true,"propertyValue_executionisolationThreadPoolKeyOverride":null,"propertyValue_executionisolationSemaphoreMaxConcurrentrequests":10,"propertyValue_fallBACkisolationSemaphoreMaxConcurrentrequests":10,"propertyValue_metricsRollingStatisticalWindowInMilliseconds":10000,"propertyValue_requestCacheEnabled":true,"propertyValue_requestLogEnabled":true,"reporTingHosts":1}

data: {"type":"HyStrixCommand","name":"generate","group":"WkHtmlToPdfGenerator","reporTingHosts":1}

data: {"type":"HyStrixThreadPool","name":"PdfController","currentActiveCount":0,"currentCompletedTaskCount":4,"currentCorePoolSize":10,"currentLargestPoolSize":4,"currentMaximumPoolSize":10,"currentPoolSize":4,"currentQueueSize":0,"currentTaskCount":4,"rollingCountThreadsExecuted":0,"rollingMaxActiveThreads":0,"propertyValue_queueSizeRejectionThreshold":5,"reporTingHosts":1}

但是，当我将turbo.stream附加到hyStrix仪表板时，什么也没得到。日志说：

[2015-02-06 12:42:48.922] boot - 24816  INFO [Timer-0] --- EureKainstanceDiscovery: Received instance list for app: pdf-creator-service = 1
[2015-02-06 12:42:48.922] boot - 24816  INFO [Timer-0] --- InstanceObservable: Retrieved hosts from InstanceDiscovery: 1
[2015-02-06 12:42:48.922] boot - 24816  INFO [Timer-0] --- InstanceObservable: Found hosts that have been previously terminated: 0
[2015-02-06 12:42:48.922] boot - 24816  INFO [Timer-0] --- InstanceObservable: Hosts up:1,hosts down: 0
[2015-02-06 12:43:26.237] boot - 24816  INFO [XNIO-2 task-4] --- TurbinestreamServlet: FilterCriteria: []
[2015-02-06 12:43:26.237] boot - 24816  INFO [XNIO-2 task-4] --- TurbinestreamServlet: StatsType filters: []
[2015-02-06 12:43:26.237] boot - 24816  INFO [XNIO-2 task-4] --- TurbinestreamingConnection: Relevance config: []
[2015-02-06 12:43:26.237] boot - 24816  INFO [XNIO-2 task-4] --- TurbinestreamingConnection: Relevance metrics config: {}
[2015-02-06 12:43:26.237] boot - 24816  INFO [XNIO-2 task-4] --- ClusterMonitor: Registering event handler for cluster monitor: StreamingHandler_f1308dda-58c5-47a5-b1e2-5a0bea32226b
[2015-02-06 12:43:26.237] boot - 24816  INFO [XNIO-2 task-4] --- TurbineDataDispatcher:

Just added and starTing handler tuple: StreamingHandler_f1308dda-58c5-47a5-b1e2-5a0bea32226b
[2015-02-06 12:43:26.238] boot - 24816  INFO [XNIO-2 task-4] --- AggDataFromCluster: Per handler dispacher started for: StreamingHandler_f1308dda-58c5-47a5-b1e2-5a0bea32226b
[2015-02-06 12:43:26.238] boot - 24816  INFO [XNIO-2 task-4] --- ClusterMonitor: All event handlers for cluster monitor: [StreamingHandler_637572ab-acda-4bf4-81cd-6a658adb73eb,StreamingHandler_f1308dda-58c5-47a5-b1e2-5a0bea32226b,StaticListener_For_Aggregator,StreamingHandler_5ec12ee8-3fcd-4a6f-9006-d2a6ecc309d0,StreamingHandler_72d7b9e2-ad98-42a0-9ac3-abe4aa57cc7a]
[2015-02-06 12:43:26.238] boot - 24816  INFO [XNIO-2 task-4] --- ClusterMonitor: StarTing up the cluster monitor for default_agg

如果我这样做，curl http://localhost:8989/turbine.stream我只会得到：

: ping
data: {"reporTingHostsLast10Seconds":0,"name":"meta","type":"meta","timestamp":1423223006935}

: ping
data: {"reporTingHostsLast10Seconds":0,"timestamp":1423223010935}

: ping
data: {"reporTingHostsLast10Seconds":0,"timestamp":1423223013936}

: ping
data: {"reporTingHostsLast10Seconds":0,"timestamp":1423223017936}

: ping
data: {"reporTingHostsLast10Seconds":0,"timestamp":1423223020937}

: ping
: ping
data: {"reporTingHostsLast10Seconds":0,"timestamp":1423223024937}

: ping
data: {"reporTingHostsLast10Seconds":0,"timestamp":1423223028938}

: ping
data: {"reporTingHostsLast10Seconds":0,"timestamp":1423223032938}

: ping
: ping
data: {"reporTingHostsLast10Seconds":0,"timestamp":1423223036938}

: ping
data: {"reporTingHostsLast10Seconds":0,"timestamp":1423223039939}

: ping
data: {"reporTingHostsLast10Seconds":0,"timestamp":1423223043939}

: ping
data: {"reporTingHostsLast10Seconds":0,"timestamp":1423223046940}

: ping
data: {"reporTingHostsLast10Seconds":0,"timestamp":1423223050940}

: ping
: ping
data: {"reporTingHostsLast10Seconds":0,"timestamp":1423223054941}

我的问题是：
我在设置和运行时是否错过了一些东西？以前，我曾尝试通过在单个实例中安装eureka和涡轮服务器来管理此问题，但是在那种情况下，涡轮甚至无法使用正确的应用程序名称在eureka中找到注册的应用程序。拆分尤里卡和涡轮后，我取得了进步，但仍然无法正常工作。

如有任何建议，我将不胜感激。如果您需要更多信息，请告诉我，我可能会错过一些重要的事情。

更新20150209

根据Dave的建议，我对的application.yml文件进行了一些小的更改turbine-server。现在该文件仅包含：

info:
  component: Turbine

turbine:
  appConfig: pdf-creator-service
  clusterNameExpression: 'default'

server:
  port: 8989

management:
  port: 8990

eureka:
  instance:
    leaseRenewalIntervalInSeconds: 10
  client:
    serviceUrl:
      defaultZone: ${vcap.services.${PREFIX:}eureka.credentialS.Uri:http://user:password@localhost:8761}/eureka/

但这并不能使turbo.stream正常工作。在涡轮服务器知道eureka服务器中已注册的客户端之后，它失败并显示以下异常：

[2015-02-09 21:25:03.516] boot - 4808  INFO [Timer-0] --- EureKainstanceDiscovery: Fetching instance list for apps: [pdf-creator-service]
[2015-02-09 21:25:03.516] boot - 4808  INFO [Timer-0] --- EureKainstanceDiscovery: Fetching instances for app: pdf-creator-service
[2015-02-09 21:25:03.516] boot - 4808  INFO [Timer-0] --- EureKainstanceDiscovery: Received instance list for app: pdf-creator-service = 1
[2015-02-09 21:25:03.520] boot - 4808 ERROR [Timer-0] --- EureKainstanceDiscovery: Failed to fetch instances for app: pdf-creator-service,retrying once more
org.springframework.expression.spel.SpelEvaluationException: EL1008E:(pos 0): Property or field 'default' cAnnot be found on object of type 'com.netflix.appinfo.InstanceInfo' - maybe not public?
    at org.springframework.expression.spel.ast.PropertyOrFieldReference.readProperty(PropertyOrFieldReference.java:226)
    at org.springframework.expression.spel.ast.PropertyOrFieldReference.getValueInternal(PropertyOrFieldReference.java:93)
    at org.springframework.expression.spel.ast.PropertyOrFieldReference.getValueInternal(PropertyOrFieldReference.java:81)
    at org.springframework.expression.spel.ast.SpelNodeImpl.getValue(SpelNodeImpl.java:120)
    at org.springframework.expression.spel.standard.SpelExpression.getValue(SpelExpression.java:242)
    at org.springframework.cloud.netflix.turbine.EureKainstanceDiscovery.getClusterName(EureKainstanceDiscovery.java:183)
    at org.springframework.cloud.netflix.turbine.EureKainstanceDiscovery.marshallInstanceInfo(EureKainstanceDiscovery.java:141)
    at org.springframework.cloud.netflix.turbine.EureKainstanceDiscovery.geTinstancesForApp(EureKainstanceDiscovery.java:123)
    at org.springframework.cloud.netflix.turbine.EureKainstanceDiscovery.geTinstanceList(EureKainstanceDiscovery.java:88)
    at com.netflix.turbine.discovery.InstanceObservable.geTinstanceList(InstanceObservable.java:327)
    at com.netflix.turbine.discovery.InstanceObservable.access$500(InstanceObservable.java:66)
    at com.netflix.turbine.discovery.InstanceObservable$1.run(InstanceObservable.java:258)
    at java.util.TimerThread.mainLoop(Timer.java:555)
    at java.util.TimerThread.run(Timer.java:505)

我尝试'default'了以及default，但是结果很遗憾。

解

感谢Dave Syer找到正确的解决方案。基本上，窍门是添加了什么：

turbine:
    clusterNameExpression: new String("default")

到application.yml涡轮服务器应用程序实例文件。它可能看起来很奇怪，我不相信它会起作用，但确实可以。现在，当我调用hyStrix客户端应用程序时，我会从hyStrix.stream该应用程序以及turbine.streamTurbine服务器中获得正确的信息。我当前application.yml在涡轮服务器中的外观如下：

info:
  component: Turbine

turbine:
  clusterNameExpression: new String("default")
  appConfig: pdf-creator-service

server:
  port: 8989

management:
  port: 8990

eureka:
  instance:
    leaseRenewalIntervalInSeconds: 10
  client:
    serviceUrl:
      defaultZone: ${vcap.services.${PREFIX:}eureka.credentialS.Uri:http://user:password@localhost:8761}/eureka/

turbine.appConfig保留有关hyStrix客户端的信息（按其ID）。要将另一个客户端添加到您的涡轮服务器，您只需简单地放置另一个实例ID（以逗号分隔）即可。那就是所有的人:)

大佬总结

以上是大佬教程为你收集整理的Spring Boot + Eureka Server +带涡轮的Hystrix：空turbo.stream全部内容，希望文章能够帮你解决Spring Boot + Eureka Server +带涡轮的Hystrix：空turbo.stream所遇到的程序开发问题。

如果觉得大佬教程网站内容还不错，欢迎将大佬教程推荐给程序员好友。

本图文内容来源于网友网络收集整理提供，作为学习参考使用，版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ：384754419，请注明来意。
标签：++带涡轮的Hystrix：空turbo.streamServer
猜你在找的程序问答相关文章
其他相关热搜词更多
phpJavaPython程序员load中如何string使用参数jquery开发安装listlinuxiosandroid工具javascriptcap