RxJava+Retrofit+OkHttp + MVP

一、MvpFile(mvp)
  • BaseView
public interface BaseView {
    Context getContext();
}
  • BasePresenter
public interface BasePresenter<V extends BaseView> {
    void attachView(V view);
    void detachView();
}
  • BasePresenterImpl
public class BasePresenterImpl<V extends BaseView> implements BasePresenter<V> {

    protected V mView;

    @Override
    public void attachView(V view) {
        mView = view;
    }

    @Override
    public void detachView() {
        mView = null;
    }
}
  • MVPBaseActivity
public abstract class MVPBaseActivity<V extends BaseView, T extends BasePresenterImpl<V>> extends AppCompatActivity implements BaseView {

    public T mPresenter;

    @Override
    protected void onCreate(@Nullable Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        mPresenter = getInstance(this, 1);
        mPresenter.attachView((V) this);
    }

    @Override
    protected void onDestroy() {
        super.onDestroy();
        if (mPresenter != null)
            mPresenter.detachView();
    }

    @Override
    public Context getContext() {
        return this;
    }

    public <T> T getInstance(Object o, int i) {
        try {
            return ((Class<T>) ((ParameterizedType) (o.getClass()
                    .getGenericSuperclass())).getActualTypeArguments()[i])
                    .newInstance();
        } catch (InstantiationException e) {
            e.printStackTrace();
        } catch (IllegalAccessException e) {
            e.printStackTrace();
        } catch (ClassCastException e) {
            e.printStackTrace();
        }
        return null;
    }
}
  • MVPBaseFragment
public abstract class MVPBaseFragment<V extends BaseView, T extends BasePresenterImpl<V>> extends Fragment implements BaseView {

    public T mPresenter;

    @Override
    public void onCreate(@Nullable Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        mPresenter = getInstance(this, 1);
        mPresenter.attachView((V) this);
    }

    @Override
    public void onDestroy() {
        super.onDestroy();
        if (mPresenter != null)
            mPresenter.detachView();
    }

    @Override
    public Context getContext() {
        return super.getContext();
    }

    public <T> T getInstance(Object o, int i) {
        try {
            return ((Class<T>) ((ParameterizedType) (o.getClass()
                    .getGenericSuperclass())).getActualTypeArguments()[i])
                    .newInstance();
        } catch (InstantiationException e) {
            e.printStackTrace();
        } catch (IllegalAccessException e) {
            e.printStackTrace();
        } catch (ClassCastException e) {
            e.printStackTrace();
        } catch (java.lang.InstantiationException e) {
            e.printStackTrace();
        }
        return null;
    }
}
二、MvpFile(loginactivity)
  • LoginContract
public class LoginContract {

    interface View extends BaseView {
    }

    interface Presenter extends BasePresenter<View> {
    }
}
  • LoginPresenter
public class LoginPresenter extends BasePresenterImpl<LoginContract.View> implements LoginContract.Presenter {
}
  • LoginActivity
public class LoginActivity extends MVPBaseActivity<LoginContract.View, LoginPresenter> implements LoginContract.View {
}
三、Rx-Retrofit
  • 根目录下build.gradle添加仓地址:
allprojects {
    repositories {
        jcenter()
        maven { url 'https://jitpack.io' }
    }
}
  • app目录下build.gradle添加依赖库:
dependencies {
    compile 'com.github.wzgiceman:Rx-Retrofit:v1.0'
}
  • 添加Application并在AndroidManifest中注册
public class MyApplication extends Application {

    // TODO 若BaseUrl全局唯一的需在此处设置,不唯一则设"",并在具体Api中设置BaseUrl
    public static final String APP_BASE_URL = "";

    @Override
    public void onCreate() {
        super.onCreate();
        RxRetrofitApp.init(this, APP_BASE_URL);
    }

}
  • 添加BaseActivity并继承RxAppCompatActivity
public class BaseActivity extends RxAppCompatActivity {

    protected ProgressDialog dialog;

    @Override
    protected void onCreate(@Nullable Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        if (dialog == null) {
            dialog = new ProgressDialog(this);
            dialog.setCancelable(false);
        }
    }

    protected void showLoading() {
        if (dialog != null && !dialog.isShowing()) {
            dialog.show();
        }
    }

    protected void hideLoading() {
        if (dialog != null && dialog.isShowing()) {
            dialog.dismiss();
        }
    }

}
  • 修改MVPBaseActivity继承BaseActivity
四、Package(rxretrofit)
  • LoginService
public interface LoginService {

//    @GET("login/mlogin")
//    Observable<String> getLoginResult(@Query("username") String username,
//                                      @Query("password") String password);

    @FormUrlEncoded
    @POST("login/mlogin")
    Observable<String> getLoginResult(@Field("username") String username,
                                      @Field("password") String password);
}
  • LoginApi
