programing

스프링 부트 + 유레카 서버 + 하이스트릭스(터빈 포함): 빈 터빈.스트림

yellowcard 2023. 6. 19. 21:21

스프링 부트 + 유레카 서버 + 하이스트릭스(터빈 포함): 빈 터빈.스트림

Spring Boot(Spring Cloud 사용) + Eureka Server + Hystrix Dashboard 및 Turvin 스트림을 실행하려고 하는데 문제가 발생하여 지금까지 해결책을 찾을 수 없었습니다.Spring Boot 1.2.1.REASE 및 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

유레카 서버는 정상적으로 실행되고 있습니다. 유레카 서버 대시보드에서 등록된 인스턴스를 볼 수 있습니다. 또한 사용할 수 있습니다.LoadBalancerID를 사용하여 등록된 인스턴스로 URL을 가져옵니다.아직까지는 모든 것이 괜찮습니다.

몇 가지 사례가 있습니다.@EnableHystrix주석 및 사용@HystrixCommandHystrix에서 모니터링해야 하는 방법을 정의합니다.단일 인스턴스의 hystrix.stream에 URL을 전달하면 문제 없이 실행되는 것을 볼 수 있습니다.

또한 터빈 서버를 별도로 보유하고 있습니다. 복잡한 서버는 아닙니다.

@EnableAutoConfiguration
@EnableTurbine
@Configuration
@EnableDiscoveryClient
class Application {

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

여기에서 찾을 수 있습니다.build.gradle터빈 서버 인스턴스의 경우 - 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/

이러한 인스턴스를 순서대로 실행한 후:

유레카 서버
터빈 서버
클라이언트 인스턴스 검색,

eureka 서버에 등록된 두 번째 및 세 번째 인스턴스가 있습니다. 터빈 서버 로그에 따르면 위에 하나의 인스턴스가 있습니다.

[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},"latencyTotal_mean":0,"latencyTotal":{"0":0,"25":0,"50":0,"75":0,"90":0,"95":0,"99":0,"99.5":0,"100":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","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},"latencyTotal_mean":0,"latencyTotal":{"0":0,"25":0,"50":0,"75":0,"90":0,"95":0,"99":0,"99.5":0,"100":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":"HystrixThreadPool","name":"PdfController","currentTime":1423223614259,"currentActiveCount":0,"currentCompletedTaskCount":4,"currentCorePoolSize":10,"currentLargestPoolSize":4,"currentMaximumPoolSize":10,"currentPoolSize":4,"currentQueueSize":0,"currentTaskCount":4,"rollingCountThreadsExecuted":0,"rollingMaxActiveThreads":0,"propertyValue_queueSizeRejectionThreshold":5,"propertyValue_metricsRollingStatisticalWindowInMilliseconds":10000,"reportingHosts":1}

그러나 turvin.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,"name":"meta","type":"meta","timestamp":1423223010935}

: ping
data: {"reportingHostsLast10Seconds":0,"name":"meta","type":"meta","timestamp":1423223013936}

: ping
data: {"reportingHostsLast10Seconds":0,"name":"meta","type":"meta","timestamp":1423223017936}

: ping
data: {"reportingHostsLast10Seconds":0,"name":"meta","type":"meta","timestamp":1423223020937}

: ping
: ping
data: {"reportingHostsLast10Seconds":0,"name":"meta","type":"meta","timestamp":1423223024937}

: ping
data: {"reportingHostsLast10Seconds":0,"name":"meta","type":"meta","timestamp":1423223028938}

: ping
data: {"reportingHostsLast10Seconds":0,"name":"meta","type":"meta","timestamp":1423223032938}

: ping
: ping
data: {"reportingHostsLast10Seconds":0,"name":"meta","type":"meta","timestamp":1423223036938}

: ping
data: {"reportingHostsLast10Seconds":0,"name":"meta","type":"meta","timestamp":1423223039939}

: ping
data: {"reportingHostsLast10Seconds":0,"name":"meta","type":"meta","timestamp":1423223043939}

: ping
data: {"reportingHostsLast10Seconds":0,"name":"meta","type":"meta","timestamp":1423223046940}

: ping
data: {"reportingHostsLast10Seconds":0,"name":"meta","type":"meta","timestamp":1423223050940}

: ping
: ping
data: {"reportingHostsLast10Seconds":0,"name":"meta","type":"meta","timestamp":1423223054941}

제 질문은: 설정 및 실행 과정에서 누락된 부분이 있습니까?이전에는 단일 인스턴스에 유레카와 터빈 서버를 설치하여 이를 관리하려고 했지만, 터빈은 적절한 애플리케이션 이름을 사용하여 유레카에서 등록된 애플리케이션을 찾지 못했습니다.유레카와 터빈을 분리하여 진행하였으나 여전히 제대로 작동하지 않습니다.

어떤 제안이든 감사하겠습니다.더 많은 정보가 필요하시면, 중요한 것을 놓칠 수도 있으니 말씀해 주십시오.

업데이트 20150209

데이브의 제안에 따라 나는 작은 변화를 적용했습니다.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/

하지만 터빈.스트림이 작동하지는 않습니다.터빈 서버가 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.stream터빈 서버도 마찬가지입니다.의 의전류.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.appConfigID별로 hystrix 클라이언트에 대한 정보를 저장합니다.터빈 서버에 다른 클라이언트를 추가하려면 이전 인스턴스 ID와 구분된 다른 인스턴스 ID, 코마를 입력하면 됩니다.그리고 그것이 모두입니다 여러분 :)

