前言

kotlin系统学习：http://www.jianshu.com/u/5509a21c1623
retrofit学习：http://www.jianshu.com/p/3e13e5d34531
rxjava学习：http://www.jianshu.com/p/464fa025229e
mvp学习：http://blog.csdn.net/lmj623565791/article/details/46596109
Kotlin+Retrofit+RxJava+MVP封装（二）
Kotlin+Retrofit+RxJava+MVP封装（三）

MVP简介

mvp和mvc.png

我们可以对mvp进行一个简单的理解，mvp分别为：
model:处理业务逻辑
view:展示视图
presenter:中间人（绑定view和model）
那么view和presenter之间是通过接口进行交互，这样能够降低耦合，方便进行单元测试。

实现一个简单的登录demo

我们先看一下目录结构：

目录结构.png

需要导入的第三方库：

   /*网络依赖*/
    compile 'com.squareup.retrofit2:retrofit:2.1.0'
    compile 'com.squareup.retrofit2:adapter-rxjava:2.1.0'
    compile 'com.squareup.retrofit2:converter-gson:2.1.0'
    compile 'com.squareup.okhttp3:okhttp:3.2.0'
    compile 'com.squareup.okhttp3:logging-interceptor:3.2.0'
    compile 'com.squareup.okhttp3:okhttp-urlconnection:3.4.1'
   /*rxjava*/
    compile 'io.reactivex:rxandroid:1.1.0'
    compile 'io.reactivex:rxjava:1.1.0'
   /*图片处理（glide）*/
    compile 'com.github.bumptech.glide:glide:3.7.0'

view interface及activity实现

使用kotlin创建interface和activity

创建activity和interface.png 登录界面.png

如大多数登录界面所示，在登录时我们需要输入用户名和密码，以及点击登录按钮过后的一个监听回调，所以在写接口时我们需要三样东西：

interface LoginView :BaseView{

    fun getUserName(): String//获取用户名
    fun getPassWord(): String//获取密码
    fun LoginSuccess(baseBean: BaseBean)//登录成功
    fun LoginFailed(baseBean: BaseBean)//登录失败

}

我们在activity中实现以上接口，对界面做出相应操作:

override fun getUserName(): String {
        return "test"
    }

    override fun getPassWord(): String {
        return "111111"
    }

    override fun LoginSuccess(baseBean: BaseBean) {
        LoadingDis()
        openActivity(MoneyDetailActivity::class.java)
        Toast.makeText(this,"成功"+baseBean.message,Toast.LENGTH_SHORT).show()

    }

    override fun LoginFailed(baseBean: BaseBean) {
        LoadingDis()
        Toast.makeText(this,"失败"+baseBean.message,Toast.LENGTH_SHORT).show()

    }

以上，我们创建完了对应的activity以及接口，相应的我们需要去处理逻辑的Model以及把model和view相关联的presenter。

Model实现

因为model是逻辑处理的，所以在登录时需要做出登录的逻辑操作和登录过后的返回动作，

interface LoginModel {
    //登录
    fun Login(username:String,password:String)
    / /登录完成过后的接口
    fun LoadComplete(onLoginListener: OnLoginListener)
    interface OnLoginListener{
        fun LoginSuccess(baseBean: BaseBean)
        fun LoginFailed(baseBean: BaseBean)
    }
}

然后我们写好相对应的实现类，实现上面的接口，进行一个具体的操作：

class LoginModeImpl: LoginModel, BaseModel<BaseBean>() {
//取到RetrofitManager中的service
    override fun ServiceParams(params: HashMap<String, String>): Observable<BaseBean> {
        return RetrofitManager.builder().service!!.getRegisterList(params)
    }


    //var mOnLoginListenr:LoginPresenter.onLoginListener?=null
    var mOnLoginListener: LoginModel.OnLoginListener?=null
    var mUserName:String?=null
    var mPassWord:String?=null

//失败过后的操作
    override fun FailedOperation(e: Throwable?) {

    }
//声明监听接口
    override fun LoadComplete(onLoginListener: LoginModel.OnLoginListener) {
        if(mOnLoginListener==null){
            mOnLoginListener=onLoginListener
        }
    }

//登录成功过后的操作
    override fun SuccessOperation(o: BaseBean) {
       // val message = o.message
        if(o.success){
            mOnLoginListener!!.LoginSuccess(o)

        }else{
            mOnLoginListener!!.LoginFailed(o)
        }
    }
//需要传入的参数
    override fun Params(): HashMap<String, String>? {
        ClearHashMap()
        mParams!!.put("username",mUserName!!)
        mParams!!.put("password",mPassWord!!)
        return mParams
    }

//进行的登录操作
    override fun Login(username: String, password: String) {
        mUserName=username
        mPassWord=password
        PostParams()

    }
}

