Spring RestTemplate 샘플 : 타임아웃 및 pool설정 등의 튜닝버전

package com.sample;

import java.util.concurrent.TimeUnit;

import org.apache.http.client.HttpClient;

import org.apache.http.impl.client.HttpClientBuilder;

import org.springframework.http.client.HttpComponentsClientHttpRequestFactory;

import org.springframework.web.client.RestTemplate;

import lombok.extern.slf4j.Slf4j;

/**

 * Spring RestTemplate 샘플

 *  - 타임아웃 및 pool설정 등의 튜닝버전 

 *

 * @author 

 */

@Slf4j

public class RestTemplateSample {

     private static final String REQ_URL_1 = "https://테스트URL 1번째";

     private static final String REQ_URL_2 = "https://테스트URL 2번째";

    

    private static RestTemplate restTemplate = new RestTemplate();

     

    public static void init() {

          log.info("== Start : restTemplate 초기화");

          HttpComponentsClientHttpRequestFactory crf = new HttpComponentsClientHttpRequestFactory();

          crf.setReadTimeout(7000); //읽기시간초과 타임아웃

          crf.setConnectTimeout(7000); //연결시간초과 타임아웃

          // @formatter:off

          HttpClient httpClient = HttpClientBuilder.create()

               .setMaxConnTotal(300) //커넥션풀적용(최대 오픈되는 커넥션 수)

               .setMaxConnPerRoute(50) //커넥션풀적용(IP:포트 1쌍에 대해 수행 할 연결 수제한)

               .evictIdleConnections(2000L, TimeUnit.MILLISECONDS) //서버에서 keepalive시간동안 미 사용한 커넥션을 죽이는 등의 케이스 방어로 idle커넥션을 주기적으로 지움

               .build();

          crf.setHttpClient(httpClient);

          // @formatter:on

          restTemplate.setRequestFactory(crf);

          log.info("== end : restTemplate 초기화\n\n");

     }

     /**

      * Spring RestTemplate 샘플

      *  - 타임아웃 및 pool설정 등의 튜닝버전

      *  - https URL호출 테스트시, 로그에 SSLConnectionSocketFactory 존재 유무 등을 확인하면 pool이 활용되어 https three hand shake가 발생하는지 알 수 있음

      * 

      * @param args

      * @throws Exception

      */

     public static void main(String[] args) throws Exception {

          init();

          int testReqCnt = 3; //테스트 호출 횟수

          //1번째 요청시 커넥션을 맺어서 pool에 넣고, 2번째 요청부터는 pool을 재사용(로그를 보면 ssl핸드쉐이크 부분이 2번째에서는 없음)

          for (int i = 1; i <= testReqCnt; i++) {

               System.out.println("\n\n" + i + "번째 요청 시작");

               log.info("\n\nURL:{}의 {} 번째 결과. {}\n\n\n", REQ_URL_1, i, restTemplate.getForObject(REQ_URL_1, String.class));

               //evictIdleConnections 확인시 주석 풀어서 실행=> 로그에 "Closing connections idle longer than 2000 MILLISECONDS" 확인 됨

               Thread.sleep(3000);

               if (i != testReqCnt) {

                    log.info("\n\n3초 sleep 후 idleConnection이 pool에서 제거된 후 해당URl을 재 요청해봄\n\n");

               }

          }

          System.out.println("\n\n\n\n");

          System.out.println("=== 2번째 URL호출 테스트 시작 ===");

          for (int i = 1; i <= testReqCnt; i++) {

               System.out.println("\n\n" + i + "번째 요청 시작");

               log.info("\n\nURL:{}의 {} 번째 결과. {}\n\n\n", REQ_URL_2, i, restTemplate.getForObject(REQ_URL_2, String.class));

          }

          System.out.println("\n\n\n\n");

          System.out.println("1번째 URL 재 호출해봄");

          log.info("\n\nURL:{}의결과. {}\n", REQ_URL_1, restTemplate.getForObject(REQ_URL_1, String.class));

     }

}