前言
最近有個新項目要做钾菊，搭建框架的時候溃槐，順便梳理了下MVP模式匣砖，特此記錄，歡迎大家指正昏滴。
- 【Android架構(gòu)】基于MVP模式的Retrofit2+RXjava封裝（一）
- 【Android架構(gòu)】基于MVP模式的Retrofit2+RXjava封裝之文件下載（二）
- 【Android架構(gòu)】基于MVP模式的Retrofit2+RXjava封裝之文件上傳（三）
- 【Android架構(gòu)】基于MVP模式的Retrofit2+RXjava封裝之常見問題（四）
- 【Android架構(gòu)】基于MVP模式的Retrofit2+RXjava封裝之?dāng)帱c下載（五）
- 【Android架構(gòu)】基于MVP模式的Retrofit2+RXjava封裝之?dāng)?shù)據(jù)預(yù)處理（六）
- 【Android架構(gòu)】基于MVP模式的Retrofit2+RXjava封裝之多Url（七）
一 猴鲫、首先是依賴
compile 'com.google.code.gson:gson:2.8.0'
compile 'com.squareup.okhttp3:okhttp:3.4.1'
compile 'com.squareup.retrofit2:retrofit:2.3.0'
compile 'io.reactivex.rxjava2:rxandroid:2.0.1'
compile 'io.reactivex.rxjava2:rxjava:2.1.5'
//ConverterFactory的String依賴包
compile 'com.squareup.retrofit2:converter-scalars:2.3.0'
//ConverterFactory的Gson依賴包
compile 'com.squareup.retrofit2:converter-gson:2.3.0'
//CallAdapterFactory的Rx依賴包
compile 'com.squareup.retrofit2:adapter-rxjava2:2.3.0'
二、ApiServer谣殊，定義了一些接口
public interface ApiServer {
@POST("shopping_login.htm")
Observable<String> LoginByRx(@Field("username") String username, @Field("password") String password);
}
三拂共、ApiRetrofit，初始化Retrofit姻几、OkHttpClient宜狐，加入了攔截器
public class ApiRetrofit {
public final String BASE_SERVER_URL = "https://wawa-api.vchangyi.com/";
private static ApiRetrofit apiRetrofit;
private Retrofit retrofit;
private OkHttpClient client;
private ApiServer apiServer;
private String TAG = "ApiRetrofit";
/**
* 請求訪問quest
* response攔截器
*/
private Interceptor interceptor = new Interceptor() {
@Override
public Response intercept(Chain chain) throws IOException {
Request request = chain.request();
long startTime = System.currentTimeMillis();
Response response = chain.proceed(chain.request());
long endTime = System.currentTimeMillis();
long duration = endTime - startTime;
MediaType mediaType = response.body().contentType();
String content = response.body().string();
Log.e(TAG, "----------Request Start----------------");
Log.e(TAG, "| " + request.toString() + request.headers().toString());
Log.e(TAG, "| Response:" + content);
Log.e(TAG, "----------Request End:" + duration + "毫秒----------");
return response.newBuilder()
.body(ResponseBody.create(mediaType, content))
.build();
}
};
public ApiRetrofit() {
client = new OkHttpClient.Builder()
//添加log攔截器
.addInterceptor(interceptor)
.connectTimeout(10, TimeUnit.SECONDS)
.readTimeout(10, TimeUnit.SECONDS)
.build();
retrofit = new Retrofit.Builder()
.baseUrl(BASE_SERVER_URL)
.addConverterFactory(GsonConverterFactory.create())
.addConverterFactory(ScalarsConverterFactory.create())
//支持RxJava2
.addCallAdapterFactory(RxJava2CallAdapterFactory.create())
.client(client)
.build();
apiServer = retrofit.create(ApiServer.class);
}
public static ApiRetrofit getInstance() {
if (apiRetrofit == null) {
synchronized (Object.class) {
if (apiRetrofit == null) {
apiRetrofit = new ApiRetrofit();
}
}
}
return apiRetrofit;
}
public ApiServer getApiService() {
return apiServer;
}
}
四、基類
1.BaseView蛇捌，其中定義了常用的接口
public interface BaseView {
/**
* 顯示dialog
*/
void showLoading();
/**
* 隱藏 dialog
*/
void hideLoading();
/**
* 顯示錯誤信息
*
* @param msg
*/
void showError(String msg);
/**
* 錯誤碼
*/
void onErrorCode(BaseModel model);
}
2.BaseModel
public class BaseModel<T> implements Serializable {
private int errcode;
private String errmsg;
private T result;
public int getErrcode() {
return errcode;
}
public void setErrcode(int errcode) {
this.errcode = errcode;
}
public String getErrmsg() {
return errmsg;
}
public void setErrmsg(String errmsg) {
this.errmsg = errmsg;
}
public T getResult() {
return result;
}
public void setResult(T result) {
this.result = result;
}
}
3.BasePresenter
public class BasePresenter<V extends BaseView> {
private CompositeDisposable compositeDisposable;
public V baseView;
protected ApiServer apiServer = ApiRetrofit.getInstance().getApiService();
public BasePresenter(V baseView) {
this.baseView = baseView;
}
/**
* 解除綁定
*/
public void detachView() {
baseView = null;
removeDisposable();
}
/**
* 返回 view
*
* @return
*/
public V getBaseView() {
return baseView;
}
public void addDisposable(Observable<?> observable, BaseObserver observer) {
if (compositeDisposable == null) {
compositeDisposable = new CompositeDisposable();
}
compositeDisposable.add(observable.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribeWith(observer));
}
public void removeDisposable() {
if (compositeDisposable != null) {
compositeDisposable.dispose();
}
}
}
4.BaseObserver抚恒，主要處理了常見的錯誤
public abstract class BaseObserver<T> extends DisposableObserver<T> {
protected BaseView view;
/**
* 解析數(shù)據(jù)失敗
*/
public static final int PARSE_ERROR = 1001;
/**
* 網(wǎng)絡(luò)問題
*/
public static final int BAD_NETWORK = 1002;
/**
* 連接錯誤
*/
public static final int CONNECT_ERROR = 1003;
/**
* 連接超時
*/
public static final int CONNECT_TIMEOUT = 1004;
public BaseObserver(BaseView view) {
this.view = view;
}
@Override
protected void onStart() {
if (view != null) {
view.showLoading();
}
}
@Override
public void onNext(T o) {
try {
BaseModel model = (BaseModel) o;
if (model.getErrcode() == 0) {
onSuccess(o);
} else {
if (view != null) {
view.onErrorCode(model);
}
}
} catch (Exception e) {
e.printStackTrace();
onError(e.toString());
}
}
@Override
public void onError(Throwable e) {
if (view != null) {
view.hideLoading();
}
if (e instanceof HttpException) {
// HTTP錯誤
onException(BAD_NETWORK);
} else if (e instanceof ConnectException
|| e instanceof UnknownHostException) {
// 連接錯誤
onException(CONNECT_ERROR);
} else if (e instanceof InterruptedIOException) {
// 連接超時
onException(CONNECT_TIMEOUT);
} else if (e instanceof JsonParseException
|| e instanceof JSONException
|| e instanceof ParseException) {
// 解析錯誤
onException(PARSE_ERROR);
} else {
if (e != null) {
onError(e.toString());
} else {
onError("未知錯誤");
}
}
}
private void onException(int unknownError) {
switch (unknownError) {
case CONNECT_ERROR:
onError("連接錯誤");
break;
case CONNECT_TIMEOUT:
onError("連接超時");
break;
case BAD_NETWORK:
onError("網(wǎng)絡(luò)問題");
break;
case PARSE_ERROR:
onError("解析數(shù)據(jù)失敗");
break;
default:
break;
}
}
@Override
public void onComplete() {
if (view != null) {
view.hideLoading();
}
}
public abstract void onSuccess(T o);
public abstract void onError(String msg);
}
5.BaseActivity，實現(xiàn)BaseView络拌，統(tǒng)一處理了Presenter的解綁與綁定俭驮。
public abstract class BaseActivity<P extends BasePresenter> extends AppCompatActivity implements BaseView {
public Context context;
private ProgressDialog dialog;
public Toast toast;
protected P presenter;
protected abstract P createPresenter();
protected abstract int getLayoutId();
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
context = this;
setContentView(getLayoutId());
presenter = createPresenter();
initView();
initData();
}
public void initData() {
}
public void initView() {
}
@Override
protected void onDestroy() {
super.onDestroy();
//銷毀時，解除綁定
if (presenter != null) {
presenter.detachView();
}
}
/**
* @param s
*/
public void showtoast(String s) {
if (toast == null) {
toast = Toast.makeText(getApplicationContext(), s, Toast.LENGTH_LONG);
}
toast.show();
}
private void closeLoadingDialog() {
if (dialog != null && dialog.isShowing()) {
dialog.dismiss();
}
}
private void showLoadingDialog() {
if (dialog == null) {
dialog = new ProgressDialog(context);
}
dialog.setCancelable(false);
dialog.show();
}
@Override
public void showLoading() {
showLoadingDialog();
}
@Override
public void hideLoading() {
closeLoadingDialog();
}
@Override
public void showError(String msg) {
showtoast(msg);
}
@Override
public void onErrorCode(BaseModel model) {
}
@Override
public void showLoadingFileDialog() {
showFileDialog();
}
@Override
public void hideLoadingFileDialog() {
hideFileDialog();
}
@Override
public void onProgress(long totalSize, long downSize) {
if (dialog != null) {
dialog.setProgress((int) (downSize * 100 / totalSize));
}
}
}
如上春贸，框架已經(jīng)搭建好了混萝，讓我們來看看在實際項目中怎么用遗遵。
我們來模擬登陸
1.定義LoginView 繼承于BaseView
public interface LoginView extends BaseView {
void onLoginSucc();
}
2.定義LoginPresenter繼承于BasePresenter
public class LoginPresenter extends BasePresenter<LoginView> {
public LoginPresenter(LoginView baseView) {
super(baseView);
}
public void login(String name, String pwd) {
addDisposable(apiServer.LoginByRx(name, pwd), new BaseObserver(baseView) {
@Override
public void onSuccess(Object o) {
baseView.onLoginSucc();
}
@Override
public void onError(String msg) {
baseView.showError(msg);
}
});
}
}
3.LoginActivity 中使用
public class LoginActivity extends BaseActivity<LoginPresenter> implements LoginView {
private AutoCompleteTextView mEmailView;
private EditText mPasswordView;
@Override
protected LoginPresenter createPresenter() {
return new LoginPresenter(this);
}
@Override
protected int getLayoutId() {
return R.layout.activity_login;
}
@Override
public void initView() {
mEmailView = (AutoCompleteTextView) findViewById(R.id.email);
mPasswordView = (EditText) findViewById(R.id.password);
Button mEmailSignInButton = (Button) findViewById(R.id.email_sign_in_button);
mEmailSignInButton.setOnClickListener(new OnClickListener() {
@Override
public void onClick(View view) {
//示例代碼，示例接口
presenter.login(mEmailView.getText().toString(), mPasswordView.getText().toString());
}
});
}
@Override
public void onLoginSucc() {
//Login Succ
showtoast("登錄成功");
}
}
