一、MVC模式
目录
- 一、MVC模式
- 二、MVP模式
- 1、MVP的简单应用
- 1.1 导入相关依赖包并设置权限
- 1.2 实现Model
- 1.2 实现Presenter
- 1.3 实现View
- 1.4分析项目结构和绑定过程
- 1.5效果展示
- 2、MVP结合RxJava
- 1、MVP的简单应用
一、MVC模式
MVC(Model(模型)——View(视图)——Controller(控制器))
Android中MVC的角色定义如下:
- 模型(Model)层:针对业务模型建立的数据结构和相关类
- 视图(View)层:一般作为UI的展示XML文件
- 控制(Controller)层:通常在Activity和Fragment中,或者在由他们控制的业务类中
简单来说MVC就是通过Controller层操作Model层数据,并且返回给VIew展示。
[外链图片转存中…(img-oi8sABEO-1702569842215)]
MVC的缺点:
- Activity不是一个标准的Controller,它主要是加载应用布局、初始化界面、并且收发用户操作的请求而做出响应
- VIew层和Model层互相耦合,不易于开发维护
二、MVP模式
MVP(Model——View——presenter)它是MVC的演化版本,MPV角色定义如下:
- Model:主要负责数据的存取功能
- View:负责处理用户事件和视图展示,在Android中它可能是Activity、Fragment或者某给View的控件。
- Presenter:作为View和Model之间的桥梁,它从Model中检索数据返回给View。使得View和Model之间没有耦合
主要的控制逻辑在Presenter里实现,而且Presenter与具体的View是没有直接关联的,而是通过定义好的接口交互。这样使得View变更时Presenter不会受到影响。绝不允许View直接访问Model,这就是它和MVC的不同之处。
1、MVP的简单应用
1.1 导入相关依赖包并设置权限
导入需要的相关依赖:
implementation 'com.squareup.okhttp3:okhttp:4.11.0'
implementation 'org.projectlombok:lombok:1.18.30'
implementation 'com.google.code.gson:gson:2.10.1'
implementation 'com.github.bumptech.glide:glide:4.16.0'
接下来设置网络请求权限:
<uses-permission android:name="android.permission.INTERNET" />
<uses-permission android:name="android.permission.ACCESS_NETWORK_STATE" />
我们使用这个免费的Api获取一首网易热门歌曲
https://api.uomg.com/api/rand.music?sort=热歌榜&format=json
JSON数据结构如下所示:
{"code": 1,"data": {"name": "晚安","url": "http://music.163.com/song/media/outer/url?id=1359356908","picurl": "http://p1.music.126.net/8N1fsMRm2L5HyZccc6I3ew==/109951164007377169.jpg","artistsname": "颜人中"}
}
先看一下完整的项目目录结构:
[外链图片转存中…(img-pjbexowu-1702569842216)]
1.2 实现Model
创建一个musicData用于存储转化后的JSON数据:
@NoArgsConstructor
@Data
public class musicData {@SerializedName("data")private DataDTO data;@NoArgsConstructor@Datapublic static class DataDTO {@SerializedName("name")private String name;@SerializedName("url")private String url;@SerializedName("picurl")private String picurl;@SerializedName("artistsname")private String artistsname;public String getName() {return name;}public String getUrl() {return url;}public String getPicurl() {return picurl;}public String getArtistsname() {return artistsname;}}public DataDTO getData() {return data;}
}`
定义获取网络数据的接口类NetTask:
public interface NetTask<T> {void execute(T data, LoadTasksCallBack callBack);
}
这里有一个回调接口LoadTasksCallBack用于监听网络访问回调的各种状态:
public interface LoadTasksCallBack<T> {/*** 网络请求成功** @param data:数据仓库,存放解析后的数据*/void onSuccess(T data);/***网络请求失败*/void onFailed();
}
接下来我们编写NetTask的实现类以获取数据,如下所示:
public class MusicInfoTask implements NetTask<String> {private static MusicInfoTask INSTANCE = null;private static final String HOST = "https://api.uomg.com/api/rand.music?sort=%E7%83%AD%E6%AD%8C%E6%A6%9C&format=json";private LoadTasksCallBack loadTasksCallBack;public static MusicInfoTask getInstance(){if (INSTANCE == null){INSTANCE = new MusicInfoTask();}return INSTANCE;}@Overridepublic void execute(String data, final LoadTasksCallBack callBack) {//这里展示一下传入的data数据,HOSP是写死的,没有拼接data,可以自行实现使用data重新拼接。Log.e("TAG", "execute: "+data);sendOkHttpRequest(HOST,new okhttp3.Callback(){@Overridepublic void onResponse(@NonNull Call call, @NonNull Response response) throws IOException {if (response.isSuccessful()){String responseBody = response.body().string();Gson gson = new Gson();musicData musicData = gson.fromJson(responseBody, musicData.class);callBack.onSuccess(musicData);}}@Overridepublic void onFailure(@NonNull Call call, @NonNull IOException e) {callBack.onFailed();}});}/*** 发送网络请求** @param address* @param callback*/public static void sendOkHttpRequest(String address, okhttp3.Callback callback) {OkHttpClient client = new OkHttpClient();Request request = new Request.Builder().url(address).build();client.newCall(request).enqueue(callback);}
}
MusicInfoTask是一个单例模式,在execute方法中通过OKHttp来获取数据,同时在okhttp3.Callback中回调自定义的LoadTasksCallBack。
通过时序图理解execute方法是如何做的:
1.2 实现Presenter
我们首先定义一个契约接口MusicInfoContract
用来存放具有相同业务的Presenter和View的接口,便于查找和维护。代码如下:
public interface MusicInfoContract {interface Presenter {void getMusiInfo(String ip);}/*** 视图需要的功能** @author lukecc0* @date 2023/12/13*/interface View extends BaseView<Presenter> {void setMusicData(musicData musicData);void showError();/*** 用于判断Fragment是否成功加入到Activity** @return {@link Boolean}*/Boolean isACtive();}
}
在这里看见Presenter接口定义了获取数据的方法,而View接口定义了与界面交互的方法。其中isActive方法用于判断Fragment是否加入到了Activity中。
另外,View接口基础于BaseView接口,BaseView接口如下所示:
public interface BaseView<T>{/*** 为视图绑定对应的presenter** @param presenter*/void setPresenter(T presenter);
}
BaseView接口的目的就是为View绑定对应的Presenter。它作为一个View的管理类,为每一个View实现绑定方法。
接着实现Presenter接口,如下所示:
public class MusicInfoPresenter implements MusicInfoContract.Presenter, LoadTasksCallBack<musicData> {private NetTask netTask;private MusicInfoContract.View addTaskView;/*** @param addTaskView 是我们传入的View用于实现Presenter绑定View,然后我们操作这个View实现Ui的变更* @param netTask 传入的Model用于实现Presenter绑定Model,通过这个Model获取数据*/public MusicInfoPresenter(MusicInfoContract.View addTaskView, NetTask netTask) {this.netTask = netTask;this.addTaskView = addTaskView;}@Overridepublic void onSuccess(musicData musicData) {if (addTaskView.isACtive()) {addTaskView.setMusicData(musicData);}}@Overridepublic void onFailed() {if (addTaskView.isACtive()) {addTaskView.showError();}}@Overridepublic void getMusiInfo(String ip) {//1、将自身回调,把自身传入到Model中,实现Model绑定PresenternetTask.execute(ip, this);}
}
在MusicInfoPresenter中含有NetTask和MusicInfoContract.View的实例,并且还实现了LoadTasksCallBack接口。
在注释1中MusicInfoPresenter将自身传递给NetTask的execute方法来获取数据。并回调给MusicInfoPresenter本身实现的onSuccess、onFailed两个方法,在这两个方法中通过addTaskView与View交互。我们看一下这个getMusiInfo方法的时序图理解它是怎么做的:
[外链图片转存中…(img-6HAbY7JS-1702569842216)]
这样我们就理解了,这里的Presenter作为一个中间代理,通过NetTask也就是Model来获取和保存数据,然后通过View更新页面。在这个过程中通过自定义接口使得Model和View没有任何交互。
1.3 实现View
在前面的契约接口MusicInfoContract中我们已经自定义了View接口,接下来我们使用MusicInfoFragment实现它:
public class MusicInfoFragment extends Fragment implements MusicInfoContract.View {private TextView textView;private ImageView imageView;private Button button;private MusicInfoContract.Presenter mPresenter;public static MusicInfoFragment newInstance() {return new MusicInfoFragment();}@Nullable@Overridepublic View onCreateView(@NonNull LayoutInflater inflater, @Nullable ViewGroup container, @Nullable Bundle savedInstanceState) {View root = inflater.inflate(R.layout.music_fragment, container, false);textView = root.findViewById((int) R.id.textView);imageView = root.findViewById((int) R.id.image);button = root.findViewById((int) R.id.button);button.setOnClickListener(new View.OnClickListener() {@Overridepublic void onClick(View view) {mPresenter.getMusiInfo("热歌榜");}});return root;}@Overridepublic void setPresenter(MusicInfoContract.Presenter presenter) {mPresenter = presenter;}@Overridepublic void setMusicData(musicData musicData) {Log.e("TAG", "execute: " + musicData.getData().toString());if (musicData != null) {textView.setText(musicData.getData().getName());requireActivity().runOnUiThread(new Runnable() {@Overridepublic void run() {String originalUrl = musicData.getData().getPicurl();//将http协议换成httpsString modifiedUrl = originalUrl.replace("http://", "https://");Glide.with(requireActivity()).load(modifiedUrl).into(imageView);}});}}@Overridepublic void showError() {textView.setText("Error");}@Overridepublic Boolean isACtive() {//判断是否加入到Activityreturn isAdded();}
}
在上面注释1的部分通过实现setPresenter方法来实现注入MusicInfoPresenter,用于实现View绑定到Presenter。
在注释2中则调用MusicInfoPresenter的getMusiInfo方法来获取Ip地址的信息。另外Fragment实现了MusicInfoContract.View接口,用来接受MusicInfoPresenter的回调。
那么MusicInfoFragment是在哪里调用setPresenter实现注入MusicInfoPresenter?
其实在MainActivity中实现这个注入,我们看一下MainActivity做了什么事情:
public class MainActivity extends AppCompatActivity {private MusicInfoPresenter presenter;@Overrideprotected void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);setContentView(R.layout.activity_main);//1、创建FragmentMusicInfoFragment fragment = (MusicInfoFragment) getSupportFragmentManager().findFragmentById(R.id.fragment);if (fragment == null){fragment = MusicInfoFragment.newInstance();//2、将Fragment加入到Activity中ActivityUtils.addFragmentToActivity(getSupportFragmentManager(),fragment,R.id.fragment);}MusicInfoTask task = MusicInfoTask.getInstance();//3、将View和Model注入Presenter中presenter = new MusicInfoPresenter(fragment,task);//4、将Presenter注入View中实现双向绑定fragment.setPresenter(presenter);}
}
这个例子中Activity不作为View层,而是作为View、Model、Presenter三层的纽带。
📌注意我们看注释3、4可以发现View和Presenter是双向绑定的
ActivityUtils的addFragmentToActivity负责提交事务,实现了绑定Fragment到Activity,我们看一下代码:
public class ActivityUtils {public static void addFragmentToActivity(FragmentManager fragmentManager,Fragment fragment,int frameId){FragmentTransaction transaction = fragmentManager.beginTransaction();transaction.add(frameId,fragment);transaction.commit();}
}
1.4分析项目结构和绑定过程
从图中可以看出,View和Model之间并没有什么联系;View和Presenter通过接口交互,并在Activity中互相注入。Model的NetTask在Activity中注入Presenter,并等待Presenter调用。
1.5效果展示
2、MVP结合RxJava
这个例子是在上个例子的基础上修改的,加入了RxJava3和Retrofit2实现网络请求。
首先导入需要的依赖:
implementation 'io.reactivex.rxjava3:rxandroid:3.0.2'
implementation 'io.reactivex.rxjava3:rxjava:3.1.8'
implementation 'com.squareup.retrofit2:converter-gson:2.9.0'
implementation 'com.squareup.retrofit2:adapter-rxjava3:2.9.0'
定义网络访问接口,如下所示:
public interface MusicService {@GET("rand.music?format=json")Observable<musicData> getMusicData(@Query("sort") String sort);
}
getMusicData返回Observable类型是为了支持RxJava,然后我们修改NetTask接口:
public interface NetTask<T> {// void execute(T data, LoadTasksCallBack callBack);Disposable execute(T data, LoadTasksCallBack callBack);
}
接下来修改NetTask接口的实现类MusicInfoTask,代码如下:
public class MusicInfoTask implements NetTask<String> {private static MusicInfoTask INSTANCE = null;private Retrofit retrofit;private static final String HOST = "https://api.uomg.com/api/";public MusicInfoTask() {createRetrofit();}public static MusicInfoTask getInstance(){if (INSTANCE == null){INSTANCE = new MusicInfoTask();}return INSTANCE;}/*** 初始化Retrofit*/private void createRetrofit(){retrofit= new Retrofit.Builder().baseUrl(HOST).addConverterFactory(GsonConverterFactory.create()).addCallAdapterFactory(RxJava3CallAdapterFactory.create()).build();}@Overridepublic Disposable execute(String data, LoadTasksCallBack callBack) {MusicService service = retrofit.create(MusicService.class);Disposable disposable = service.getMusicData(data).subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).subscribeWith(new DisposableObserver<musicData>() {@Overridepublic void onNext(@NonNull musicData musicData) {// 收到数据时的操作callBack.onSuccess(musicData);}@Overridepublic void onError(@NonNull Throwable e) {// 发生错误时的操作callBack.onFailed();}@Overridepublic void onComplete() {// 完成时的操作}});return disposable;}}
主要变化就是使用RxJava和Retrofit代替OKHttp访问网络,在execute方法中返回Disposable。接下来我们实现取消网络请求功能。首先定义一个BasePresenter接口:
public interface BasePresenter {void subscribe();void unsubscribe();
}
然后改写Presenter接口,继承这个BasePresenter:
public interface MusicInfoContract {
// interface Presenter {
// void getMusiInfo(String ip);
// }interface Presenter extends BasePresenter{void getMusiInfo(String ip);}...........
}
最后改写MusicInfoPresenter类:
public class MusicInfoPresenter implements MusicInfoContract.Presenter, LoadTasksCallBack<musicData> {private NetTask netTask;private MusicInfoContract.View addTaskView;private CompositeDisposable compositeDisposable;private Disposable disposable;/*** @param addTaskView 是我们传入的View用于实现Presenter绑定View,然后我们操作这个View实现Ui的变更* @param netTask 传入的Model用于实现Presenter绑定Model,通过这个Model获取数据*/public MusicInfoPresenter(MusicInfoContract.View addTaskView, NetTask netTask) {this.netTask = netTask;this.addTaskView = addTaskView;compositeDisposable = new CompositeDisposable();}@Overridepublic void onSuccess(musicData musicData) {if (addTaskView.isACtive()) {addTaskView.setMusicData(musicData);}}@Overridepublic void onFailed() {if (addTaskView.isACtive()) {addTaskView.showError();unsubscribe();}}@Overridepublic void getMusiInfo(String ip) {//1、将自身回调,把自身传入到Model中,实现Model绑定Presenterdisposable = netTask.execute(ip, this);subscribe();}@Overridepublic void subscribe() {if (disposable != null) {compositeDisposable.add(disposable);}}@Overridepublic void unsubscribe() {if (compositeDisposable != null && compositeDisposable.isDisposed()){compositeDisposable.dispose();}}
}
当注释1调用execute方法时返回一个disposable,然后调用subscribe方法传入compositeDisposable,用来管理这个网络请求,当我们需要取消这个网络请求时调用unsubscribe即可。