투케이2K

368. (kotlin/코틀린) [유틸 파일] RequestSyncPatchBodyJsonHttp 안드로이드 동기 방식 http patch 요청 실시 본문

Kotlin

368. (kotlin/코틀린) [유틸 파일] RequestSyncPatchBodyJsonHttp 안드로이드 동기 방식 http patch 요청 실시

투케이2K 2023. 8. 5. 11:28

[개발 환경 설정]

개발 툴 : AndroidStudio

개발 언어 : Kotlin

 

[소스 코드]

 

    // ----------------------------------------------------------------------------------
    // TODO [SEARCH FAST] : [PATCH] : [BODY JSON] : requestPatchBodyJsonHttp
    // ----------------------------------------------------------------------------------
    /*
    try {
        // TODO [로딩 프로그레스 활성]
        C_Ui_View.startLoadingAlert(
            A_Intro@this,
            S_FinalMsg.AL_TITLE_NORMAL,
            "[HTTP] 요청 중 입니다. 잠시만 기다려 주세요.",
            S_FinalMsg.AL_OK)


        // TODO [새로운 스레드 생성 및 동기 요청 실시]
        val sync = Thread(Runnable {
            for(i in 1..5 step(1)) {

                // [URL 주소 선언]
                val url = "https://jsonplaceholder.typicode.com/posts/1"


                // [헤더 생성]
                val header: HashMap<String, Any> = HashMap()


                // [파라미터 생성]
                val params: HashMap<String, Any> = HashMap()
                params["title"] = "foo"


                // [http 요청 수행]
                var requestPatchBodyJsonHttp = N_SyncHttp().RequestSyncPatchBodyJsonHttp("http 요청", url, header, params)
                requestPatchBodyJsonHttp.start()
                try {
                    requestPatchBodyJsonHttp.join()
                }
                catch (e : Exception) {
                    S_Log._printStackTrace_(null, S_FinalMsg.LOG_BUG_STATE, null, e)
                }


                // [http 응답 확인]
                var response = requestPatchBodyJsonHttp.getResponse()
                S_Log.ltw("================================================")
                S_Log.cnt("[" + ACTIVITY_NAME + " >> "+C_Util.getNowMethod(1)+" :: [PATCH BODY JSON] HTTP 통신 수행 결과]")
                S_Log.cnt("-----------------------------------------")
                S_Log.cnt("[SUCCESS :: "+response.get(N_SyncHttp.RESPONSE_FLAG)+"]")
                S_Log.cnt("-----------------------------------------")
                S_Log.cnt("[DATA :: "+response.get(N_SyncHttp.RESPONSE_DATA)+"]")
                S_Log.lbw("================================================")

            }


            // TODO [로딩 프로그레스 종료]
            C_Ui_View.stopLoadingAlert(A_Intro@this)

        })
        sync.start() // [스레드 동작 수행]
    }
    catch (e : Exception) {
        S_Log._printStackTrace_(null, S_FinalMsg.LOG_BUG_STATE, null, e)
    }
    */
    // ----------------------------------------------------------------------------------
    inner class RequestSyncPatchBodyJsonHttp : Thread {

        // [변수 선언 실시]
        var tag = ""
        var url = ""
        var header = HashMap<String, Any>()
        var params = HashMap<String, Any>()


        // [http 요청 후 응답 값 리턴]
        var response = HashMap<String, Any>()


        // [클래스 생성자 초기화]
        constructor(tag : String, url:String, header:HashMap<String, Any>, params:HashMap<String, Any>){
            this.tag = tag
            this.url = url
            this.header = header
            this.params = params
        }


        // [http 수행 실시]
        override fun run(){
            super.run()
            try {
                // ------------------------------------------------------
                // TODO [URL 변수 선언 실시]
                // ------------------------------------------------------
                var urlData = url
                // ------------------------------------------------------


                // ------------------------------------------------------
                // TODO [url 에 파라미터 추가 실시]
                // ------------------------------------------------------
                var requestBody: RequestBody? = null
                var bodyData = ""
                if (C_Util.mapNotNull(params) === true) { // [파라미터가 있는 경우]

                    // [json 데이터로 변경 실시]
                    bodyData = C_Util.mapToJsonObject(params).toString()
                    requestBody = bodyData.toRequestBody("application/json; charset=utf-8".toMediaType())
                }
                // ------------------------------------------------------


                // ------------------------------------------------------
                // TODO [OK HTTP 객체 선언 실시]
                // ------------------------------------------------------
                val client: OkHttpClient = OkHttpClient().newBuilder()
                    .connectTimeout(TIME_OUT_SECOND.toLong(), TimeUnit.SECONDS) // [커넥션 제한 시간]
                    //.readTimeout(10, TimeUnit.SECONDS)
                    //.writeTimeout(10, TimeUnit.SECONDS)
                    .retryOnConnectionFailure(false)
                    .build()

                val request = Request.Builder()
                request.addHeader("Content-Type", "application/json") //TODO [헤더]
                request.addHeader("Cache-Control", "no-cache") //TODO [헤더]

                if (C_Util.mapNotNull(header) === true) {
                    val set = header.keys
                    val iterator = set.iterator()
                    while (iterator.hasNext()) {
                        val key = iterator.next() as String
                        request.addHeader(key, header[key].toString()) //TODO [헤더 추가]
                    }
                }

                if (requestBody != null){
                    request.patch(requestBody)
                }
                else {
                    request.patch(FormBody.Builder().build())
                }
                request.url(urlData) //TODO [urlData 추가]
                // ------------------------------------------------------


                // ------------------------------------------------------
                // TODO [요청 로그 출력 실시]
                // ------------------------------------------------------
                S_Log._W_("RequestSyncPatchBodyJsonHttp :: OK HTTP 동기 PATCH BODY JSON [요청] 실시", arrayOf(
                    "TAG :: $tag",
                    "TYPE :: " + "POST BODY JSON >> REQUEST",
                    "URL :: $urlData",
                    "HEADER :: $header",
                    "PARAMS :: $params"
                ))
                // ------------------------------------------------------


                // ------------------------------------------------------
                // TODO [비동기 처리 (enqueue 사용)]
                // ------------------------------------------------------
                val finalUrlData = urlData
                // ------------------------------------------------------


                // ------------------------------------------------------
                // TODO [동기 처리 (execute 사용)]
                // ------------------------------------------------------
                val response = client.newCall(request.build()).execute()
                if (response.isSuccessful){
                    val responseHeader = response.headers.toString()
                    val responseCode = response.code.toString()
                    val responseData = response.body!!.string()


                    // ------------------------------------------------------
                    // [로그 출력]
                    // ------------------------------------------------------
                    S_Log._W_("RequestSyncPatchBodyJsonHttp :: OK HTTP 동기 PATCH BODY JSON [응답] 확인", arrayOf(
                        "TAG :: $tag",
                        "TYPE :: " + "POST BODY JSON >> RESPONSE",
                        "CODE :: $responseCode",
                        "URL :: $finalUrlData",
                        "HEADER :: $responseHeader",
                        "DATA :: $responseData"
                    ))
                    // ------------------------------------------------------


                    // ------------------------------------------------------
                    // TODO [응답 코드 값 체크 및 리턴 데이터 반환]
                    // ------------------------------------------------------
                    try {
                        val statusCode = response.code
                        if (statusCode >= 200 && statusCode < 300) { // TODO [정상 응답]

                            // ------------------------------------------------------
                            // TODO [응답 값 삽입]
                            // ------------------------------------------------------
                            this.response.put(RESPONSE_FLAG, true) // [플래그값 저장]
                            this.response.put(RESPONSE_DATA, responseData) // [메시지 삽입]
                        }
                        else { // TODO [에러 응답]

                            // ------------------------------------------------------
                            // TODO [응답 값 삽입]
                            // ------------------------------------------------------
                            this.response.put(RESPONSE_FLAG, false) // [플래그값 저장]
                            this.response.put(RESPONSE_DATA, "[ERROR] : [RequestSyncPatchBodyJsonHttp] : " + C_ErrorCheck.getErrorHttpMsg(responseCode)) // [메시지 삽입]
                        }
                    } catch (e: Exception) {
                        S_Log._printStackTrace_(null, S_FinalMsg.LOG_BUG_STATE, null, e)

                        // ------------------------------------------------------
                        // TODO [응답 값 삽입]
                        // ------------------------------------------------------
                        this.response.put(RESPONSE_FLAG, false) // [플래그값 저장]
                        this.response.put(RESPONSE_DATA, "[EXCEPTION] : [0] : [RequestSyncPatchBodyJsonHttp] : " + e.message.toString()) // [메시지 삽입]
                    }

                    // ------------------------------------------------------
                }
                else { // TODO [요청이 실패한 경우]
                    val responseHeader = response.headers.toString()
                    val responseCode = response.code.toString()
                    val responseData = response.body!!.string()


                    // ------------------------------------------------------
                    // [로그 출력]
                    // ------------------------------------------------------
                    S_Log._E_("RequestSyncPatchBodyJsonHttp :: OK HTTP 동기 PATCH BODY JSON [에러] 확인", arrayOf(
                        "TAG :: $tag",
                        "TYPE :: " + "POST BODY JSON >> FAIL",
                        "CODE :: $responseCode",
                        "URL :: $finalUrlData",
                        "HEADER :: $responseHeader",
                        "DATA :: $responseData"
                    ))
                    // ------------------------------------------------------


                    // ------------------------------------------------------
                    // TODO [응답 값 삽입]
                    // ------------------------------------------------------
                    this.response.put(RESPONSE_FLAG, false) // [플래그값 저장]
                    this.response.put(RESPONSE_DATA, "[EXCEPTION] : [1] : [RequestSyncPatchBodyJsonHttp] : " + responseData) // [메시지 삽입]
                }
            }
            catch (e : Exception) {
                S_Log._printStackTrace_(null, S_FinalMsg.LOG_BUG_STATE, null, e)
                // ------------------------------------------------------
                // [로그 출력]
                // ------------------------------------------------------
                S_Log._E_("RequestSyncPatchBodyJsonHttp :: OK HTTP 동기 PATCH BODY JSON [EXCEPTION] 확인", arrayOf(
                    "TAG :: $tag",
                    "TYPE :: " + "POST BODY JSON >> EXCEPTION",
                    "EXCEPTION :: " + e.message.toString()
                ))
                // ------------------------------------------------------


                // ------------------------------------------------------
                // TODO [응답 값 삽입]
                // ------------------------------------------------------
                this.response.put(RESPONSE_FLAG, false) // [플래그값 저장]
                this.response.put(RESPONSE_DATA, "[EXCEPTION] : [2] : [RequestSyncPatchBodyJsonHttp] : " + e.message.toString()) // [메시지 삽입]
            }
        }


        // [http 요청 성공 및 슬패 결과 값 리턴 함수]
        fun getResponse(): Map<String, Any> {
            return this.response
        }

    }

 

반응형
Comments