分享android mvvm 實踐

網(wǎng)上看了好多的android mvvm形式,大多數(shù)都很復(fù)雜,不夠簡潔,造成項目代碼臃腫,邏輯難以梳理,因此分享下自己的mvvm實踐(大多數(shù)來源于優(yōu)秀項目思路的整合,可能不是最優(yōu)的):
1.第一步,當(dāng)然是接口了(kt代碼)

interface ApiService {
    companion object {
        val instance by lazy { RetrofitFactory.create(ApiService::class.java) }
    }

    @Headers("$DOMAIN_NAME_HEADER$BASE_HTTP_URL_NAME")
    @POST("user/login")
    @FormUrlEncoded
    suspend fun login(@FieldMap map: Map<String, String>): ResponseBean<UserBean>
}

其中RetrofitFactory代碼為:

object RetrofitFactory {
    //初始化
    //通用攔截
    private val interceptor: Interceptor by lazy {
        Interceptor { chain ->
            val request = chain.request()
            val builder = request.newBuilder()
            builder.addHeader("X-Client-Platform", "Android")
                .addHeader("X-Client-Version", BuildConfig.VERSION_NAME)
                .addHeader("X-Client-Build", BuildConfig.VERSION_CODE.toString())
                .build()
            chain.proceed(request)
        }
    }

    //Retrofit實例化
    private val retrofit: Retrofit by lazy {
        Retrofit.Builder()
            .baseUrl(Constant.DEFAULT_URL)
            .addConverterFactory(NullOnEmptyConverterFactory())
            .addConverterFactory(CustomConverterFactory.create(ResponseBean::class.java))
            .client(RetrofitUrlManager.getInstance().with(initClient()).build())
            .build()
    }

    /*
        OKHttp創(chuàng)建
     */
    private fun initClient(): OkHttpClient.Builder {
        val sslParams1 = HttpsUtils.getSslSocketFactory()
        return OkHttpClient.Builder()
            .sslSocketFactory(sslParams1.sSLSocketFactory, sslParams1.trustManager)
            .addInterceptor(initLogInterceptor())
            .addInterceptor(interceptor)
            .connectTimeout(30, TimeUnit.SECONDS)
            .readTimeout(30, TimeUnit.SECONDS)

    }

    /*
        日志攔截器
     */
    private fun initLogInterceptor(): HttpLoggingInterceptor {
        val interceptor = HttpLoggingInterceptor()
        interceptor.setPrintLevel(HttpLoggingInterceptor.Level.BODY)
        interceptor.setColorLevel(Level.INFO)
        return interceptor
    }

    /*
        具體服務(wù)實例化
     */
    fun <T> create(service: Class<T>): T {
        return retrofit.create(service)
    }

}

其中header用到了me.jessyan:retrofit-url-manager:1.4.0這個庫,主要作用是多域名配置
2.第二步

object Repository : BaseRepository() {
    suspend fun login(map: Map<String, String>): ResponseBean<UserBean> {
        return apiCall { ApiService.instance.login(map) }
    }
}

其中用到的BaseRepository代碼為:

open class BaseRepository {
    suspend fun <T> apiCall(call: suspend () -> ResponseBean<T>): ResponseBean<T> {
        return call.invoke()
    }


    suspend fun <T> dbCall(call: suspend () -> T): T {
        return call.invoke()
    }

}

3.第三步,就是viewmodel了,代碼如下

class LoginViewModel: BaseViewModel() {
    val mLoginLiveData = StateLiveData<UserBean>()
    fun login(userName:String,password:String){
        if (userName.isEmpty()){
            mLoginLiveData.postError(1,"用戶名不能為空")
            return
        }
        if (password.isEmpty()){
            mLoginLiveData.postError(1,"密碼不能為空")
            return
        }
        val map = hashMapOf<String, String>()
        map["adminLoginName"] = userName
        map["adminPassword"] = password
        launch(mLoginLiveData){
            await { Repository.login(map) }
        }

    }
}

其中用到的BaseViewModel,代碼為:

open class BaseViewModel : ViewModel() {
    fun launch(block: suspend CoroutineScope.() -> Unit) {
        if (!isNetUsable)
            return
        viewModelScope.launch { block() }
    }

