Notice
Recent Posts
Recent Comments
Link
투케이2K
536. (Android/Java) [okhttp 4.9.0] [유틸 파일] requestPutBodyJsonHttp : put 방식 동기 http 요청 수행 본문
Android
536. (Android/Java) [okhttp 4.9.0] [유틸 파일] requestPutBodyJsonHttp : put 방식 동기 http 요청 수행
투케이2K 2023. 4. 8. 23:48[개발 환경 설정]
개발 툴 : AndroidStudio
[소스 코드]
// -----------------------------------------------------------------------------------------
// TODO [SEARCH FAST] : [PUT] : [BODY JSON] : requestPutBodyJsonHttp
// -----------------------------------------------------------------------------------------
// TODO [호출 방법 소스 코드]
// -----------------------------------------------------------------------------------------
/*
try {
// TODO [로딩 프로그레스 활성]
C_Ui_View.startLoadingAlert(
A_Intro.this,
S_FinalMsg.AL_TITLE,
"[HTTP] 요청 중 입니다. 잠시만 기다려 주세요.",
S_FinalMsg.AL_OK);
// TODO [새로운 스레드 생성 및 동기 요청 실시]
new Thread(){
@Override
public void run(){
try {
// TODO [순차적 요청 수행]
for (int i=0; i<10; i++){
// TODO [URL 및 데이터 생성]
String url = "https://jsonplaceholder.typicode.com/posts/1";
Map header = new HashMap();
Map params = new HashMap();
params.put("userId",1);
params.put("id",1);
params.put("title","foo");
params.put("bar","foo");
// TODO [http 통신 시작]
N_SyncHttp.RequestSyncPutBodyJsonHttp requestPutBodyJsonHttp = new N_SyncHttp.RequestSyncPutBodyJsonHttp(url, header, params);
requestPutBodyJsonHttp.start();
try{
requestPutBodyJsonHttp.join(); // [스레드 작업 완료까지 대기]
}catch(Exception e){
e.printStackTrace();
}
// TODO [http 통신 응답 값 확인]
Map response = requestPutBodyJsonHttp.getResponse();
S_Log.ltw("================================================");
S_Log.cnt("["+ACTIVITY_NAME+" >> "+C_Util.getNowMethod(1)+" :: [PUT BODY JSON] HTTP 통신 수행 결과]");
S_Log.cnt("[SUCCESS :: "+response.get(N_SyncHttp.RESPONSE_FLAG)+"]");
S_Log.cnt("[DATA :: "+response.get(N_SyncHttp.RESPONSE_DATA)+"]");
S_Log.lbw("================================================");
}
// TODO [로딩 프로그레스 종료]
C_Ui_View.stopLoadingAlert(A_Intro.this);
}
catch (Exception e) {
e.printStackTrace();
}
}
}.start();
}
catch (Exception e){
e.printStackTrace();
}
*/
// -----------------------------------------------------------------------------------------
public static class RequestSyncPutBodyJsonHttp extends Thread {
// [변수 선언 실시]
String url = "";
Map header = new HashMap();
Map params = new HashMap();
// [http 요청 후 응답 값 리턴]
private Map response = new HashMap(); // [http 요청 성공 및 실패 플래그값]
// [클래스 생성자 초기화]
public RequestSyncPutBodyJsonHttp(String url, Map header, Map params){
this.url = url;
this.header = header;
this.params = params;
}
// [http 수행 실시]
public void run() {
try {
// ------------------------------------------------------
// TODO [URL 변수 선언 실시]
String urlData = String.valueOf(url);
// ------------------------------------------------------
// ------------------------------------------------------
//TODO [BODY에 파라미터 추가 실시]
RequestBody requestBody = null;
String bodyData = "";
if (C_Util.mapNotNull(params) == true) { // [파라미터가 있는 경우]
// [json 데이터로 변경 실시]
bodyData = C_Util.mapToJsonObject(params).toString();
requestBody = RequestBody.create(bodyData, MediaType.parse("application/json; charset=utf-8"));
}
// ------------------------------------------------------
// ------------------------------------------------------
//TODO [OK HTTP 객체 선언 실시]
OkHttpClient client = new OkHttpClient.Builder()
.connectTimeout(10, TimeUnit.SECONDS) // [커넥션 제한 시간]
//.readTimeout(10, TimeUnit.SECONDS)
//.writeTimeout(10, TimeUnit.SECONDS)
.retryOnConnectionFailure(false)
.build();
Request.Builder request = new Request.Builder();
request.addHeader("Content-Type", "application/json"); //TODO [헤더]
request.addHeader("Cache-Control", "no-cache"); //TODO [헤더]
if (C_Util.mapNotNull(header) == true){
Set set = header.keySet();
Iterator iterator = set.iterator();
while(iterator.hasNext()){
String key = (String) iterator.next();
request.addHeader(key, String.valueOf(header.get(key))); //TODO [헤더 추가]
S_Log.ltd("================================================");
S_Log.cnt("["+ACTIVITY_NAME+" >> RequestSyncPutBodyJsonHttp :: OK HTTP 동기 PUT BODY JSON [헤더] 추가]");
S_Log.cnt("-----------------------------------------");
S_Log.cnt("[KEY :: "+String.valueOf(key)+"]");
S_Log.cnt("-----------------------------------------");
S_Log.cnt("[VALUE :: "+String.valueOf(header.get(key))+"]");
S_Log.lbd("================================================");
}
}
HttpUrl.Builder httpBuilder = HttpUrl.get(URI.create(urlData)).newBuilder();
if (requestBody != null){
request.put(requestBody);
}
else {
request.put(new FormBody.Builder().build());
}
request.url(httpBuilder.build()); //TODO [httpBuilder 추가]
// ------------------------------------------------------
// ------------------------------------------------------
// TODO [요청 로그 출력 실시]
S_Log.ltw("================================================");
S_Log.cnt("["+ACTIVITY_NAME+" >> RequestSyncPutBodyJsonHttp :: OK HTTP 동기 PUT BODY JSON [요청] 실시]");
S_Log.cnt("-----------------------------------------");
S_Log.cnt("[TYPE :: PUT BODY JSON >> REQUEST]");
S_Log.cnt("-----------------------------------------");
S_Log.cnt("[URL :: "+String.valueOf(urlData)+"]");
S_Log.cnt("-----------------------------------------");
S_Log.cnt("[HEADER :: "+String.valueOf(header)+"]");
S_Log.cnt("-----------------------------------------");
S_Log.cnt("[PARAMS :: "+String.valueOf(params)+"]");
S_Log.lbw("================================================");
// ------------------------------------------------------
// ------------------------------------------------------
//TODO [비동기 처리 (enqueue 사용)]
String finalUrlData = urlData;
//TODO [동기 처리 (execute 사용)]
Response response = client.newCall(request.build()).execute();
if (response.isSuccessful()) { //TODO [요청이 성공한 경우]
final String responseUrl = String.valueOf(finalUrlData);
final String responseHeader = String.valueOf(response.headers().toString());
final String responseCode = String.valueOf(response.code());
final String responseData = String.valueOf(response.body().string());
S_Log.ltw("================================================");
S_Log.cnt("["+ACTIVITY_NAME+" >> RequestSyncPutBodyJsonHttp :: OK HTTP 동기 PUT BODY JSON [응답] 확인]");
S_Log.cnt("-----------------------------------------");
S_Log.cnt("[TYPE :: PUT BODY JSON >> RESPONSE]");
S_Log.cnt("-----------------------------------------");
S_Log.cnt("[CODE :: "+String.valueOf(responseCode)+"]");
S_Log.cnt("-----------------------------------------");
S_Log.cnt("[URL :: "+String.valueOf(responseUrl)+"]");
S_Log.cnt("-----------------------------------------");
S_Log.cnt("[HEADER :: "+String.valueOf(responseHeader)+"]");
S_Log.cnt("-----------------------------------------");
S_Log.cnt("[DATA :: "+String.valueOf(responseData)+"]");
S_Log.lbw("================================================");
// ------------------------------------------------------
// TODO [응답 코드 값 체크 및 리턴 데이터 반환]
// ------------------------------------------------------
try {
int statusCode = response.code();
if (statusCode >= 200 && statusCode < 300){ // TODO [정상 응답]
// [응답 값 삽입]
this.response.put(RESPONSE_FLAG, true); // [플래그값 저장]
this.response.put(RESPONSE_DATA, responseData); // [메시지 삽입]
}
else { // TODO [에러 응답]
// [응답 값 삽입]
this.response.put(RESPONSE_FLAG, false); // [플래그값 저장]
this.response.put(RESPONSE_DATA, "[ERROR] : [RequestSyncPutBodyJsonHttp] : " + String.valueOf(C_Msg.getErrorHttpMsg(responseCode))); // [메시지 삽입]
}
}
catch (Exception e){
e.printStackTrace();
// [응답 값 삽입]
this.response.put(RESPONSE_FLAG, false); // [플래그값 저장]
this.response.put(RESPONSE_DATA, "[EXCEPTION] : [0] : [RequestSyncPutBodyJsonHttp] : " + String.valueOf(e.getMessage())); // [메시지 삽입]
}
}
else { //TODO [요청이 실패한 경우]
final String responseUrl = String.valueOf(finalUrlData);
final String responseHeader = String.valueOf(response.headers().toString());
final String responseCode = String.valueOf(response.code());
final String responseData = String.valueOf(response.body().string());
S_Log.lte("================================================");
S_Log.cnt("["+ACTIVITY_NAME+" >> RequestSyncPutBodyJsonHttp :: OK HTTP 동기 PUT BODY JSON [에러] 확인]");
S_Log.cnt("-----------------------------------------");
S_Log.cnt("[TYPE :: PUT BODY JSON >> FAIL]");
S_Log.cnt("-----------------------------------------");
S_Log.cnt("[URL :: "+String.valueOf(responseUrl)+"]");
S_Log.cnt("-----------------------------------------");
S_Log.cnt("[ERROR :: "+String.valueOf(responseData)+"]");
S_Log.lbe("================================================");
// [응답 값 삽입]
this.response.put(RESPONSE_FLAG, false); // [플래그값 저장]
this.response.put(RESPONSE_DATA, "[FAIL] : [RequestSyncPutBodyJsonHttp] : " + String.valueOf(responseData)); // [메시지 삽입]
}
}
catch (final Exception e){
S_Log.lte("================================================");
S_Log.cnt("["+ACTIVITY_NAME+" >> RequestSyncPutBodyJsonHttp :: OK HTTP 동기 PUT BODY JSON [Exception] 확인]");
S_Log.cnt("-----------------------------------------");
S_Log.cnt("[TYPE :: PUT BODY JSON >> EXCEPTION]");
S_Log.cnt("-----------------------------------------");
S_Log.cnt("[EXCEPTION :: "+String.valueOf(e.getMessage())+"]");
S_Log.lbe("================================================");
// ------------------------------------------------------
// TODO [리턴 데이터 반환]
// ------------------------------------------------------
try {
// [응답 값 삽입]
this.response.put(RESPONSE_FLAG, false); // [플래그값 저장]
this.response.put(RESPONSE_DATA, "[EXCEPTION] : [1] : [RequestSyncPutBodyJsonHttp] : " + String.valueOf(e.getMessage())); // [메시지 삽입]
}
catch (Exception ex){
ex.printStackTrace();
// [응답 값 삽입]
this.response.put(RESPONSE_FLAG, false); // [플래그값 저장]
this.response.put(RESPONSE_DATA, "[EXCEPTION] : [2] : [RequestSyncPutBodyJsonHttp] : " + String.valueOf(ex.getMessage())); // [메시지 삽입]
}
}
}
//TODO [http 요청 성공 및 실패 결과값 리턴해주는 함수]
public Map getResponse(){
return this.response;
}
}
[결과 출력]
W///===========//: ================================================
I/: [A_Intro >> run :: [PUT BODY JSON] HTTP 통신 수행 결과]
I/: [SUCCESS :: true]
I/: [DATA :: {
"bar": "foo",
"id": 1,
"title": "foo",
"userId": 1
}]
W///===========//: ================================================
반응형
'Android' 카테고리의 다른 글
Comments