本文主要是介绍retrofit2网络请求的kotlin版本封装，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！
从最早网络请求使用httpclient开始，到后面只用okhttp, 到使用retrofit2 ,（听闻retrofit2有kotlin版本，但是我去官网看似乎仍然是java 的）
虽然网络框架还是基于java的。但是多数项目都开始使用kotlin编写。所以对自己之前的封装的网络框架也使用kotlin重构一下吧。
其实还有一些变化，在测试版本的as中 ，权限请求的方法也过时了，结构变得更灵活，所以以后会把那个再重新封装一下。
常规的app用的最多的感觉就是访问网络和权限请求了。好了就这些，这次的封装还耐心的写了注解，并且补全了复合数据的提交。哈哈希望看了这篇的能有点收获吧
有些业务逻辑相关的部分简写了，可以根据实际去扩展。下面是主要代码，其实有部分还没有完善，等再有时间会整理一下。发布到github的仓库。
class CommonHttp {companion object {lateinit var mBaseUrl: Stringlateinit var retrofit: Retrofitlateinit var client:OkHttpClientlateinit var callBack:(back:HttpMessage)->Unit;}/*** 不使用拦截器的构造方法*/constructor(baseUrl:String,function:(back:HttpMessage)->Unit){callBack=functionmBaseUrl=baseUrlif(retrofit==null) {var httpBuilder: OkHttpClient.Builder = OkHttpClient.Builder()var dispatcher = Dispatcher()dispatcher.maxRequests = 128dispatcher.maxRequestsPerHost = 32httpBuilder.dispatcher(dispatcher)httpBuilder.connectionPool(ConnectionPool(32, 20, TimeUnit.MILLISECONDS))client =httpBuilder.readTimeout(3, TimeUnit.MINUTES).connectTimeout(3, TimeUnit.MINUTES).writeTimeout(3,TimeUnit.MINUTES).build()retrofit = Retrofit.Builder().baseUrl(baseUrl).client(client).build();}}/*** 带拦截器的构造方法。多个域名的情况可以考虑使用*/constructor(baseUrl:String,interceptor: Interceptor,function:(back:HttpMessage)->Unit){callBack=functionmBaseUrl=baseUrlif(retrofit==null) {var httpBuilder: OkHttpClient.Builder = OkHttpClient.Builder()var dispatcher = Dispatcher()dispatcher.maxRequests = 128dispatcher.maxRequestsPerHost = 32httpBuilder.dispatcher(dispatcher)httpBuilder.connectionPool(ConnectionPool(32, 20, TimeUnit.MILLISECONDS))client =httpBuilder.readTimeout(3, TimeUnit.MINUTES).connectTimeout(3, TimeUnit.MINUTES).writeTimeout(3,TimeUnit.MINUTES).addInterceptor( if (interceptor==null) BaseUrlInterceptor() else interceptor).build()retrofit = Retrofit.Builder().baseUrl(baseUrl).client(client).build();}}fun doRequest(vararg objects:Any){var call:Call<ResponseBody>? = nullvar cookies:HashMap<String,String> = HashMap()when(objects.size){1->{var url=objects[0] as Stringcall= retrofit.create(CommonHttpService::class.java).get(url)}2->{var url=objects[0] as Stringvar params=objects[1] as HashMap<String,String>/*** json 形式*/var jsonBody:RequestBody= RequestBody.create(MediaType.parse("application/json;charset=utf-8"),JSON.toJSONString(params))/*** form 表单格式*/var formBodyBuilder=FormBody.Builder()for(param in params){formBodyBuilder.add(param.key,param.value)}var formBody=formBodyBuilder.build()call= retrofit.create(CommonHttpService::class.java).post(url,params,jsonBody)//json 或表单形式提交}3->{var url=objects[0] as Stringvar params=objects[1] as HashMap<String,String>var files=objects[2] as HashMap<String, File>/*** 复合表单格式，适合同时提交参数与文件*/var builer=MultipartBody.Builder()for(param in params){builer.addFormDataPart(param.key,param.value)}for(file in files){var requestBody=RequestBody.create(MediaType.parse("application/octet-stream"),file.value)builer.addFormDataPart(file.key,file.value.name,requestBody)}var multipartBody=builer.build()call= retrofit.create(CommonHttpService::class.java).postFile(url,multipartBody.parts())
// call= retrofit.create(CommonHttpService::class.java).post(url,cookies,multipartBody)//不同的请求格式，两种都可以，看服务器接收格式}}call?.enqueue(object: retrofit2.Callback<ResponseBody> {override fun onResponse(call: Call<ResponseBody>,response: retrofit2.Response<ResponseBody>,) {Log.e("http","请求成功")if(response!=null) {var message = Message()message.obj = responsemessage.what=0handler.sendMessage(message)}else{handler.sendEmptyMessage(-1)}}override fun onFailure(call: Call<ResponseBody>, t: Throwable) {Log.e("http","请求异常")handler.sendEmptyMessage(-1)}})}/*** httpmsg type 0成功 1失败 -1异常。指代服务器返回结果，-1访问失败 使用* code 指代服务器业务逻辑返回码* result 返回的数据*/var handler= object:Handler(Looper.getMainLooper()){override fun handleMessage(msg: Message) {super.handleMessage(msg)var httpmsg=HttpMessage()var response=msg.obj as retrofit2.Response<ResponseBody>var result=response.body().toString()var resultFormat=getResultFormat(result)when(msg.what){-1->{httpmsg.type=-1callBack(httpmsg)}0->{when(response.code()){200-> {httpmsg.code = resultFormat.code/*** 业务逻辑层面判断成功与失败*/if(resultFormat.code==1000) {httpmsg.type=0httpmsg.msg = resultFormat.msghttpmsg.result = result}else{httpmsg.type=1httpmsg.msg = resultFormat.msghttpmsg.result = result}}500,400,404->{httpmsg.type=-1httpmsg.code=response.code()}}callBack(httpmsg)}}}}fun getResultFormat(json:String):ResultFormat{return JSON.parse(json) as ResultFormat}/*** 默认拦截器。在baseurl改变时进行重定向*/class BaseUrlInterceptor:Interceptor{open override fun intercept(chain: Interceptor.Chain): Response {var request:Request=chain.request()var oldHttpUrl:HttpUrl=request.url()var builder:Request.Builder=request.newBuilder()var newHttpUrl:HttpUrl= HttpUrl.parse(mBaseUrl)!!var httpUrl=oldHttpUrl.newBuilder().scheme(newHttpUrl.scheme()).host(newHttpUrl.host()).port(newHttpUrl.port()).build()return chain.proceed(builder.url(httpUrl).build())}}
}data class ResultFormat(var msg:String,var code:Int)
data class HttpMessage(var type:Int=-1,var code:Int=-1,var msg:String="",var result:String="")
interface CommonHttpService {@HTTP(method="POST",path="{url}",hasBody=true)@Headers("ContentType:application/json;charset=UTF-8")fun post(@Path(value="url",encoded = true) url:String?,@HeaderMap() cookies:HashMap<String,String>,@Body body:RequestBody): Call<ResponseBody>@HTTP(method = "GET", hasBody = false)operator fun get(@Url url: String?): Call<ResponseBody>@HTTP(method = "GET", hasBody = false)operator fun get(@Url url: String?,@HeaderMap tokens: HashMap<String?, String?>?): Call<ResponseBody>@Multipart@HTTP(method = "POST", path = "{url}", hasBody = true)fun postFile(@Path(value = "url", encoded = true) url: String?,@Part parts: List<MultipartBody.Part?>?): Call<ResponseBody>@Multipart@HTTP(method = "POST", path = "{url}", hasBody = true)fun postFile(@Path(value = "url", encoded = true) url: String?,@Header("Cookie") token: String?,@Part parts: List<MultipartBody.Part?>?): Call<ResponseBody>
}
这篇关于retrofit2网络请求的kotlin版本封装的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
