在上一篇我们搭建了简单的MVVM项目,并使用玩安卓API(感谢鸿洋),实现了一个简单的banner的广告功能。这篇,我们要在上一篇的基础上去优化
从零开始搭建MVVM架构系列文章(持续更新):
Android从零开始搭建MVVM架构(1)————DataBinding
Android从零开始搭建MVVM架构(2)————ViewModel
Android从零开始搭建MVVM架构(3)————LiveData
Android从零开始搭建MVVM架构(4)————Room(从入门到进阶)
Android从零开始搭建MVVM架构(5)————Lifecycles
Android从零开始搭建MVVM架构(6)————使用玩Android API带你搭建MVVM框架(初级篇)
Android从零开始搭建MVVM架构(7) ———— 使用玩Android API带你搭建MVVM框架(终极篇)
一、拓展LiveData的功能。
在上篇,我们发现只有接口请求成功了的操作。我们正常项目中还会有,showloading、hideloading、联网失败,而且还有即使联网成功也有可能没有走通逻辑,如:关注失败。等等,那么一个LiveData只有一个onChange回调,怎么?
拓展LiveData<T>,泛型里我们是可以随便更改的,我们新建一个Resource类,和我们之前的ResponModel几乎一样,唯一有区别的是Resource类里有很多状态,来区分到底走的哪个。
public class Resource<T> {
//状态 这里有多个状态 0表示加载中;1表示成功;2表示联网失败;3表示接口虽然走通,但走的失败(如:关注失败)
public static final int LOADING = 0;
public static final int SUCCESS = 1;
public static final int ERROR = 2;
public static final int FAIL = 3;
public static final int PROGRESS = 4;//注意只有下载文件和上传图片时才会有
public int state;
public String errorMsg;
public T data;
public Throwable error;
//这里和文件和进度有关了
public int precent;//文件下载百分比
public long total;//文件总大小
//这里定义我们状态的回调
public interface OnHandleCallback<T> {
void onLoading(String showMessage);
void onSuccess(T data);
void onFailure(String msg);
void onError(Throwable error);
void onCompleted();
void onProgress(int precent,long total);
}
//...省略部分代码,便于理解
//这里是判断,接口走通了,是否走了该走的逻辑,玩android api规则是code =0,算成功
public static <T> Resource<T> response(ResponModel<T> data) {
if (data != null) {
if (data.isSuccess()) {
return new Resource<>(SUCCESS, data.getData(), null);
}
return new Resource<>(FAIL, null, data.getErrorMsg());
}
return new Resource<>(ERROR, null, null);
}
public static <T> Resource<T> failure(String msg) {
return new Resource<>(ERROR, null, msg);
}
public static <T> Resource<T> error(Throwable t) {
return new Resource<>(ERROR, t);
}
public static <T> Resource<T> progress(int precent, long total) {
return new Resource<>(PROGRESS, precent, total);
}
public void handler(OnHandleCallback<T> callback) {
switch (state) {
case LOADING:
callback.onLoading(errorMsg);
break;
case SUCCESS:
callback.onSuccess(data);
break;
case FAIL:
callback.onFailure(errorMsg);
break;
case ERROR:
callback.onError(error);
break;
case PROGRESS:
callback.onProgress(precent,total);
break;
}
if (state != LOADING) {
callback.onCompleted();
}
}
}
加上这个Resource后,我们再想想,这些回调回来了。不可能每一个去处理,所以我们要想办法把统一操作放在Base里,而且还能随意被重写的。因为要showLoading,那就在BaseActivity里来个抽象类,实现我们Resource里的接口回调。这里为什么选择抽象类,因为抽象类实现接口后,需要父类统一操作的可以写在方法体内,不需要操作的甚至可以不操作,留给子类操作。如果子类不需要父类的统一操作,可以主动重写那个方法,并且把super()代码去掉。
//这个是BaseActivity里的内部类
public abstract class OnCallback<T> implements Resource.OnHandleCallback<T> {
@Override
public void onLoading(String msg) {
//统一操作 showLoading
}
@Override
public void onError(Throwable throwable) {
//统一操作联网失败
}
@Override
public void onFailure(String msg) {
//接口走通了,但是code 不等于0
}
@Override
public void onCompleted() {
//统一关闭 hideLoading
}
@Override
public void onProgress(int precent, long total) {
//这是上传图片和下载文件才需要的。
}
}
这些做完之后,再来看看我们现在的banner的网络请求,
public MutableLiveData<Resource<List<BannerBean>>> getBanners(){
final MutableLiveData<Resource<List<BannerBean>>> liveData = new MutableLiveData<>();
RetrofitManager.getInstance().getApiService().getBanner()
.subscribeOn(Schedulers.io())
.doOnSubscribe(new Consumer<Disposable>() {
@Override
public void accept(Disposable disposable) throws Exception {
//showLoading,后面传参,是loading显示文字配用
liveData.postValue(Resource.<List<BannerBean>>loading(""));
}
})
.subscribe(new Consumer<ResponModel<List<BannerBean>>>() {
@Override
public void accept(ResponModel<List<BannerBean>> listResponModel) throws Exception {
//成功
liveData.postValue(Resource.success(listResponModel.getData()));
}
}, new Consumer<Throwable>() {
@Override
public void accept(Throwable throwable) throws Exception {
//失败
liveData.postValue(Resource.<List<BannerBean>>error(throwable));
}
});
return liveData;
}
而在我们的Activity里,是这样
//因为我BaseActivity里的OnCallback,没有实现onSuccess方法,这里会主动实现
//比如我们BaseActivity里的OnCallback里,失败的时候,Toast一句话,这个时候我们不需要Toast,想要自己实现,那就重写他,注意注释super
mViewModel.getBanner().observe(this, new Observer<Resource<List<BannerBean>>>() {
@Override
public void onChanged(Resource<List<BannerBean>> listResource) {
listResource.handler(new OnCallback<List<BannerBean>>() {
@Override
public void onSuccess(List<BannerBean> data) {
}
});
}
});
上面的代码,看起来很复杂一样,使用lambda表达式试试,变化如下(你会发现请求网络和网络回调,就用这几句代码搞定了,真的是很链式编程!!):
mViewModel.getBanner().observe(this, resource -> resource.handler(new OnCallback<List<BannerBean>>() {
@Override
public void onSuccess(List<BannerBean> data) {
updateBanner(data);
}
}));
二、增加Model层
很多项目用Repository命名,数据仓库层。Model层是个概念,想用什么命名都行。为什么要添加这一层呢?先看上面ViewModel里,联网操作,不同的是Restrofit的接口 RetrofitApiService,其他基本都一致的。那么我们要让ViewModel成为类似MVP中契约类的功能,人家只要看你的ViewModel,就知道有哪些逻辑和功能了。BaseModel如下(这里RxJava + Retrofit的封装用的我之前的一个封装,这里对这方面不多讲的,本文在 此前做了些许改变,点击这里查看)
//BaseModel里我封装了很多,比如文件下载,上传,这里省略了部分代码,便于理解
public abstract class BaseModel {
//解决RxJava可能存在的内存泄漏
public LifecycleTransformer objectLifecycleTransformer;
//离开页面,是否取消网络
public CompositeDisposable compositeDisposable;
//如果开启,同一url还在请求网络时,不会
public ArrayList<String> onNetTags;
public RetrofitApiService getApiService() {
return RetrofitManager.getRetrofitManager().getApiService();
}
//把统一操作全部放在这,ParamsBuilder是我定义的一个参数,需不需要Loading,loadingmessage,需不需要重连都在这里。
//不传的话,都是默认值。封装好后,子类只要传Retrofit的网络请求返回值,和LiveData返回值就Ok了
public <T> MutableLiveData<T> observe(Observable observable, final MutableLiveData<T> liveData, ParamsBuilder paramsBuilder) {
if (paramsBuilder == null) {
paramsBuilder = paramsBuilder.build();
}
boolean showDialog = paramsBuilder.isShowDialog();
String loadingMessage = paramsBuilder.getLoadingMessage();
int onlineCacheTime = paramsBuilder.getOnlineCacheTime();
int offlineCacheTime = paramsBuilder.getOfflineCacheTime();
boolean cancleNet = paramsBuilder.isCancleNet();
if (onlineCacheTime > 0) {
setOnlineCacheTime(onlineCacheTime);
}
if (offlineCacheTime > 0) {
setOfflineCacheTime(offlineCacheTime);
}
String oneTag = paramsBuilder.getOneTag();
if (!TextUtils.isEmpty(oneTag)) {
if (oneNetMap.contains(oneTag)) {
return liveData;
}
}
Disposable disposable = observable.subscribeOn(Schedulers.io())
.doOnSubscribe(new Consumer<Disposable>() {
@Override
public void accept(Disposable disposable) throws Exception {
if (!TextUtils.isEmpty(oneTag)) {
onNetTags.add(oneTag);
}
if (showDialog) {
liveData.postValue((T) Resource.loading(loadingMessage));
}
}
}).observeOn(AndroidSchedulers.mainThread())
//防止RxJava内存泄漏(这里其实不用,LiveData已经解决了这个问题。只不过单独使用rxjava的时候要加上。2020/07/03发现。特地记录)
//.compose(objectLifecycleTransformer)
.subscribe(new Consumer() {
@Override
public void accept(Object o) throws Exception {
liveData.postValue((T) Resource.response((ResponModel<Object>) o));
if (!TextUtils.isEmpty(oneTag)) {
onNetTags.remove(oneTag);
}
}
}, new Consumer<Throwable>() {
@Override
public void accept(Throwable throwable) throws Exception {
liveData.postValue((T) Resource.error(throwable));
if (!TextUtils.isEmpty(oneTag)) {
onNetTags.remove(oneTag);
}
}
});
if (cancleNet) {
compositeDisposable.add(disposable);
}
return liveData;
}
}
我们在banner建一个Repository继承BaseModel,如下:
public class HomeRepository extends BaseModel {
//目前home里只有一个请求banner列表的网络请求
public MutableLiveData<Resource<List<BannerBean>>> getBannerList() {
MutableLiveData<Resource<List<BannerBean>>> liveData = new MutableLiveData<>();
return observeGo(getApiService().getBanner(), liveData);
}
}
这里有一点要提下BaseModel里的数据都是BaseViewModel里传过来的,因为ViewModel生命周期的原因,所以现在的BaseViewModel是这样的
public abstract class BaseViewModel<T extends BaseModel> extends AndroidViewModel {
//这个是为了退出页面,取消请求的
public CompositeDisposable compositeDisposable;
private T repository;
private ArrayList<String> onNetTags;
protected abstract T createRepository();
public BaseViewModel(@NonNull Application application) {
super(application);
this.repository = createRepository();
compositeDisposable = new CompositeDisposable();
onNetTags = new ArrayList<>();
}
public void setObjectLifecycleTransformer(LifecycleTransformer objectLifecycleTransformer) {
//objectLifecycleTransformer是从BaseActivity传过来的,RxFragmentActivity的生命周期
repository.setObjectLifecycleTransformer(objectLifecycleTransformer);
repository.setCompositeDisposable(compositeDisposable);
repository.setOnNetTags(onNetTags);
}
public T getRepository() {
return repository;
}
@Override
protected void onCleared() {
super.onCleared();
//销毁后,取消当前页所有在执行的网络请求。
if (compositeDisposable != null) {
compositeDisposable.dispose();
}
}
}
结束语
这是目前2个最大优化的点。项目还有很多优化的地方,包括已经优化的地方,这里就不罗列了。我会利用空闲时间,把项目继续更新下去。MVVM系列文章,就此结束了,非常感谢你的阅读!