springcloud 구성요소의 RestTemplate으로 통합된 리본에 대한 자세한 설명

이 문서에서는 springcloud가 리본을 통합하는 방법에 대해 설명합니다. 다양한 springcloud 구성 요소(feign, zuul, RestTemplate)가 리본을 다르게 통합합니다. 이 문서에서는 먼저 RestTemplate을 살펴봅니다.

RestTemplate의 클래스 다이어그램은 다음과 같습니다. code> Main ClientHttpRequestFactory

InterceptingHttpAccessor를 기반으로 ClientHttpRequest를 생성하고 를 확장합니다. HttpAccessor, 인터셉터된 InterceptingClientHttpRequest를 생성합니다. 여기서 RestTemplate이 실행될 때 통합 리본의 핵심인 인터셉터 ClientHttpRequestInterceptor가 설정됩니다. http 요청 호출 시간을 시작하면 먼저 인터셉터를 통과한 다음 실제로 http 요청을 시작합니다.

인터셉터 ClientHttpRequestInterceptor는 어떻게 설정되나요? LoadBalancerAutoConfiguration 클래스에는 다음 코드가 있습니다:

• @LoadBalanced
  @Autowired(required = false)
  private List<RestTemplate> restTemplates = Collections.emptyList();

  @LoadBalanced 주석이 추가되는 한 RestTemplate가 삽입됩니다. 스프링 재시도 구성 요소가 도입되지 않으면 다음 구성을 로드합니다. <code>HttpAccessor主要根据ClientHttpRequestFactory创建ClientHttpRequest

• InterceptingHttpAccessor扩展了HttpAccessor，创建拦截的InterceptingClientHttpRequest，这里会设置拦截器ClientHttpRequestInterceptor，这是集成ribbon的核心，当RestTemplate发起http请求调用的时候，会先经过拦截器，然后才真正发起http请求。

拦截器ClientHttpRequestInterceptor是如何被设置的呢？在LoadBalancerAutoConfiguration类中，有如下代码：

@Configuration
@ConditionalOnMissingClass("org.springframework.retry.support.RetryTemplate")
static class LoadBalancerInterceptorConfig {
    @Bean
    public LoadBalancerInterceptor ribbonInterceptor(
        LoadBalancerClient loadBalancerClient,
        LoadBalancerRequestFactory requestFactory) {
        return new LoadBalancerInterceptor(loadBalancerClient, requestFactory);
    }

    @Bean
    @ConditionalOnMissingBean
    public RestTemplateCustomizer restTemplateCustomizer(
        final LoadBalancerInterceptor loadBalancerInterceptor) {
        return new RestTemplateCustomizer() {
            @Override
            public void customize(RestTemplate restTemplate) {
                List<ClientHttpRequestInterceptor> list = new ArrayList<>(
                    restTemplate.getInterceptors());
                list.add(loadBalancerInterceptor);
                restTemplate.setInterceptors(list);
            }
        };
    }
}

只要加入注解@LoadBalanced的RestTemplate会被注入，在没有引入spring retry组件的时候，加载如下配置：

@Override
public ClientHttpResponse execute(HttpRequest request, byte[] body) throws IOException {
    if (this.iterator.hasNext()) {
        ClientHttpRequestInterceptor nextInterceptor = this.iterator.next();
        return nextInterceptor.intercept(request, body, this);
    }else {
        ClientHttpRequest delegate = requestFactory.createRequest(request.getURI(), request.getMethod());
        for (Map.Entry<String, List<String>> entry : request.getHeaders().entrySet()) {
            List<String> values = entry.getValue();
            for (String value : values) {
                delegate.getHeaders().add(entry.getKey(), value);
            }
        }
        if (body.length > 0) {
            StreamUtils.copy(body, delegate.getBody());
        }
        return delegate.execute();
    }
}

这样RestTemplate就被设置了LoadBalancerInterceptor，下面来看看整个调用过程

整个过程有点复杂，核心就是经过拦截器LoadBalancerInterceptor，通过RibbonLoadBalancerClient发起负载均衡调用。RibbonLoadBalancerClientI组合了LoadBalancer，所以具备了负载均衡的能力，也就是我们在上一篇文章解读的ribbon原理。

图中我们没有画出真正发起http请求的过程，其默认是由SimpleClientHttpRequestFactory创建，ClientHttpRequestFactory的类图如下：

