前言：
在android开发中，关于架构的设计，不管是MVC,还是MVP，抑或是MVVM，http的网络请求封装（这里是指二次封装，基于 OkHttp Retrofit 的再封装），前篇文章说的不够仔细。

github也有很多比较优秀的二次封装，本人也收益匪浅，这里我也给大家分享一下我的经验

力求简洁！！！优雅！！！实用！！！

前置：大家对协程 以及 flow 有一定的了解，这里就不说线程与协程的区别了
只需要记住kotlin协程仅仅是线程的框架，仅仅是方便开发者进行异步操作的框架，并没有任何性能优势

ok，开撸

fun <T> launchData(
    scope: CoroutineScope = GlobalScope,
    request: suspend CoroutineScope.() -> Res<T>,
    resp:(T?)->Unit
) {
    scope.launch {
        flow { emit(request()) }      //网络请求
            .flowOn(Dispatchers.IO) //指定请求线程
            .catch { }              // 异常处理
            .collect { resp(it.data)} //数据返回
    }
}

好了，http网络请求封装完毕，谢谢大家！WTF ??? 这就完了，是的，基本思路已经完了。

http请求简单来说就两个过程: 请求与响应 这两个过程具体操作OkHttp已经实现，我们调接口完事了

1: 请求是个消耗资源的操作，所以必须在子线程中进行，request方法就属于IO线程
2: 响应的处理是在主线程进行，协程已经自动切回主线程，resp方法就是在主线程中

android Http获取网络数据的过程就是 请求(IO) + 响应(UI) + 线程切换的过程。
没有那么多弯弯绕绕，秉着这个原则就很好理解与运用了，有了kotlin 协程就更加简洁了。

如果不想用流，只用协程也很简洁
Retrofit + 协程， 一行代码就实现 HTTP请求的封装 简洁的令人发指

 fun <T> launchData(
        scope: CoroutineScope = GlobalScope,
        request: suspend CoroutineScope.() -> Res<T>,
        resp:(T?)->Unit
    ) {
        scope.launch {
             try {
                // 请求数据: 切换到io线程, 数据响应：数据已自动解析并返回数据的同时切换到UI线程
               // 由于协程的特性，result 得到数据会继续在UI线程中向下执行resp方法，整个过程UI线程并不阻塞!!!!
              //  val result = withContext(Dispatchers.IO) { request() }  
              //  resp(result.data)  
               resp(withContext(Dispatchers.IO) { request() }.data)
            } catch (t: Throwable) {
                catchThr(t)  // 异常处理
            }
        }
    }

那具体如何使用呢 三鞭肯定能倒

第一鞭: 使用retrofit UserApi (名字随意 )定义好网络接口

intferface UserApi {
    /**
     * 接化发
     */
    @GET("article/jhf")
    suspend fun jhf():Res<String?>
}

第二鞭: 注入 userApi（单例或者注解都可以）
提示!!!：如果在Activity 发起http请求 scope 建议使用传入 lifecycleScope,
如果在viewmodel 发起请求建议使用viewModelScope ,笔者以后者为例

    /**
     * 接化发
     */
   class viewmodel : BaseViewModel{
      ...
      fun jhf(ok: (String?) -> Unit) {
                             // 请求        响应
          launchData( { userApi.jhf() }, { ok(it) })
          ...或者...
         launchData(
           requset = { userService.jhf() },
           resp    = { ok(it) } 
         )

      }
}

这里userApi.jhf() 就是flow 中 request()方法。ok()方法接收的值就是flow中的resp()方法返回的值，即网络数据返回的结果值。
从数据请求到结果返回，业务层仅需一行代码。

第三鞭：在activity或者fragment直接调用viewmodel中方法，结果直接返回，

class MainActivity : BaseActivity(){
 override fun onCreate(savedInstanceState: Bundle?) {
        ...
        //这里的it 就是网络请求返回的结果
        viewModel.jhf {textView.text = it}
    }
}

三鞭打完!!! 如果 发生网络异常该如何处理呢？

两种处理方式

1 默认弹toast 原先逻辑不变

fun <T> launchData(
    scope: CoroutineScope = GlobalScope,
    request: suspend CoroutineScope.() -> Res<T>,
    resp:(T?)->Unit,
    error:(String)->Unit = {toast(it)}   //toat(“网络异常”)
) {
    scope.launch {
        flow { emit(request()) }      //网络请求
            .flowOn(Dispatchers.IO) //指定请求线程
            .catch { error(e.msg)}  // 异常处理
            .collect { resp(it.data)} //数据返回
    }
}

2 不弹toast 自行处理
在viewmodel 调用的时候这样写

/**
 * 接化发
 */
fun jhf(ok:(String?)->Unit,error: ()->Unit){
    launchData( { userService.jhf() },  { ok(it) }, error  = { error() })
    ...或者...
   launchData(
       request = { userService.jhf() },
       resp    = { ok(it) },
       error   = { error() }
     )
}

在activity或者frament调用的这样写

    viewModel.jhf(
        ok = { textView.text = it},
        error = {  }  // 这里处理异常
    )

或者这样都可以

    viewModel.jhf({ textView.text = it}){
        //这里处理异常
    }

关于协程的取消

//当组件结束时，会取消协程内的任务
override fun onCleared() {
    viewModelScope.cancel()
}

后记

上面的封装剔除了一些状态的判断!!!

关于showLoading ,hideLoading ,以及页面状态的转换都在Base中做了统一处理
具体的代码，笔者已经上传github
https://github.com/ruirui1128/jetpack-hilt-flow-mvvm.git