투케이2K

537. (Android/Java) [okhttp 4.9.0] [유틸 파일] RequestSyncPostQueryStringHttp : 동기 POST QUERY STRING 요청 본문

Android

537. (Android/Java) [okhttp 4.9.0] [유틸 파일] RequestSyncPostQueryStringHttp : 동기 POST QUERY STRING 요청

투케이2K 2023. 4. 9. 17:42
반응형

[개발 환경 설정]

개발 툴 : AndroidStudio

 

[소스 코드]

    // -----------------------------------------------------------------------------------------
    // TODO [SEARCH FAST] : [POST] : [QUERY STRING] : requestPostQueryStringHttp
    // -----------------------------------------------------------------------------------------
    // 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";

                        Map header = new HashMap();

                        Map params = new HashMap();
                        params.put("userId",1);
                        params.put("id",1);


                        // TODO [http 통신 시작]
                        N_SyncHttp.RequestSyncPostQueryStringHttp requestPostQueryStringHttp = new N_SyncHttp.RequestSyncPostQueryStringHttp(url, header, params);
                        requestPostQueryStringHttp.start();
                        try{
                            requestPostQueryStringHttp.join(); // [스레드 작업 완료까지 대기]
                        }catch(Exception e){
                            e.printStackTrace();
                        }


                        // TODO [http 통신 응답 값 확인]
                        Map response = requestPostQueryStringHttp.getResponse();
                        S_Log.ltw("================================================");
                        S_Log.cnt("["+ACTIVITY_NAME+" >> "+C_Util.getNowMethod(1)+" :: [POST QUERY STRING] 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 RequestSyncPostQueryStringHttp extends Thread {

        // [변수 선언 실시]
        String url = "";
        Map header = new HashMap();
        Map params = new HashMap();


        // [http 요청 후 응답 값 리턴]
        private Map response = new HashMap(); // [http 요청 성공 및 실패 플래그값]


        // [클래스 생성자 초기화]
        public RequestSyncPostQueryStringHttp(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 [url 에 파라미터 추가 실시]
                if (C_Util.mapNotNull(params) == true) { // [파라미터가 있는 경우]

                    if (urlData.endsWith("?") == false){
                        urlData = urlData + "?";
                    }

                    urlData = urlData + C_Util.mapToUrlEncodeQueryString(params);
                }
                // ------------------------------------------------------


                // ------------------------------------------------------
                //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/x-www-form-urlencoded; charset=utf-8;"); //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+" >> RequestSyncPostQueryStringHttp :: OK HTTP 동기 POST QUERY STRING [헤더] 추가]");
                        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();
                request.post(new FormBody.Builder().build());
                request.url(httpBuilder.build()); //TODO [httpBuilder 추가]
                // ------------------------------------------------------


                // ------------------------------------------------------
                // TODO [요청 로그 출력 실시]
                S_Log.ltw("================================================");
                S_Log.cnt("["+ACTIVITY_NAME+" >> RequestSyncPostQueryStringHttp :: OK HTTP 동기 POST QUERY STRING [요청] 실시]");
                S_Log.cnt("-----------------------------------------");
                S_Log.cnt("[TYPE :: POST QUERY STRING >> 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+" >> RequestSyncPostQueryStringHttp :: OK HTTP 동기 POST QUERY STRING [응답] 확인]");
                    S_Log.cnt("-----------------------------------------");
                    S_Log.cnt("[TYPE :: POST QUERY STRING >> 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] : [RequestSyncPostQueryStringHttp] : " + String.valueOf(C_Msg.getErrorHttpMsg(responseCode))); // [메시지 삽입]

                        }
                    }
                    catch (Exception e){
                        e.printStackTrace();

                        // [응답 값 삽입]
                        this.response.put(RESPONSE_FLAG, false); // [플래그값 저장]
                        this.response.put(RESPONSE_DATA, "[EXCEPTION] : [0] : [RequestSyncPostQueryStringHttp] : " + 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+" >> RequestSyncPostQueryStringHttp :: OK HTTP 동기 POST QUERY STRING [에러] 확인]");
                    S_Log.cnt("-----------------------------------------");
                    S_Log.cnt("[TYPE :: POST QUERY STRING >> 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] : [RequestSyncPostQueryStringHttp] : " + String.valueOf(responseData)); // [메시지 삽입]
                }
            }
            catch (final Exception e){
                S_Log.lte("================================================");
                S_Log.cnt("["+ACTIVITY_NAME+" >> RequestSyncPostQueryStringHttp :: OK HTTP 동기 POST QUERY STRING [Exception] 확인]");
                S_Log.cnt("-----------------------------------------");
                S_Log.cnt("[TYPE :: POST QUERY STRING >> 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] : [RequestSyncPostQueryStringHttp] : " + String.valueOf(e.getMessage())); // [메시지 삽입]
                }
                catch (Exception ex){
                    ex.printStackTrace();

                    // [응답 값 삽입]
                    this.response.put(RESPONSE_FLAG, false); // [플래그값 저장]
                    this.response.put(RESPONSE_DATA, "[EXCEPTION] : [2] : [RequestSyncPostQueryStringHttp] : " + String.valueOf(ex.getMessage())); // [메시지 삽입]
                }
            }
        }

        //TODO [http 요청 성공 및 실패 결과값 리턴해주는 함수]
        public Map getResponse(){
            return this.response;
        }
    }
 

[결과 출력]

 

W///===========//: ================================================
I/: [A_Intro >> run :: [POST QUERY STRING] HTTP 통신 수행 결과]
I/: [SUCCESS :: true]
I/: [DATA :: {
      "id": 101
    }]
W///===========//: ================================================

 

반응형
Comments