8.11. Hystrix
8.11.1. 개요
Camel 2.18부터 사용 가능합니다.
Hystrix 패턴을 사용하면 애플리케이션이 Camel 경로에서 회로 차단기를 제공할 수 있는 networkshistrix와 통합할 수 있습니다. Hystrix는 대기 시간 및 내결함성 라이브러리입니다.
- 원격 시스템, 서비스 및 타사 라이브러리에 대한 액세스 지점을 분리
- 계단식 중지 실패
- 오류가 발생할 수 있는 복잡한 분산 시스템에서 탄력성 활성화
maven을 사용하는 경우 pom.xml 파일에 다음 종속성을 추가하여 Hystrix를 사용합니다.
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-hystrix</artifactId>
<version>x.x.x</version>
<!-- Specify the same version as your Camel core version. -->
</dependency>8.11.2. Java DSL 예
다음은 인라인 대체 경로로 다시 대체하여 느린 작업으로부터 보호하는 Hystrix 엔드포인트를 보여주는 예입니다. 기본적으로 시간 초과 요청은 1000ms 이므로 HTTP 끝점이 성공할 수 있어야 합니다.
from("direct:start")
.hystrix()
.to("http://fooservice.com/slow")
.onFallback()
.transform().constant("Fallback message")
.end()
.to("mock:result");8.11.3. XML 구성 예
다음은 동일한 예이지만 XML에서는 다음과 같습니다.
<camelContext xmlns="http://camel.apache.org/schema/spring">
<route>
<from uri="direct:start"/>
<hystrix>
<to uri="http://fooservice.com/slow"/>
<onFallback>
<transform>
<constant>Fallback message</constant>
</transform>
</onFallback>
</hystrix>
<to uri="mock:result"/>
</route>
</camelContext>8.11.4. Hystrix 대체 기능 사용
onFallback() 메서드는 메시지를 변환하거나 빈을 호출하거나 폴백으로 다른 것을 호출할 수 있는 로컬 처리를 위한 것입니다. 네트워크를 통해 외부 서비스를 호출해야 하는 경우 첫 번째 명령 개체를 고갈하지 않도록 자체 스레드 풀을 사용하는 독립적인 HystrixCommand 개체에서 실행되는 onFallbackViaNetwork() 메서드를 사용해야 합니다.
8.11.5. Hystrix 구성 예
Hystrix에는 다음 섹션에 나열된 많은 옵션이 있습니다. 아래 예제에서는 상태가 이동될 때 다시 요청을 시도하기 전에 회로 차단기가 5초(기본값)가 아닌 10초 동안 실행 타임아웃을 설정하는 데 필요한 Java DSL을 보여줍니다.
from("direct:start")
.hystrix()
.hystrixConfiguration()
.executionTimeoutInMilliseconds(5000).circuitBreakerSleepWindowInMilliseconds(10000)
.end()
.to("http://fooservice.com/slow")
.onFallback()
.transform().constant("Fallback message")
.end()
.to("mock:result");다음은 동일한 예이지만 XML에서는 다음과 같습니다.
<camelContext xmlns="http://camel.apache.org/schema/spring">
<camelContext xmlns="http://camel.apache.org/schema/spring">
<route>
<from uri="direct:start"/>
<hystrix>
<hystrixConfiguration executionTimeoutInMilliseconds="5000" circuitBreakerSleepWindowInMilliseconds="10000"/>
<to uri="http://fooservice.com/slow"/>
<onFallback>
<transform>
<constant>Fallback message</constant>
</transform>
</onFallback>
</hystrix>
<to uri="mock:result"/>
</route>
</camelContext>You can also configure Hystrix globally and then refer to that configuration. For example:
<camelContext xmlns="http://camel.apache.org/schema/spring">
<!-- This is a shared config that you can refer to from all Hystrix patterns. -->
<hystrixConfiguration id="sharedConfig" executionTimeoutInMilliseconds="5000" circuitBreakerSleepWindowInMilliseconds="10000"/>
<route>
<from uri="direct:start"/>
<hystrix hystrixConfigurationRef="sharedConfig">
<to uri="http://fooservice.com/slow"/>
<onFallback>
<transform>
<constant>Fallback message</constant>
</transform>
</onFallback>
</hystrix>
<to uri="mock:result"/>
</route>
</camelContext>8.11.6. 옵션
thshystrix 구성 요소는 다음 옵션을 지원합니다. Hystrix는 기본값을 제공합니다.
| 이름 | 기본값 | 유형 | 설명 |
|---|---|---|---|
|
|
| 부울 | 회로 차단기가 상태를 추적하고 쇼크 요청을 이동하는 경우 단락 요청을 사용하는지 여부를 결정합니다. |
|
|
| 정수 | 회로가 열린 상태로 이동해야 하는 오류 백분율을 설정하고 폴백 논리에 대한 쇼트 서킷 요청을 시작합니다. |
|
|
| 부울 | true 값은 회로 차단기가 오류 백분율에 관계없이 요청을 허용하는 closed 상태로 강제 적용합니다. |
|
|
| 부울 | true 값은 회로 차단기가 모든 요청을 거부하는 열린(트립됨) 상태로 강제 적용합니다. |
|
|
| 정수 | 회로를 이동할 롤링 창에서 최소 요청 수를 설정합니다. |
|
|
| 정수 | 회로를 추적한 후 요청을 거부한 후 시간을 설정합니다. 이 시간이 지나면 회로가 다시 종료되어야 하는지를 요청 시도가 허용됩니다. |
|
| 노드 ID | 문자열 | Hystrix 명령을 식별합니다. 이 옵션을 구성할 수 없습니다. 이 옵션은 항상 명령을 고유하게 만드는 노드 ID입니다. |
|
|
| 정수 |
코어 thread-pool 크기를 설정합니다. 동시에 실행할 수 있는 |
|
|
| 정수 |
|
|
|
| 문자열 |
이러한 격리 전략 중 |
|
|
| 부울 |
시간 초과가 발생할 때 |
|
|
| 정수 | 실행 완료를 위해 시간 초과를 밀리초 단위로 설정합니다. |
|
|
| 부울 |
|
|
|
| 부울 |
hy |
|
|
| 정수 |
|
|
|
| 문자열 | 통계 및 회로 차단기 속성의 상관 관계를 유지하는 데 사용되는 Hystrix 그룹을 식별합니다. |
|
|
| 정수 | 연결 유지 시간을 분 단위로 설정합니다. |
|
|
| 정수 |
|
|
|
| 정수 | 상태 스냅샷을 사용하도록 허용하는 사이의 대기 시간(밀리초)을 설정합니다. 상태 스냅샷은 성공 및 오류 백분율을 계산하고 회로 차단기 상태에 영향을 미칩니다. |
|
|
| 정수 | 버킷당 보관되는 최대 실행 횟수를 설정합니다. If more executions occur during the time they will wrap and start over-writing at the beginning of the bucket. |
|
|
| 부울 | 실행 대기 시간을 추적해야 하는지 여부를 나타냅니다. 대기 시간은 백분율로 계산됩니다. false 값은 요약 통계(mean, percentiles)가 -1로 반환됩니다. |
|
|
| 정수 |
|
|
|
| 정수 | 밀리초 단위로 백분위 계산을 허용하도록 실행 시간이 유지되는 롤링 창의 기간을 설정합니다. |
|
|
| 정수 | 롤링 통계 창이 분할되는 버킷 수를 설정합니다. |
|
|
| 정수 |
이 옵션과 다음 옵션은 |
|
|
| 정수 |
큐 크기 거부 임계값 - Cryostat |
|
|
| 부울 |
|
|
|
| 문자열 | 이 명령을 실행해야 하는 thread-pool을 정의합니다. 기본적으로 이 키는 그룹 키와 동일한 키를 사용합니다. |
|
|
| 정수 | 롤링 통계 창이 분할되는 버킷 수를 설정합니다. |
|
|
| 정수 | 통계 롤링 창의 기간을 밀리초 단위로 설정합니다. 스레드 풀에 대한 메트릭이 유지되는 시간입니다. |