从调用时序图上我们看到，开始我们调用的是InterceptingClientHttpRequestFactory来获取InterceptingClientHttpRequest,它们通过组合的方式集成了ClientHttpRequestFactory和拦截器，InterceptingClientHttpRequest发起调用的时候委托了其内部类InterceptingRequestExecution去处理，核心逻辑：

@Bean
@LoadBalanced
public RestTemplate restTemplate() {
    SimpleClientHttpRequestFactory factory  = new SimpleClientHttpRequestFactory();
    factory.setConnectTimeout(1000 * 2);//连接超时时间
    factory.setReadTimeout(1000 * 1);//读超时时间
    return new RestTemplate(factory);
}

首先会先取出拦截器集合的第一个执行，当拦截器执行完成后，会回调回来，执行else的代码，真正发起http请求，主要有两种方式实现ClientHttpRequestFactory接口：

• 一种是SimpleClientHttpRequestFactory，使用J2SE提供的方式（既java.net包提供的方式）创建底层的Http请求连接

• 一种方式是使用HttpComponentsClientHttpRequestFactory方式，底层使用HttpClient访问远程的Http服务，使用HttpClient可以配置连接池和证书等信息。

 RestTemplate默认是使用SimpleClientHttpRequestFactory，内部是调用jdk的HttpConnection，默认超时为-1，可以这样设置超时时间：

<dependency>
    <groupId>org.springframework.retry</groupId>
    <artifactId>spring-retry</artifactId>
    <version>版本号</version>
</dependency>

使用HttpComponentsClientHttpRequestFactory方式可以使用连接池(推荐) ，还可以设置重试策略(具体没有研究过)

如果想开启重试机制，我们可以引入spring的retry组件

@Configuration
@ConditionalOnClass(RetryTemplate.class)
public static class RetryAutoConfiguration {
    @Bean
    public RetryTemplate retryTemplate() {
        RetryTemplate template =  new RetryTemplate();
        template.setThrowLastExceptionOnExhausted(true);
        return template;
    }

    @Bean
    @ConditionalOnMissingBean
    public LoadBalancedRetryPolicyFactory loadBalancedRetryPolicyFactory() {
        return new LoadBalancedRetryPolicyFactory.NeverRetryFactory();
    }
}

@Configuration
@ConditionalOnClass(RetryTemplate.class)
public static class RetryInterceptorAutoConfiguration {
    @Bean
    @ConditionalOnMissingBean
    public RetryLoadBalancerInterceptor ribbonInterceptor(
        LoadBalancerClient loadBalancerClient, LoadBalancerRetryProperties properties,
        LoadBalancedRetryPolicyFactory lbRetryPolicyFactory,
        LoadBalancerRequestFactory requestFactory) {
        return new RetryLoadBalancerInterceptor(loadBalancerClient, properties,
                                                lbRetryPolicyFactory, requestFactory);
    }

    @Bean
    @ConditionalOnMissingBean
    public RestTemplateCustomizer restTemplateCustomizer(
        final RetryLoadBalancerInterceptor loadBalancerInterceptor) {
        return new RestTemplateCustomizer() {
            @Override
            public void customize(RestTemplate restTemplate) {
                List<ClientHttpRequestInterceptor> list = new ArrayList<>(
                    restTemplate.getInterceptors());
                list.add(loadBalancerInterceptor);
                restTemplate.setInterceptors(list);
            }
        };
    }
}

这样springcloud-ribbon就会加重如下配置：

@Bean
@ConditionalOnClass(name = "org.springframework.retry.support.RetryTemplate")
@ConditionalOnMissingBean
    public LoadBalancedRetryPolicyFactory loadBalancedRetryPolicyFactory(SpringClientFactory clientFactory) {
    return new RibbonLoadBalancedRetryPolicyFactory(clientFactory);
}

#最大的重试次数
ribbon.MaxAutoRetries=0
#最大重试server的个数
ribbon.MaxAutoRetriesNextServer=1
#是否开启任何异常都重试（默认在get请求下会重试，其他情况不会重试，除非设置为true）
ribbon.OkToRetryOnAllOperations=false
#指定重试的http状态码
ribbon.retryableStatusCodes=500,501

拦截器替换成RetryLoadBalancerInterceptor了，这里集成了retry组件retryTemplate。重试策略由RetryHandler接口来配置，默认实现类DefaultLoadBalancerRetryHandler,如下为默认的配置参数