클러스터에 대한 구성을 추가하는 경우(예:

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

터빈은 "클러스터" 이름(응용 프로그램 집합의 집계 키)을 구성하는 방법을 알아야 합니다.으로 앱 이름을 을 사용할 수 .clusterNameExpressionURL에 를 들어, "URL"과 같은 파라미터를 사용해야 합니다./turbine.stream?cluster=CUSTOMERS(대문자 앱 이름).

저의 경우 터빈 앱을 테스트하기 위한 클라이언트로 :7979/mock.stream을 사용했습니다.터빈은 이벤트 시간(timeOfEvent)을 확인하여 현재 날짜 시간 이벤트만 표시합니다.

다음을 사용하여 끌 수 있습니다.

터빈InstanceMonitor.eventStream.skipLineLogic.enabled = false

언급URL : https://stackoverflow.com/questions/28365202/spring-boot-eureka-server-hystrix-with-turbine-empty-turbine-stream

'programing' 카테고리의 다른 글

비동기 하위 수집 데이터를 기반으로 한 VueJS 목록 정렬 (0)	2023.06.19
Excel의 워크시트 암호 보호 작동 방식 (0)	2023.06.19
SQL Server 쿼리를 사용하여 날짜가 30일보다 오래된 행 삭제 (0)	2023.06.19
터미널의 Git commit이 VIM을 열지만 터미널로 돌아갈 수 없습니다. (0)	2023.06.19
django의 model.save()가 full_clean()을 호출하지 않는 이유는 무엇입니까? (0)	2023.06.09

현재글스프링 부트 + 유레카 서버 + 하이스트릭스(터빈 포함): 빈 터빈.스트림

각종 프로그래밍 정보를 다루는 블로그입니다.

reactjs, MongoDB, C, bash, sql-server, jQuery, oracle, Python, MySQL, Excel, ASP.NET, spring-boot, powershell, MariaDB, JSON, android, WordPress, AngularJS, git, Ajax,

Today :
Yesterday :

yellowcard

스프링 부트 + 유레카 서버 + 하이스트릭스(터빈 포함): 빈 터빈.스트림

스프링 부트 + 유레카 서버 + 하이스트릭스(터빈 포함): 빈 터빈.스트림

업데이트 20150209

해결책

'programing' 카테고리의 다른 글

'programing'의 다른글

티스토리툴바

« 2024/11 »
일	월	화	수	목	금	토
					1	2
3	4	5	6	7	8	9
10	11	12	13	14	15	16
17	18	19	20	21	22	23
24	25	26	27	28	29	30

스프링 부트 + 유레카 서버 + 하이스트릭스(터빈 포함): 빈 터빈.스트림

스프링 부트 + 유레카 서버 + 하이스트릭스(터빈 포함): 빈 터빈.스트림

업데이트 20150209

해결책

'programing' 카테고리의 다른 글

'programing'의 다른글

관련글

티스토리툴바