ribbon url 레벨 의 시간 초과 설정
6238 단어 springcloud
ribbon 의 시간 초과 설정 은 퍼 가기 serviceId 에 따라 만 나 눌 수 있 으 며, nginx 처럼 퍼 가기 링크 마다 시간 초과 설정 을 할 수 없습니다.url 기본 ribbon 시간 초과 설정 을 실현 합 니 다.구체 적 인 사고방식 은 Ribbon ApacheHttpRequest 의 toRequest 방법 을 다시 쓰 고 설정 하 는 것 이다.
CustomRibbonApacheHttpRequest
public class CustomRibbonApacheHttpRequest extends RibbonApacheHttpRequest {
public CustomRibbonApacheHttpRequest(RibbonCommandContext context) {
super(context);
}
@Override
public HttpUriRequest toRequest(RequestConfig requestConfig) {
final RequestBuilder builder = RequestBuilder.create(this.context.getMethod());
builder.setUri(this.uri);
for (final String name : this.context.getHeaders().keySet()) {
final List values = this.context.getHeaders().get(name);
for (final String value : values) {
builder.addHeader(name, value);
}
}
for (final String name : this.context.getParams().keySet()) {
final List values = this.context.getParams().get(name);
for (final String value : values) {
builder.addParameter(name, value);
}
}
if (this.context.getRequestEntity() != null) {
final BasicHttpEntity entity;
entity = new BasicHttpEntity();
entity.setContent(this.context.getRequestEntity());
// if the entity contentLength isn't set, transfer-encoding will be set
// to chunked in org.apache.http.protocol.RequestContent. See gh-1042
if (this.context.getContentLength() != null) {
entity.setContentLength(this.context.getContentLength());
} else if ("GET".equals(this.context.getMethod())) {
entity.setContentLength(0);
}
builder.setEntity(entity);
}
customize(this.context.getRequestCustomizers(), builder);
//todo timeout
if(uri.getPath().equals("/review/timeout")){
RequestConfig.Builder configBuilder = RequestConfig.copy(builder.getConfig());
configBuilder.setConnectionRequestTimeout(30*1000);
configBuilder.setConnectTimeout(30*1000);
configBuilder.setSocketTimeout(30*1000);
builder.setConfig(configBuilder.build());
}else{
builder.setConfig(requestConfig);
}
return builder.build();
}
}
CustomHttpClientRibbonCommand
public class CustomHttpClientRibbonCommand extends HttpClientRibbonCommand {
public CustomHttpClientRibbonCommand(String commandKey, RibbonLoadBalancingHttpClient client, RibbonCommandContext context, ZuulProperties zuulProperties) {
super(commandKey, client, context, zuulProperties);
}
public CustomHttpClientRibbonCommand(String commandKey, RibbonLoadBalancingHttpClient client, RibbonCommandContext context, ZuulProperties zuulProperties, ZuulFallbackProvider zuulFallbackProvider) {
super(commandKey, client, context, zuulProperties, zuulFallbackProvider);
}
@Override
protected RibbonApacheHttpRequest createRequest() throws Exception {
RibbonApacheHttpRequest ribbonApacheHttpRequest = new CustomRibbonApacheHttpRequest(this.context);
return ribbonApacheHttpRequest;
}
}
CustomHttpClientRibbonCommandFactory
public class CustomHttpClientRibbonCommandFactory extends HttpClientRibbonCommandFactory{
private final SpringClientFactory clientFactory;
private final ZuulProperties zuulProperties;
public CustomHttpClientRibbonCommandFactory(SpringClientFactory clientFactory, ZuulProperties zuulProperties) {
super(clientFactory, zuulProperties);
this.clientFactory = clientFactory;
this.zuulProperties = zuulProperties;
}
public CustomHttpClientRibbonCommandFactory(SpringClientFactory clientFactory, ZuulProperties zuulProperties, Set fallbackProviders) {
super(clientFactory, zuulProperties, fallbackProviders);
this.clientFactory = clientFactory;
this.zuulProperties = zuulProperties;
}
@Override
public HttpClientRibbonCommand create(RibbonCommandContext context) {
ZuulFallbackProvider zuulFallbackProvider = getFallbackProvider(context.getServiceId());
final String serviceId = context.getServiceId();
final RibbonLoadBalancingHttpClient client = this.clientFactory.getClient(
serviceId, RibbonLoadBalancingHttpClient.class);
client.setLoadBalancer(this.clientFactory.getLoadBalancer(serviceId));
return new CustomHttpClientRibbonCommand(serviceId, client, context, zuulProperties, zuulFallbackProvider);
}
}
배치 하 다.
@Autowired(required = false)
private Set zuulFallbackProviders = Collections.emptySet();
@Bean
@ConditionalOnMissingBean
public RibbonCommandFactory> ribbonCommandFactory(
SpringClientFactory clientFactory, ZuulProperties zuulProperties) {
return new CustomHttpClientRibbonCommandFactory(clientFactory, zuulProperties, zuulFallbackProviders);
}
게 이 트 웨 이의 시간 초과 등급
zuul
zuul:
max:
host:
connections: 500
host:
socket-timeout-millis: 60000
connect-timeout-millis: 60000
ribbon
ribbon:
ReadTimeout: 10000
ConnectTimeout: 10000
MaxAutoRetries: 0
MaxAutoRetriesNextServer: 1
eureka:
enabled: true
hystrix
hystrix:
command:
default:
execution:
timeout:
enabled: true
isolation:
thread:
timeoutInMilliseconds: 60000
작은 매듭
게 이 트 웨 이 를 걸 으 면 3 층 의 시간 초과 시간 이 있 습 니 다. 하 나 는 zuul 의 것 이 고 하 나 는 ribbon 의 것 이 며 다른 하 나 는 Hstrix 의 것 입 니 다.Hstrix 의 시간 초과 설정, AbstractRibbon Command 같은 종 류 는 Hstrix 를 설정 한 Setter 방법 을 노출 하지 않 았 기 때문에 계승 방식 으로 확장 할 수 없습니다.따라서 ribbon 의 시간 초 과 를 사용자 정의 하려 면 이 시간 초 과 는 hystrix 보다 작 아야 합 니 다. 그렇지 않 으 면 미리 hystrix 에 의 해 시간 을 초과 하여 효 과 를 볼 수 없습니다.
이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:
Spring Cloud에서 Feign에 대한 일반적인 질문 요약1. FeignClient 인터페이스, @GettingMapping 같은 조합 메모는 사용할 수 없음 코드 예: 이쪽 @RequestMapping(value = "/simple/{id}", method = Reque...
텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.