File name
Commit message
Commit date
File name
Commit message
Commit date
File name
Commit message
Commit date
File name
Commit message
Commit date
File name
Commit message
Commit date
File name
Commit message
Commit date
File name
Commit message
Commit date
File name
Commit message
Commit date
File name
Commit message
Commit date
package com.takensoft.pohangTp.common.util;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.UnsupportedEncodingException;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.URL;
import java.net.URLEncoder;
import java.util.List;
import com.takensoft.pohangTp.common.connection.api.vo.ApiParam;
/**
* @author 김성원
* @since 2024.01.12
*
* 데이터 수집 - HTTP통신 관련 Util 입니다.
*/
public class HTTPUtil {
/**
* @author 김성원
* @since 2024.01.12
*
* [GET] HTTP 통신
*/
public synchronized String HttpConnectionApi (String urlText, int type, List<ApiParam> parameter) {
StringBuffer response = new StringBuffer();
URL url = null;
try {
if (parameter.isEmpty() == false) {
urlText += "?" + createUrlQueryApi(parameter, "UTF-8");
}
url = new URL(urlText);
} catch (MalformedURLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
HttpURLConnection httpCon = null;
try {
/* Connection */
httpCon = (HttpURLConnection) url.openConnection();
if(type == 1) {
httpCon.setRequestMethod("POST");
}else {
httpCon.setRequestMethod("GET");
}
httpCon.setRequestProperty("User-Agent", "Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/41.0.2272.101 Safari/537.36");
httpCon.setConnectTimeout(1000 * 60);//http통신 최대 커넥션 시간(1분)
httpCon.setReadTimeout(1000 * 60);//http통신 커넥션 이후, 데이터를 받아오는데 걸리는 최대 시간(1분)
httpCon.setDoInput(true);//받아올 데이터가 있을 때, 사용
//HTTP Request 결과 코드
int responseCode = httpCon.getResponseCode();
if (responseCode == 200) {
//Response 결과 데이터 받기
BufferedReader input = new BufferedReader(new InputStreamReader(httpCon.getInputStream(), "UTF-8"));
//Response 결과 데이터를 문자열로 만들기
String result = null;
while ((result = input.readLine()) != null) {
response.append(result);
}
//InputStream, BufferedReader 종료
input.close();
//HTTP Connection 종료
httpCon.disconnect();
} else {
System.out.println("[HTTP]" + url + "(" + responseCode + " 에러)");
}
} catch (Exception e) {
e.printStackTrace();
}
//문자열로된 Response 결과 return
return response.toString();
}
/**
* @author 김성원
* @since 2024.01.12
*
* 파라메터 데이터를 HTTP통신을 위한 문자열로 변환시켜주는 메서드
* Map -> String
*/
public String createUrlQueryApi (List<ApiParam> parameter, String incoding) {
if (parameter.isEmpty() == true) {
return "";
} else {
StringBuilder query = new StringBuilder();
for(ApiParam param : parameter) {
try {
// 날짜 변경 처리
if(param.isDateForm() == true) {
param.setValue(StringUtil.getTodayaddDate(param.getValue().toString(),param.getDateType(), param.getAddDate()));
}
if(query.length() > 0) {
query.append('&');
}
if (StringUtil.isEmpty(incoding) == true) {
query.append(param.getKey());
query.append('=');
query.append(param.getValue());
} else {
query.append(URLEncoder.encode(param.getKey(), incoding));
query.append('=');
if(param.isDisableDecode()) {
query.append(param.getValue());
}else {
query.append(URLEncoder.encode(String.valueOf(param.getValue()), incoding));
}
}
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
}
}
return query.toString();
}
}
}