因为我对Model进行了一个简单的封装，可能有点看不懂，我把basemodel的代码也贴出来，这样便于理解：

abstract class BaseModel <T:BaseBean>{

//需要传入的参数
    var mParams:HashMap<String,String>?=HashMap()
//进行数据请求
    open fun PostParams(){
        ServiceParams(Params()!!)
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe (object : Subscriber<BaseBean>() {
                    override fun onCompleted() {
                        Completed()
                    }

                    override fun onError(e: Throwable?) {
                        FailedOperation(e)
                    }

                    override fun onNext(o: BaseBean) {
                       // val message = o.message
                        //mOnLoginListenr?.LoginSuccess()
                        SuccessOperation(o)
                    }
                })
    }

    open fun Completed() {

    }

    abstract fun FailedOperation(e: Throwable?)



    abstract fun SuccessOperation(o: BaseBean)


    abstract fun Params(): HashMap<String, String>?
//得到rxjava中的Observable
    abstract fun ServiceParams(params: HashMap<String, String>): Observable<T>

    open fun ClearHashMap(){
        if (mParams!!.size>0)
            mParams!!.clear()
    }


}

到此，我们的view和model都已经实现了，那么就得通过presenter来进行绑定、交互了。

Presenter实现

presenter来绑定view和model，那么显然，presenter将持有view和model的一个对象，比较简单，直接贴代码：

class LoginPresenterxx(val loginView: LoginView): BasePresenter<LoginView>() {

    var loginmode:LoginModel?=null

    init {
        loginmode= LoginModeImpl()
    }

    fun Login(username: String, password: String){
        loginmode!!.Login(username,password)

        loginmode!!.LoadComplete(object : LoginModel.OnLoginListener {
            override fun LoginSuccess(baseBean: BaseBean) {
                loginView.LoginSuccess(baseBean)
            }

            override fun LoginFailed(baseBean: BaseBean) {
                loginView.LoginFailed(baseBean)
            }
        })
    }
}

至此，关于mvp的一部分差不多就这些了，小结一哈：
1.首先对应功能需求实现view就对应的activity；
2.对应逻辑需求实现Model和ModelImpl;
3.通过各自接口，实现presenter，实现model和view的交互。

Retrofit+RxJava实现

//retrofit的一个初始化
initOkHttpclient()
        var retrofit = Retrofit.Builder()
                .baseUrl(Constants.BASE_URL)
                .client(mOkHttpClient)
                .addCallAdapterFactory(RxJavaCallAdapterFactory.create())
                .addConverterFactory(GsonConverterFactory.create())
                .build()

        service = retrofit.create(RetrofitService::class.java)

//对okhttp的一个初始化
    fun initOkHttpclient() {
        //log信息拦截器
        val interceptor = HttpLoggingInterceptor()
   
        interceptor.level = HttpLoggingInterceptor.Level.BODY
        if (mOkHttpClient == null) {
            mOkHttpClient = OkHttpClient.Builder()
      
                    .retryOnConnectionFailure(true)
                    .addNetworkInterceptor(this)
                    .addInterceptor(this)
                    .connectTimeout(15, TimeUnit.SECONDS)
                    .readTimeout(10000L, TimeUnit.MILLISECONDS)//读操作超时时间
                    .cookieJar(CookiesManager())//设置长久存在的cookie
                    .build()
        }
    }
//定义的接口类
interface RetrofitService {

    //登录
    @FormUrlEncoded
    @POST("/app/common/login.html")
    fun getRegisterList(@FieldMap params: HashMap<String, String>): Observable<BaseBean>
}
//通过rxjava处理线程切换
ServiceParams(Params()!!)
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe (object : Subscriber<BaseBean>() {
                    override fun onCompleted() {
                        Completed()
                    }

                    override fun onError(e: Throwable?) {
                        FailedOperation(e)
                    }

                    override fun onNext(o: BaseBean) {
                       // val message = o.message
                        //mOnLoginListenr?.LoginSuccess()
                        SuccessOperation(o)
                    }
                })

小结：
1.创建一个Retrofit;
2.创建接口，通过Retrofit获取实例；
3.结合Rxjava，实现线程切换，逻辑更加流畅。

总结

在这篇文章中，是对Kotlin+Retrofit+RxJava+MVP的一个简单实现，如果需要补基础的话可以借鉴前言的博客或者简书。这篇简书没有相对应的源码，因为后续会在这篇文章的基础上对源码进行封装以及Recyclerview的实现和封装，待续......