配置日志
// 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ù)。