public class LoginApi extends BaseApi {

    public static final String LOGIN_BASE_URL = "";

    private String username;
    private String password;

    public String getUsername() {
        return username;
    }

    public void setUsername(String username) {
        this.username = username;
    }

    public String getPassword() {
        return password;
    }

    public void setPassword(String password) {
        this.password = password;
    }

    public LoginApi() {
        setShowProgress(false);
        setCancel(false);
        setMothed("login/mlogin");
        setCache(false);
        // TODO 若BaseUrl非全局唯一的需在此处设置,全局唯一则在Application中设置BaseUrl
        setBaseUrl(LOGIN_BASE_URL);
    }

    @Override
    public Observable getObservable(Retrofit retrofit) {
        LoginService loginService = retrofit.create(LoginService.class);
        return loginService.getLoginResult(getUsername(), getPassword());
    }

}
五、修改
  • 修改LoginContract
public class LoginContract {

    // TODO ========================================================================================
    interface View extends BaseView {
        void onNext(String result, String method);// 成功回调
        void onError(ApiException e);// 失败回调
        void showLoad();// 显示加载框
        void hideLoad();// 隐藏加载框
    }

    interface Presenter extends BasePresenter<View> {
        void startRequest(RxAppCompatActivity activity, BaseApi api);
    }
    // TODO ========================================================================================

}
  • 修改LoginPresenter实现HttpOnNextListener
public class LoginPresenter extends BasePresenterImpl<LoginContract.View> implements LoginContract.Presenter, HttpOnNextListener {

    // TODO ========================================================================================
    @Override
    public void startRequest(RxAppCompatActivity activity, BaseApi api) {
        mView.showLoad();
        HttpManager manager = new HttpManager(this, activity);
        manager.doHttpDeal(api);
    }

    @Override
    public void onNext(String result, String method) {
        mView.onNext(result, method);
        mView.hideLoad();
    }

    @Override
    public void onError(ApiException e) {
        mView.onError(e);
        mView.hideLoad();
    }
    // TODO ========================================================================================

}
  • 修改LoginActivity
public class LoginActivity extends MVPBaseActivity<LoginContract.View, LoginPresenter> implements LoginContract.View, View.OnClickListener {

    // TODO ========================================================================================
    private EditText etUsername;
    private EditText etPassword;
    private TextView tvLog;

    @Override
    protected void onCreate(@Nullable Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_login);
        initView();
    }

    private void initView() {
        etUsername = (EditText) findViewById(R.id.activity_login_et_username);
        etPassword = (EditText) findViewById(R.id.activity_login_et_password);
        tvLog = (TextView) findViewById(R.id.activity_login_tv_log);
        findViewById(R.id.activity_login_btn_login).setOnClickListener(this);
    }

    @Override
    public void onClick(View view) {
        startRequest();
    }

    private void startRequest() {
        LoginApi api = new LoginApi();
        api.setUsername(etUsername.getText().toString().trim());
        api.setPassword(etPassword.getText().toString().trim());
        mPresenter.startRequest(this, api);
    }

    @Override
    public void onNext(String result, String method) {
        String succeed = "成功>>>>>>>>>>>>>>>>>>>>"
                + "\n---------- result\n" + result
                + "\n---------- method\n" + method
                + "\n<<<<<<<<<<<<<<<<<<<<";
        tvLog.setText(succeed);
        Log.e("lstar", succeed);
    }

    @Override
    public void onError(ApiException e) {
        String failed = "失败>>>>>>>>>>>>>>>>>>>>"
                + "\n---------- code\n" + e.getCode()
                + "\n---------- message\n" + e.getMessage()
                + "\n<<<<<<<<<<<<<<<<<<<<";
        tvLog.setText(failed);
        Log.e("lstar", failed);
    }

    @Override
    public void showLoad() {
        showLoading();
    }

    @Override
    public void hideLoad() {
        hideLoading();
    }
    // TODO ========================================================================================

}

如何设计一个靠谱的MVP架构
Android MVP Plugin,一键完成MVP结构代码编写
Android RxJava之网络处理
Rx-Retrofit极简方式使用
RxJava+Retrofit+OkHttp深入浅出-mvp(使用篇)
RxJava+Retrofit+OkHttp深入浅出-mvp(使用篇)Demo

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 216,287评论 6 498
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 92,346评论 3 392
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 162,277评论 0 353
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 58,132评论 1 292
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 67,147评论 6 388
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 51,106评论 1 295
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 40,019评论 3 417
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,862评论 0 274
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 45,301评论 1 310
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,521评论 2 332
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,682评论 1 348
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,405评论 5 343
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,996评论 3 325
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,651评论 0 22
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,803评论 1 268
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,674评论 2 368
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,563评论 2 352

推荐阅读更多精彩内容