rrreee

以上是对全局生效，如果加上xxx.ribbon.MaxAutoRetries=1rrreee

이런 식으로 RestTemplate이 LoadBalancerInterceptor로 설정됩니다. 전체 호출 과정 살펴보기

#🎜 🎜##🎜 🎜#
전체 프로세스는 약간 복잡합니다. 핵심은 RibbonLoadBalancerClient를 통해 LoadBalancerInterceptor를 통해 로드 밸런싱 호출을 시작하는 것입니다. RibbonLoadBalancerClientI는 LoadBalancer를 결합하여 이전 기사에서 설명한 리본 원리인 로드 밸런싱 기능을 갖습니다.

그림에는 실제로 http 요청을 시작하는 프로세스가 그려져 있지 않습니다. 기본값은 SimpleClientHttpRequestFactory에 의해 생성됩니다. #🎜 🎜#

호출 시퀀스 다이어그램에서 처음에는 InterceptingClientHttpRequestFactory를 호출했음을 알 수 있습니다. InterceptingClientHttpRequest를 얻기 위해 ClientHttpRequestFactory와 인터셉터를 조합하여 통합합니다. InterceptingClientHttpRequest가 호출을 시작할 때 내부 클래스 InterceptingRequestExecution을 위임합니다. 처리하기 위해 핵심 논리: #🎜🎜#rrreee#🎜🎜#는 먼저 인터셉터 세트의 첫 번째 실행을 수행합니다. 인터셉터 실행이 완료되면 다시 호출하고 else 코드를 실행합니다. 실제로 http 요청을 시작하는 방법에는 ClientHttpRequestFactory 인터페이스를 구현하는 두 가지 주요 방법이 있습니다. #🎜🎜##🎜🎜##🎜🎜##🎜🎜#One은 SimpleClientHttpRequestFactory입니다. , J2SE에서 제공하는 방법( 둘 다 java.net 패키지에서 제공하는 방법)을 사용하면 기본 Http 요청 연결이 생성됩니다. #🎜🎜##🎜🎜##🎜🎜#한 가지 방법은 를 사용하는 것입니다. HttpComponentsClientHttpRequestFactory 메서드와 기본 레이어는 원격 HTTP 서비스에 액세스하기 위해 HttpClient를 사용하고 HttpClient를 사용하여 연결 풀, 인증서 및 기타 정보를 구성합니다. #🎜🎜##🎜🎜# RestTemplate은 기본적으로 SimpleClientHttpRequestFactory를 사용하며 내부적으로 jdk의 HttpConnection을 호출합니다. 기본 시간 초과는 -1입니다. #🎜🎜#rrreee#🎜 🎜# HttpComponentsClientHttpRequestFactory 메서드를 사용하면 연결 풀을 사용할 수 있으며(권장) 재시도 전략을 설정할 수도 있습니다(구체적으로 연구되지 않음)#🎜🎜##🎜🎜#활성화하려는 경우 재시도 메커니즘을 사용하면 스프링 재시도 구성 요소를 도입할 수 있습니다#🎜🎜#rrreee#🎜🎜#이런 방식으로 springcloud-ribbon은 다음 구성을 추가합니다. #🎜🎜#rrreeerrreee#🎜🎜#인셉터는 RetryLoadBalancerInterceptor로 대체됩니다. , 재시도 구성 요소 retryTemplate이 통합되어 있습니다. 재시도 전략은 RetryHandler 인터페이스에 의해 구성됩니다. 기본 구현 클래스는 DefaultLoadBalancerRetryHandler입니다. 다음은 기본 구성 매개변수 #🎜🎜#rrreee#🎜🎜#입니다. 전역적으로 적용됩니다. xxx.ribbon.MaxAutoRetries=1를 추가하면 특정 리본 클라이언트에만 적용됩니다. MaxAutoRetries 및 MaxAutoRetriesNextServer는 각 서버마다 함께 사용됩니다. MaxAutoRetries=1 및 MaxAutoRetriesNextServer=1로 설정된 경우 트리거되는 최대 재시도 횟수는 4회입니다. #🎜🎜##🎜🎜#관련 기사: #🎜🎜##🎜🎜##🎜🎜##🎜🎜#Java 예 - 설정할 배열#🎜🎜##🎜🎜#

위 내용은 springcloud 구성요소의 RestTemplate으로 통합된 리본에 대한 자세한 설명의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!