Android:OkHttp/Retrofit2配置(日志/攔截器/https證書)

配置日志

    // Gradle中需要添加依賴:
    // implementation 'com.squareup.okhttp3:logging-interceptor:3.12.1'
    if (BuildConfig.DEBUG) {
        // 聲明日志類
        val httpLoggingInterceptor = HttpLoggingInterceptor()
        // 設(shè)定日志級別
        httpLoggingInterceptor.level = HttpLoggingInterceptor.Level.BODY
    }

配置攔截器

val okHttpClient = OkHttpClient.Builder()
okHttpClient.addInterceptor {
    // 獲得請求信息
    val requestBuilder = it.request().newBuilder()
    MainApplication.getContext()?.let { context ->
        val timestamp = System.currentTimeMillis()
        // 添加headers信息
        requestBuilder
                .addHeader("packageName", MainApplication.getPackageName()) // 應(yīng)用包名
                .addHeader("timestamp", timestamp.toString()) // 請求時間戳
    }
    val request = requestBuilder.build()
    if (BuildConfig.DEBUG) {
        // 記錄請求耗時
        val startNs = System.nanoTime()
        val response: okhttp3.Response
        try {
            // 發(fā)送請求
            response = it.proceed(request)
        } catch (e: Exception) {
            Logger.logE(javaClass.name, e)
            throw e
        }
        val tookMs = TimeUnit.NANOSECONDS.toMillis(System.nanoTime() - startNs)
        // 獲得返回的body
        val responseBody = response.body()
        // 獲得buffer對象
        val source = responseBody!!.source()
        source.request(java.lang.Long.MAX_VALUE) // Buffer the entire body.
        // 獲得返回的數(shù)據(jù)
        val buffer = source.buffer()
        val contentType = response.header("content-type")
        var responseData: String? = null
        if (contentType != null) {
            if (contentType.contains("image")) {
                responseData = "this is a image"
            } else if (contentType.contains("application/json")) {
                // clone()后使用buffer
                responseData = buffer.clone().readString(Charset.forName("UTF-8"))
            }
        }
        // 打印請求耗時
        Logger.logD(javaClass.name, "\r\n"
                + "url:" + request.url() + "\r\n"
                + "method:" + request.method() + "\r\n"
                + "request header:" + "\r\n"
                + "==============\r\n"
                + request.headers().toString()
                + "==============\r\n"
                + "request body:" + request.body().toString() + "\r\n"
                + "elapsed time:" + tookMs + "ms" + "\r\n"
                + "response header:" + "\r\n"
                + "==============\r\n"
                + response.headers().toString()
                + "==============\r\n"
                + "response:" + responseData + "\r\n")
        response
    } else {
        it.proceed(request)
    }
}

配置https證書

    fun init() {
        val okHttpClient = OkHttpClient.Builder()
        try {
            // 配置https證書
            // 證書位置:/src/main/assets/xxxx.cer
            setCertificates(okHttpClient, MainApplication.getContext()!!.assets.open("server.cer"))
            okHttpClient.hostnameVerifier { _, _ -> true }
        } catch (e: IOException) {
            Logger.logE(javaClass.name, e)
        }
    }

    /**
     * 配置https證書
     * @param clientBuilder OKhttpClient.builder
     * @param certificates 讀取證書的InputStream
     */
    private fun setCertificates(clientBuilder: OkHttpClient.Builder, certificateIs: InputStream) {
        try {
            val certificateFactory = CertificateFactory.getInstance("X.509")
            val keyStore = KeyStore.getInstance(KeyStore.getDefaultType())
            val certificate = certificateFactory.generateCertificate(certificateIs)
            Logger.logD(javaClass.name, "subjectDN: " + (certificate as X509Certificate).subjectDN)
            Logger.logD(javaClass.name, "publicKey: " + certificate.publicKey)
            keyStore.load(null, null)
            keyStore.setCertificateEntry("selfCA", certificate)
            certificateIs.close()
            val trustManagerFactory = TrustManagerFactory.getInstance(TrustManagerFactory.getDefaultAlgorithm())
            trustManagerFactory.init(keyStore)
            val trustManagers = trustManagerFactory.trustManagers
            if (trustManagers.size != 1 || trustManagers[0] !is X509TrustManager) {
                throw IllegalStateException("Unexpected default trust managers:" + Arrays.toString(trustManagers))
            }
            val trustManager = trustManagers[0] as X509TrustManager
            val sslContext = SSLContext.getInstance("TLS")
            // Create an SSLContext that uses our TrustManager
            sslContext.init(null, trustManagerFactory.trustManagers, SecureRandom())
            val sslSocketFactory = sslContext.socketFactory
            clientBuilder.sslSocketFactory(sslSocketFactory, trustManager)
        } catch (e: Throwable) {
            Logger.logE(javaClass.name, e)
        }
    }
最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點(diǎn),簡書系信息發(fā)布平臺,僅提供信息存儲服務(wù)。

友情鏈接更多精彩內(nèi)容