[java] HttpClient의 Connection Pool 이용한 원격 호출시 소켓에러 방지

hanulbit

추천 수 268

HttpUrlConnection 이나 HttpClient를 이용해서 많이들 URL 원격 호출을 할텐데

동시 접속자수가 조금 많은 서비스에 이걸 적용하게 되면

java.net.BindException: Address already in use: connect

java.net.SocketTimeoutException: connect timed out

이와 같은 에러가 나는걸 볼수가 있다

자주 발생하지 않지만 피크시간에 문제가 항상 발생되었다

그렇다면 어떻게 하면 문제를 해결할수 있을까? BindException은 더이상 열 소켓이 없어서

나는 에러이고 HttpUrlConnection 이나 HttpClient 모두 호출이 있을때마다 소켓을 열고 닫는것을

반복한다 그렇다고 하면 Connection Pool을 이용할수 없을까?

JDK API를 아무리 뒤져봐도 Pool과 관련된 소스가 없었고 아놔.. 이걸 직접 구현하려고 하니

머리가 너무나 아프고 그래서~~~ 멋진 jakarta project 가서 살짝 뒤져보니 쉽게 처리할수 있었다 ^ㅡ^

기존 HttpUrlConnection으로 구현되어 있는걸 HttpClient로 바꾸기로 결정!

말은 이제 그만하고 소스를 보자

※ HttpClient는 버젼별로 모두 소스가 다르기 때문에 google이나 다른 검색엔진에서 그냥 보고 사용하면

버젼때문에 제대로 동작을 안할수 있으니~ 꼭 API 문서를 보고 만들기를 권장(이거 때문에 삽질좀함 ㅠㅠ)

예제 샘플은 튜토리얼을 보고 작성한것임으로 이상한거 있음 해당 사이트를 참조 할것!
---------------------------------------------------------------------------------------------------------------------
최신 릴리지 HttpClient 4.0.1 기준으로 작성함

---------------------------------------------------------------------------------------------------------------------

/* Connection Pool 설정 */

HttpParams params = new BasicHttpParams();
// Increase max total connection to 200
ConnManagerParams.setMaxTotalConnections(params, 200);
// Increase default max connection per route to 20
ConnPerRouteBean connPerRoute = new ConnPerRouteBean(20);
// Increase max connections for localhost:80 to 50
HttpHost localhost = new HttpHost("locahost", 80);
connPerRoute.setMaxForRoute(new HttpRoute(localhost), 50);
ConnManagerParams.setMaxConnectionsPerRoute(params, connPerRoute);

SchemeRegistry schemeRegistry = new SchemeRegistry();
schemeRegistry.register(
   new Scheme("http", PlainSocketFactory.getSocketFactory(), 80));
schemeRegistry.register(
   new Scheme("https", SSLSocketFactory.getSocketFactory(), 443));

cm = new ThreadSafeClientConnManager(params, schemeRegistry);

/*
DefaultHttpClient 에 파라미터를 어떤걸 넘겨주냐에 따라
SingleClientConnManager 와 ThreadSafeClientConnManager 중 뭘쓰는지 결정된다
자세한건 API 참조
*/
httpClient = new DefaultHttpClient(cm, params);

ThreadSafeClientConnManager tm = (ThreadSafeClientConnManager)httpClient.getConnectionManager();

httpGet = new HttpGet("http://localhost/controller.jsp?Action=GetTopScore&GameIdx=1&Phone=111111109&Score=1213");
hr = httpClient.execute(httpGet);

entity = hr.getEntity();
if (entity != null) {
   buff = new BufferedReader(new InputStreamReader(entity.getContent()));
while((line = buff.readLine()) != null)
{
if(!line.equals(""))
{
String[] my = line.split("\\|");
topPhonenum = Integer.parseInt(my[0]);
topScore = Integer.parseInt(my[1]);
}
}
}

br.close();
entity.consumeContent();
httpGet.abort();
---------------------------------------------------------------------------------------------------------------------
아우 너무너무 귀찮아~~~ 대충 소스를 보면 알수 있을것이라 판단하고 전체 소스는 안올리기로 ^^;;

위에 소스만 보면 아 대충
ThreadSafeClientConnManager 이란 녀셕이 있군아 라고 생각이 들테고
API 문서를 조금 보다 보면 HttpClient에는 ClientConnectionManager 이라는 인터페이스가 존재하고
관련 클래스로는 SingleClientConnManager 와ThreadSafeClientConnManager 가 존재하는걸 봐서도
아...이게 Pool을 이용할때와 안할때 차이점이겠군아 대충 감이 오지 않는가?
더 궁금하면 API를 좀더 뒤져보던가 관련 소스를 열여보면 알수 있을것~~!

설마.... 무슨소리인지 모르겠다..... 라고 생각이 들면 그냥 사용하면 됨 -ㅁ-;;

자 그럼 ThreadSafeClientConnManager 를 이용해서 Pool의 대한 설정을 하고
HttpGet을 이용해서 해당 URL을 호출하고 결과값을 받았다
그렇다면 이걸 매번 같은 페이지에서 반복할것인가?

아시다시피 WEB이란 환경은 동적이지 않고 정적인 페이지다(물론 예외가 있지만 말이다)
한번 해당 URL이 호출되고 결과가 화면에 나왔으면 해당 페이지는 멈춰있고 서버는 또다른 작업을 하지 않는다
그렇다면 해당 URL에서 위에서 언급한 HttpClient를 이용해서 Connection Pool을 사용할꺼면
해당 객체를 메모리에 가지고 있어야 하는데 어떻게 해야할까?

방법은 2가지가 있는데(뭐 다른 방법이 있을수도 있겠지만 ^^;;;)
1. application 변수에 담아서 필요할때마다 꺼내쓴다
2. static class로 만들어서 tomcat 구동시 메모리에 올라가도록 한다

어떤 방법을 하던 그건 개발자가 편한대로 하면 되니깐~

간단한 예제 샘플을 만들어서 올리고 싶지만 너무나 지금 배가 고프고 귀찮기 때문에
누군가 필요하다고 절실히 요청하거나 내가 잃어버리지 않고 다시 이포스팅을 찾으면 수정해야겠다;

그래서 간단하게 정리를 하자면

상용서비스에서 원격호출을 이용한 개발을 하고 싶다면 HttpUrlConnection 보단 HttpClient을 이용해야 바람직이다
HttpClient로 ConnectionPool 을 구현할때는 application 변수나 static class를 이용하여 개발을 해야한다
그래야 BindException 에러에 대한 문제도 해결이 가능하고 Connection Timeout 문제도 해결이 가능하다
(그냥 매번 호출시에는 계속 객체를 만들었다가 없앴다가를 반복하기에 Pool을 재사용하지 않음)

< Prev HttpClient Connection Pooling

Create and use HTTP Client connection pool Next >

♥