Android MVP 利用rxjava 避免向Model传入监听方法

传统的MVP:

1、抽离出View的接口,即ILoginView。

2、抽离Model的接口,即ILoginModel。

3、抽离Presenter的接口,即ILoginPresenter。

4、实现ILoginView 接口的 LoginActivity。

5、实现ILoginModel 接口的 LoginModel。

6、实现ILoginPresenter 接口的 LoginPresenter。

LoginActivity:实现ILoginView 接口以及初始化ILoginPresenter

 public class LoginActivity extends BaseActivity implements ILoginView {
private ILoginPresenter mPresenter; @Override
public void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_login); mPresenter = new LoginPresenter(this);
} public void onUserLogin(View view) { mPresenter.login(userName, password);
}
}

LoginPresenter:

public class LoginPresenter implements ILoginPresenter {

    private ILoginView mView;
private ILoginModel mModel; public LoginPresenter() {
init();
} public LoginPresenter(ILoginView view) {
mView = view;
init();
} private void init() {
mModel = new LoginModel(this);
}
}

下面改造后抽离后的MVP:

1、抽离出View的接口,即LoginView。

2、抽离Model的接口:使用rxjava 可以避免传入各种CallBack进行结果返回。

  (1)网络层:LoginRepository。

  (2)数据缓存层:LoginCache。

3、根据Model 层,抽离 Presenter层 :LoginPresenter。

4、实现LoginView 接口的 LoginActivity。

5、实现LoginRepository 接口的 LoginRepositoryImpl。

6、(如需要数据缓存,以及缓存操作的)实现LoginCache 接口的 LoginCacheImpl。

7、实现LoginPresenter 接口的 LoginPresenterImpl。

下面例子:

(1)用户界面输入用户名密码,点击登录按钮,出现进度条,进行接口请求.

(2)登陆成功,进度条消失,跳转.

(3)登陆失败,进度条消失,Toast失败原因

布局文件:

 <LinearLayout
xmlns:android="http://schemas.android.com/apk/res/android"
xmlns:tools="http://schemas.android.com/tools"
android:layout_width="match_parent"
android:layout_height="match_parent"
android:orientation="vertical"tools:context=".MainActivity"> <EditText
android:layout_width="match_parent"
android:id="@+id/et_username"
android:hint="input user name"
android:layout_height="wrap_content" /> <EditText
android:layout_width="match_parent"
android:id="@+id/et_password"
android:hint="input user password"
android:layout_height="wrap_content" /> <Button
android:layout_width="match_parent"
android:layout_height="wrap_content"
android:onClick="onUserLogin"
android:text="登录"/> </LinearLayout>

View :

 public interface LoginView {

        void showProgress();

        void dismissProgress();

        void onLoginFail(String error);

        void goToActivity();
}

Activity :

 public class LoginActivity extends AppCompatActivity implements LoginView {

         private EditText userNameEdit;
private EditText pwdEdit;
private ProgressDialog dialog; private LoginPresenter presenter = new LoginPresenterImpl(this); @Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_login);
initViews();
} private void initViews() {
userNameEdit = (EditText) findViewById(R.id.tv_username);
pwdEdit = (EditText) findViewById(R.id.tv_password);
} public void onUserLogin(View v){
String userName = userNameEdit.getText().toString().trim(); String password = pwdEdit.getText().toString().trim();
presenter.login(userName, password);// 登录
} @Override
public void showProgress() {
if(dialog==null){
dialog = ProgressDialog.show(this,"","loading...");
}else{
if(!dialog.isShowing()){
dialog.show();
}
}
} @Override
public void dismissProgress() {
if(dialog!=null&&dialog.isShowing()){
dialog.dismiss();
}
} @Override
public void onLoginFail(final String error) {
// 提示登录失败
} @Override
public void goToActivity() {
// 登录成功跳转到其他页面
}
}

Model,网络层:

public interface LoginReposity {
// 在网络请求当中,可以一个模块一个Repository
// 在数据缓存当中,可以一个模块一个Cache
Observable<JSONObject> login(String userName,String password);
}

Model,网络层实现类:

public class LoginReposityImpl  {

    public LoginRepositoryImpl(){}

    @Override
public Observable<JSONObject> login() {
return Observable.create(new Observable.OnSubscribe<JSONObject>() {
@Override
public void call(Subscriber<? super JSONObject> subscriber) {
// 模拟请求登录成功返回json数据
JSONObject json = new JSONObject();
subscriber.onNext(json);
subscriber.onCompleted();
}
});
}
}

Presenter:

 public interface LoginPresenter {

     void login(String userName, String password);
}

presenter实现类:

 public class LoginPresenterImpl implements LoginPresenter {

     private LoginRepository repository;

     private LoginView view;

     public LoginPresenterImpl(LoginView _view){
view = _view;
repository = new LoginRepositoryImpl();
} public void login(String userName, String password){ if(TextUtils.isEmpty(userName)||TextUtils.isEmpty(password)){
view.onLoginFail("请完善登录信息");
return;
}
view.showProgress();
repository.login(userName, password)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Subscriber<Boolean>() {
@Override
public void onCompleted() { } @Override
public void onError(Throwable e) {
view.dismissProgress();
view.onLoginFail(error.getMessage());
} @Override
public void onNext(Boolean aBoolean) {
view.dismissProgress();
view.goToActivity();
}
}));
}
}
上一篇:android CheckBox控件的定义及事件监听


下一篇:Android开发之手势滑动(滑动手势监听)详解