    fun <T> launch(
        liveData: StateLiveData<T>,
        tryBlock: suspend CoroutineScope.() -> T
    ) {
        if (!isNetUsable) {
            liveData.postStart()
            liveData.postComplete()
            liveData.postNetError()
            return
        }
        launch {
            tryCatch(liveData, tryBlock)
        }
    }

    private suspend fun <T> tryCatch(
        liveData: StateLiveData<T>,
        tryBlock: suspend CoroutineScope.() -> T
    ) {
        coroutineScope {
            try {
                d("start")
                liveData.postStart()
                d("start-end")
                val response = tryBlock.invoke(this)
                d("success")
                liveData.value = response
                d("parse")
            } catch (e: OperatorException) {
                e.printStackTrace()
                d("fail")
                liveData.postError(e.code, e.msg)
            } catch (e: Exception) {
                if (isDebug) {
                    throw e
                } else {
                    liveData.postError(1, "網(wǎng)絡(luò)連接失敗,請稍候重試!")
                    e.message?.let { d(it) }
                    CrashReport.postCatchedException(e)
                }
            } finally {
                liveData.postComplete()
                d("complete")
            }
        }
    }

}

StateLiveData代碼如下:

class StateLiveData<T> : MutableLiveData<T>() {
    val startState = MutableLiveData<Int>()
    val otherState = MutableLiveData<OtherState>()
    val completeState = MutableLiveData<Int>()
    val error = MutableLiveData<Pair<Int, String?>>()

    fun postStart() {
        if (startState.value != null)
            startState.value = startState.value!! + 1
        else
            startState.value = 1
    }

    fun postComplete() {
        if (completeState.value != null)
            completeState.value = completeState.value!! + 1
        else
            completeState.value = 1
    }

    fun postEmpty() {
        otherState.value = OtherState.EMPTY
    }

    fun postNetError() {
        otherState.value = OtherState.NET_ERROR
    }

    fun postServerError() {
        otherState.value = OtherState.SERVER_ERROR
    }

    fun postTokenError() {
        otherState.value = OtherState.TOKEN_ERROR
    }

    fun postError(errorCode: Int, msg: String?) {
        error.value = errorCode to msg
    }

}

await的代碼如下:

inline fun <reified T> await(responseBean: () -> ResponseBean<T>): T {
    if (!"".isNetUsable)
        throw OperatorException(-2, "網(wǎng)絡(luò)連接失敗,請打開網(wǎng)絡(luò)連接!")
    try {
        val response = responseBean.invoke()
        when (response.code) {
            0 -> {
                return response.data ?: T::class.java.newInstance()
            }
            2000 -> {
                ActivityTask.clearTask()
                Router.withApi(App::class.java).toLogin()
                throw OperatorException(2000, "您的賬號在其它地方登陸，請保管好賬號密碼！")
            }
            else -> {
                if (response.msg?.contains(tokenError) == true) {
                    ActivityTask.clearTask()
                    Router.withApi(App::class.java).toLogin()
                    BaseApplication.instance.toast("您的賬號在其它地方登陸，請保管好賬號密碼！")
                    throw OperatorException(2000, "您的賬號在其它地方登陸，請保管好賬號密碼！")
                } else {
                    throw OperatorException(response.code, response.msg ?: "數(shù)據(jù)解析異常,請聯(lián)系技術(shù)人員解決!")
                }
            }
        }
    } catch (e: OperatorException) {
        throw OperatorException(e.code, e.msg)
    } catch (e: SocketTimeoutException) {
        e.printStackTrace()
        throw OperatorException(-6, "網(wǎng)絡(luò)連接超時,請稍后重試...")
    } catch (e: Exception) {
        e.printStackTrace()
        CrashReport.postCatchedException(e)
        throw OperatorException(-6, "網(wǎng)絡(luò)連接異常！")
    }
}

4.第四步就是activity代碼了,如下

mViewModel.mLoginLiveData.observes(this) {
            onStart {
                LoadingDialog.show(supportFragmentManager, "登錄中")
            }
            onSuccess {
                PreferenceManager.user = it
                PreferenceManager.token = it.userToken!!
              
                //記錄用戶登錄密碼
                PreferenceManager.userLoginInfo = Pair(
                    username.text.toString(),
                    if (isRememberPassword) password.text.toString() else ""
                )
                startActivity<MainActivity>()
                finish()
            }
            onFailed { error, _ ->
                showTipToast(error.toString())
            }
            onNetFail {
                showTipToast("網(wǎng)絡(luò)連接失敗，請檢查網(wǎng)絡(luò)...")
            }
            onServerFail {
                showTipToast("服務(wù)器錯誤，請稍候重試")
            }
            onComplete {
                LoadingDialog.dismiss()
            }
        }

