使用例子：
val url = "https://www.baidu.com"
NetUtils.getHttp(url, null, object : NewCallBack<String> {
override fun onFail(err: String) {
Log.e("onFail", err)
}
override fun onSuccess(t: String) {
Log.e("onSuccess", t.toString())
}
})
使用范圍：聯(lián)網(wǎng)請求 返回結(jié)果 String , Bitmap , 自定義類型
實(shí)現(xiàn)1：引入OKhttp的依賴庫(這里的例子是Android Studio 3.0 Beta2的引入)
在APP層的build.gradle文件中，dependencies標(biāo)簽下添加一行
implementation 'com.squareup.okhttp3:okhttp:3.8.1'
實(shí)現(xiàn)2：編寫NewCallBack接口用于請求結(jié)果的回調(diào)
/**
* Created by 俊華 on 17/8/12.
*/
interface NewCallBack<T> {
/**
* 失敗的回調(diào)
*/
fun onFail(err: String)
/**
* 成功的回調(diào)
*/
fun onSuccess(t: T)
/**
* 獲取接口傳入的類型<T>
*/
fun Type(): Class<T>? {
val interfacesTypes = this.javaClass.genericInterfaces.get(0) as ParameterizedType
return interfacesTypes.actualTypeArguments[0] as Class<T>
}
}
實(shí)現(xiàn)3：編寫NetUtils類辩块，用于處理聯(lián)網(wǎng)請求的邏輯處理
這里我使用到了阿里的fastjson解析，所以要引入依賴庫
在（實(shí)現(xiàn)1）的下面再添加一行
implementation 'com.alibaba:fastjson:1.2.36'
然后再繼續(xù)NetUtils的封裝
/**
* Created by 俊華 on 17/8/12.
*/
object NetUtils {
private var client: OkHttpClient
private var mHandler: Handler
private var threadPool: Executor
private lateinit var newCallBack: NewCallBack<Any>
private lateinit var url: String
private var params: Map<String, String>? = null
private lateinit var request: Request
init {
client = OkHttpClient()
mHandler = Handler(Looper.getMainLooper())
threadPool = Executors.newCachedThreadPool()
}
/**
* get請求
*/
fun <T> getHttp(url: String?, params: Map<String, String>?, callBack: NewCallBack<T>) {
http(url, params, false, callBack)
}
/**
* post請求
*/
fun <T> postHttp(url: String?, params: Map<String, String>?, callBack: NewCallBack<T>) {
http(url, params, true, callBack)
}
private fun <T> http(url: String?, params: Map<String, String>?, isPost: Boolean, callBack: NewCallBack<T>) {
if (TextUtils.isEmpty(url)) {
Log.e("url", "你輸入的路徑為空")
} else {
this.url = url as String
this.params = params
this.newCallBack = callBack as NewCallBack<Any>
setRequest(isPost)
runOnNet()
}
}
/**
* 處理自定義的類
*/
fun <T> parseJsonWithFast(jsonData: String, type: Class<T>?): T? {
if (TextUtils.isEmpty(jsonData)) {
return null
}
try {
Log.e("數(shù)據(jù)類型為自定義", "parseJsonWithFast()")
return JSONObject.parseObject(jsonData, type)
} catch (e: Exception) {
Log.e("fastJson解析數(shù)據(jù)異常", e.toString())
return null
}
}
private fun setRequest(isPost: Boolean) {
if (params != null) {
if (isPost) {
val requestBody = MultipartBody.Builder()
requestBody.setType(MultipartBody.FORM)
val iterator = params!!.entries.iterator()
while (iterator.hasNext()) {
val entry = iterator.next()
requestBody.addFormDataPart(entry.key, entry.value)
}
request = Request.Builder().url(url).post(requestBody.build()).build()
} else {
val urlStr = url + "?" + MapParamToString(params!!)
request = Request.Builder().url(urlStr).build()
}
} else {
request = Request.Builder().url(url).build()
}
}
/**
*處理傳入的請求參數(shù)
*/
private fun MapParamToString(params: Map<String, String>): String {
if (params != null) {
val stringBuilder = StringBuilder()
val iterator = params.entries.iterator()
while (iterator.hasNext()) {
val entry = iterator.next()
stringBuilder.append(entry.key + "=" + entry.value + "&")
}
val str = stringBuilder.toString().substring(0, stringBuilder.length - 1)
return str
}
return ""
}
private fun runOnNet() {
threadPool.execute {
client.newCall(request).enqueue(object : Callback {
override fun onFailure(call: Call?, e: IOException?) {
mHandler.post {
newCallBack.onFail("請求失敗")
}
}
override fun onResponse(call: Call?, response: Response?) {
if (response != null) {
if (response.isSuccessful) {
when (newCallBack.Type()!!.simpleName) {
"String" -> dealString(response.body()!!.string())
//將響應(yīng)數(shù)據(jù)轉(zhuǎn)化為輸入流數(shù)據(jù)
"Bitmap" -> dealBitmip(response.body()!!.byteStream())
else -> dealClazz(response.body()!!.string())
}
} else {
onError("請求失敗")
}
} else {
onError("解析錯誤")
}
}
})
}
}
/**
* 處理圖片
*/
private fun dealBitmip(inputStream: InputStream) {
//將輸入流數(shù)據(jù)轉(zhuǎn)化為Bitmap位圖數(shù)據(jù)
val bitmap = BitmapFactory.decodeStream(inputStream)
if (bitmap != null) {
mHandler.post({
newCallBack.onSuccess(bitmap)
})
} else {
onError("轉(zhuǎn)換圖片失敗")
}
}
/**
* 返回字符串
*/
private fun dealString(res: String?) {
if (res != null) {
if (!TextUtils.isEmpty(res)) {
mHandler.post({
newCallBack.onSuccess(res)
})
} else {
onError("解析錯誤")
}
} else {
onError("解析錯誤")
}
}
/**
* 返回錯誤提示
*/
private fun onError(err: String) {
mHandler.post({
newCallBack.onFail(err)
})
}
/**
* 處理自定義類型
*/
private fun dealClazz(res: String) {
val any = parseJsonWithFast(res, newCallBack.Type())
if (any != null) {
mHandler.post {
newCallBack.onSuccess(any)
}
} else {
onError("解析失敗")
}
}
}
以上就是我要分享的用kotlin封裝的通用網(wǎng)絡(luò)引擎內(nèi)容尚氛，如有不當(dāng)视粮，懇請批評指正
備注：要求比較高的建議使用大神的三方框架采桃，或自行封裝戏阅，我的這個封 裝思路適用 初級程序員或者小白