其中自定義擴(kuò)展函數(shù)observes為:

inline fun <reified T> StateLiveData<T>.observes(
    owner: LifecycleOwner,
    dsl: RetrofitCoroutineDsl<T>.() -> Unit
) {
    val request = RetrofitCoroutineDsl<T>()
    request.dsl()
    observe(owner, Observer {
        //這塊千萬不要改，出錯不負(fù)責(zé)
        request.onSuccess?.invoke(it ?: T::class.java.newInstance())
    })
    startState.observe(owner, Observer {
        request.onStart?.invoke()
    })
    otherState.observe(owner, Observer {
        when (it) {
            OtherState.NET_ERROR -> {
                request.onNetFail?.invoke()
            }
            OtherState.SERVER_ERROR -> {
                request.onServerFail?.invoke()
            }
            OtherState.EMPTY -> {
                d("collect observe onempty ${request.onEmpty == null}")
                request.onEmpty?.invoke()
            }
            OtherState.TOKEN_ERROR -> {
                ActivityTask.clearTask()
                Router.withApi(App::class.java).toLogin()
                BaseApplication.instance.toast("您的賬號在其它地方登陸，請保管好賬號密碼！")
            }
            else -> {

            }
        }
    })
    completeState.observe(owner, Observer {
        request.onComplete?.invoke()
    })
    error.observe(owner, Observer {
        if (it?.second?.contains(tokenError) == true) {
            ActivityTask.clearTask()
            Router.withApi(App::class.java).toLogin()
            BaseApplication.instance.toast("您的賬號在其它地方登陸，請保管好賬號密碼！")
        } else {
            request.onFailed?.invoke(it.second, it.first)
        }
    })
}

RetrofitCoroutineDsl代碼為:

enum class OtherState {
    EMPTY, NET_ERROR, SERVER_ERROR, TOKEN_ERROR
}

class RetrofitCoroutineDsl<T> {
    lateinit var api: (ResponseBean<T>)
    var onSuccess: ((T) -> Unit)? = null
    var onEmpty: (() -> Unit)? = null
    var onComplete: (() -> Unit)? = null
    var onStart: (() -> Unit)? = null
    var onNetFail: (() -> Unit)? = null
    var onServerFail: (() -> Unit)? = null
    var onFailed: ((msg: String?, code: Int) -> Unit)? = null

    var showFailedMsg = false

    internal fun clean() {
        onSuccess = null
        onComplete = null
        onFailed = null
        onEmpty = null
        onStart = null
        onNetFail = null
        onServerFail = null
    }

    fun onSuccess(block: (T) -> Unit) {
        this.onSuccess = block
    }

    fun onComplete(block: () -> Unit) {
        this.onComplete = block
    }

    fun onEmpty(block: () -> Unit) {
        d("collect dsl onempty")
        this.onEmpty = block
    }

    fun onStart(block: () -> Unit) {
        this.onStart = block
    }

    fun onNetFail(block: () -> Unit) {
        this.onNetFail = block
    }

    fun onServerFail(block: () -> Unit) {
        this.onServerFail = block
    }

    fun onFailed(block: (error: String?, code: Int) -> Unit) {
        this.onFailed = block
    }

}

其中,采用kt的dsl寫法,按需求,寫你需要的方法
因此你的網(wǎng)絡(luò)請求就很簡單了,就這四步了,這個實踐支持串行請求,只需要這樣寫:

fun login(userName:String,password:String){
        if (userName.isEmpty()){
            mLoginLiveData.postError(1,"用戶名不能為空")
            return
        }
        if (password.isEmpty()){
            mLoginLiveData.postError(1,"密碼不能為空")
            return
        }
        val map = hashMapOf<String, String>()
        map["adminLoginName"] = userName
        map["adminPassword"] = password
        launch(mLoginLiveData){
           val name = await { Repository.getName(xxx) }
           val password = await { Repository.getPassword(xxx) }
           await { Repository.login(name,password) }
        }
    }

可以看到網(wǎng)絡(luò)請求思路清晰,且書寫簡單!!!

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點，簡書系信息發(fā)布平臺，僅提供信息存儲服務(wù)。

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