首页 > 编程 > Java > 正文

基于retrofit+rxjava+knife的mvp模式demo

2019-11-06 09:36:57
字体:
来源:转载
供稿:网友

最近学习了挺多东西,所以想写个demo把最近所学的全都用到,于是就有了这篇博客,这个demo实现的功能特别简单,就是一个查询天气,并且放到textview及recyclerview上显示出来,用的mvp设计框架,也是这两天才稍微看懂的东西,如果有错,还请各路大佬指出,那么废话不多说,先上效果图

从图中能看出有以下功能:

1. 显示PRogress2. 隐藏progress3. 请求数据成功或失败弹出toast提示4. 将获取到的数据设置到TextView上5. 将获取到的数据设置到recyclerview上6. 如果查询出错清空所有的数据

确定了功能那么就是如何实现了,根据mvp的思想,V层只负责初始化view,并将view层接收到的数据(即EditText等)传递到P层,P层再传递给M层,让M层操作数据,包括存储和耗时操作等,然后M层再将数据传回给P层,P层来更新UI,说得再明白点,mvp就是面向接口,那么m,v,p层的接口该怎么写呢?很简单,根据上面我们列出的功能来写相应的接口,直接来看代码:

public interface IMainActivity {	//显示progress	void showProgress();	//隐藏progress	void hideProgress();	/*	* 设置文本	* @param temperaturestr:今日温度,@param  coldstr:今日建议,@param citystr:城市	* @param yesterdayflstr:昨日风力,@param yesterdayfxstr:昨日风向,@param yesterdayhighstr:昨日最高温	* @param yesterdaylowstr:昨日最低温,@param yesterdaytypestr:昨日天气类型,@param yesterdaydatestr:昨日时间	*	* */	void setText(String temperaturestr, String coldstr, String citystr, String yesterdayflstr,	             String yesterdayfxstr, String yesterdayhighstr, String yesterdaylowstr,	             String yesterdaytypestr, String yesterdaydatestr);	//设置item	void setItem(MyAdapter adapter);	//Toast提示	void showMsg(String msg);	//输入错误时清空textview,recyclerview的item	void clearAll();}那么现在V层,也就是Activity只需要实现这个接口即可,看代码:

public class MainActivity extends Activity implements IMainActivity {	@BindView(R.id.temperature)	TextView temperature;	@BindView(R.id.rv)	RecyclerView rv;	@BindView(R.id.citykey)	EditText citykey;	@BindView(R.id.query)	Button query;	@BindView(R.id.progress)	ProgressBar progress;	private WeatherPresenter weatherPresenter;	//初始化控件,并new出P层实例	@Override	protected void onCreate(Bundle savedInstanceState) {		super.onCreate(savedInstanceState);		setContentView(R.layout.activity_main);		ButterKnife.bind(this);		weatherPresenter = new WeatherPresenter(this);	}	//点击监听,用P层实例去调用请求数据的接口	@OnClick(R.id.query)	void query() {		if (citykey.getText().toString().equals("")) {			citykey.setError("不能为空");		}		weatherPresenter.validateCredentials(citykey.getText().toString());	}	@Override	public void showProgress() {		progress.setVisibility(View.VISIBLE);	}	@Override	public void hideProgress() {		progress.setVisibility(View.GONE);	}	@Override	public void setText(String temperaturestr, String coldstr, String citystr, String yesterdayflstr,	                    String yesterdayfxstr, String yesterdayhighstr, String yesterdaylowstr,	                    String yesterdaytypestr, String yesterdaydatestr) {		temperature.setText("城市:" + citystr + "/n" +				"今日温度:" + temperaturestr + "/n" +				"今日建议:" + coldstr + "/n" +				"昨日时间:" + yesterdaydatestr + "/n" +				"昨日天气:" + yesterdaytypestr + "/n" +				"昨日最" + yesterdayhighstr + "/n" +				"昨日最" + yesterdaylowstr + "/n" +				"昨日风力:" + yesterdayflstr + "/n" +				"昨日风向:" + yesterdayfxstr		);	}	//设置适配器,显示recyclerview,adapter由P层传回	@Override	public void setItem(MyAdapter adapter) {		rv.setLayoutManager(new LinearLayoutManager(this));		rv.setAdapter(adapter);	}	@Override	public void showMsg(String msg) {		Toast.makeText(this, msg, Toast.LENGTH_SHORT).show();	}	@Override	public void clearAll() {		rv.setAdapter(null);		temperature.setText("");	}这里注意一下,我在onCreate方法中实例化了P层,原因就是要让P层拿到V层的实例,这样才能让P层去操作UI,那么P层需要做哪些操作呢,前面说了,M层去操作数据,P层操作UI,再看看我们的效果图,V层获取到了EditText输入的字符串,并且点击查询后获取到了相应的数据,现在要做的,就是把V层获取到的数据传递给M层,让M层去做耗时操作,但是MVP模式,V层是不能直接跟M层进行交互的,怎么办?很简单,我们还有P层没用到,P层的作用就是V层和M层的桥梁,让V层把数据通过P层传递给M层即可,具体怎么做?我们再来分析一下,V层需要传递数据给M层,那么P层就需要一个方法,来接收V层的数据,这个方法就是点击查询按钮后要执行的方法,那么P层现在要做的工作就很简单了,let me show you code:

public interface IWeatherPresenter {	//请求数据	void validateCredentials(String citykey);}接下来在定义一个类去实现该接口

//进行数据请求,请求时显示progress	@Override	public void validateCredentials(String citykey) {		view.showProgress();		model.getWeather(citykey, this);	}有同学就要问了,model.getWeather又是从哪里来的方法,都是什么鬼,不要急,前面说了,P层需要一个方法来接收V层传递过来数据,然后才能让P层把数据传递给M层,那model.getWeather肯定就是M层的方法了,没错,M层需要做耗时操作,而具体要查询哪一个城市的天气数据,就是从V层传递过来的,逻辑是不是一下就通了,再来分析下M层,M层需要的就是耗时操作,那么耗时操作就有两种可能:

1、请求成功

2、请求失败

所以我们M层的接口写成这样:

public interface IWeatherModel {	interface OnLinstener {		//请求失败		void onFailed();		//请求成功		void onSuccess();	}	//请求数据	void getWeather(String citykey, OnLinstener linstener);}

现在万事具备,就剩个M层的类来实现这个接口就行了,但是,先暂停一下,看看我们的标题,基于retrofit+rxjava,前面一直没用,当然就是在这个时候来用的,先给个完整的URL,现在来看看retrofit用来实现get请求的接口:

public interface APIService {	@GET("/weather_mini")	Observable<Bean> getApi(@Query("citykey") String citykey);}有同学要问,返回的Observable是个啥,这个是rxjava特有的,我能力不足,只限于能用的阶段。。还不能很好的解释其中的原理,有兴趣的可以去看看这位大佬rxjava的系列文章,接下来是用于解析json的bean类,太长就不放了。。有兴趣可以下载源码看看,现在,要开始写M层的逻辑了,M层就是用来操作数据的,说白了就是耗时操作,存储数据,看代码:

public class WeatherModel implements IWeatherModel {	private static final String TAG = "WeatherModel";	private Retrofit retrofit;	private OkHttpClient client;	private MyBean bean;	//进行耗时操作,访问数据	@Override	public void getWeather(String citykey, final OnLinstener linstener) {		Interceptor interceptor = new Interceptor() {			@Override			public Response intercept(Chain chain) throws IOException {				Request request = chain.request().newBuilder().build();				return chain.proceed(request);			}		};		client = new OkHttpClient.Builder().addInterceptor(interceptor).build();		retrofit = new Retrofit.Builder()				.baseUrl("http://wthrcdn.etouch.cn")				.addCallAdapterFactory(RxJava2CallAdapterFactory.create())				.addConverterFactory(GsonConverterFactory.create())				.client(client)				.build();		APIService api = retrofit.create(APIService.class);		api.getApi(citykey)				.subscribeOn(Schedulers.io())//在io线程执行				.observeOn(AndroidSchedulers.mainThread())//执行完成后回调给UI线程				.subscribe(new Observer<Bean>() {					@Override					public void onSubscribe(Disposable d) {						Log.i(TAG, "onSubscribe: ");					}					@Override					public void onNext(Bean value) {						if (value.getDesc().equals("OK")) {							bean = new MyBean();							bean.setWendu(value.getData().getWendu());							bean.setGanmao(value.getData().getGanmao());							bean.setCity(value.getData().getCity());							bean.setYesterdayfl(value.getData().getYesterday().getFl());							bean.setYesterdayfx(value.getData().getYesterday().getFx());							bean.setYesterdayhigh(value.getData().getYesterday().getHigh());							bean.setYesterdaylow(value.getData().getYesterday().getLow());							bean.setYesterdaytype(value.getData().getYesterday().getType());							bean.setYesterdaydate(value.getData().getYesterday().getDate());							bean.setList(value.getData().getForecast());							bean.setMsg("请求数据正确,请稍后");							linstener.onSuccess();							Log.i(TAG, "onNext: ");						} else {							bean = new MyBean();							bean.setMsg("请求数据错误,请重新输入");							linstener.onFailed();						}					}					@Override					public void onError(Throwable e) {						linstener.onFailed();						Log.e(TAG, "onError: ");					}					@Override					public void onComplete() {						Log.i(TAG, "onComplete: ");					}				});	}我写了另一个bean类来存储所有数据,这样P层才能直接把数据拿来用,但是在M层存储好说,怎么在P层取出来呢,如果两个类持有的不是同一个对象,那P层肯定是取不出数据的,很简单,有什么需求就写什么接口,P层需要M层存储的bean类,那么我们在M层的接口再写个getBean的方法,然后让M层去实现不就行了,P层拿到M层的实例直接调用方法就可以拿到我们想要的bean类了,所以完整的M层接口代码:

public interface IWeatherModel {	interface OnLinstener {		//请求失败		void onFailed();		//请求成功		void onSuccess();	}	//请求数据	void getWeather(String citykey, OnLinstener linstener);	//获取bean类	MyBean getBean();}完整的M层代码:

public class WeatherModel implements IWeatherModel {	private static final String TAG = "WeatherModel";	private Retrofit retrofit;	private OkHttpClient client;	private MyBean bean;	//进行耗时操作,访问数据	@Override	public void getWeather(String citykey, final OnLinstener linstener) {		Interceptor interceptor = new Interceptor() {			@Override			public Response intercept(Chain chain) throws IOException {				Request request = chain.request().newBuilder().build();				return chain.proceed(request);			}		};		client = new OkHttpClient.Builder().addInterceptor(interceptor).build();		retrofit = new Retrofit.Builder()				.baseUrl("http://wthrcdn.etouch.cn")				.addCallAdapterFactory(RxJava2CallAdapterFactory.create())				.addConverterFactory(GsonConverterFactory.create())				.client(client)				.build();		APIService api = retrofit.create(APIService.class);		api.getApi(citykey)				.subscribeOn(Schedulers.io())//在io线程执行				.observeOn(AndroidSchedulers.mainThread())//执行完成后回调给UI线程				.subscribe(new Observer<Bean>() {					@Override					public void onSubscribe(Disposable d) {						Log.i(TAG, "onSubscribe: ");					}					@Override					public void onNext(Bean value) {						if (value.getDesc().equals("OK")) {							bean = new MyBean();							bean.setWendu(value.getData().getWendu());							bean.setGanmao(value.getData().getGanmao());							bean.setCity(value.getData().getCity());							bean.setYesterdayfl(value.getData().getYesterday().getFl());							bean.setYesterdayfx(value.getData().getYesterday().getFx());							bean.setYesterdayhigh(value.getData().getYesterday().getHigh());							bean.setYesterdaylow(value.getData().getYesterday().getLow());							bean.setYesterdaytype(value.getData().getYesterday().getType());							bean.setYesterdaydate(value.getData().getYesterday().getDate());							bean.setList(value.getData().getForecast());							bean.setMsg("请求数据正确,请稍后");							linstener.onSuccess();							Log.i(TAG, "onNext: ");						} else {							bean = new MyBean();							bean.setMsg("请求数据错误,请重新输入");							linstener.onFailed();						}					}					@Override					public void onError(Throwable e) {						linstener.onFailed();						Log.e(TAG, "onError: ");					}					@Override					public void onComplete() {						Log.i(TAG, "onComplete: ");					}				});	}	//将保存的MyBean类返回给P层	@Override	public MyBean getBean() {		return this.bean;	}}P层完整的代码:

public class WeatherPresenter implements IWeatherPresenter, IWeatherModel.OnLinstener {	private IMainActivity view;	private IWeatherModel model;	private List<Bean.Data.forecast> list;	//构造器,需要传入v层实例,并new一个m层实例,以达到让P层实现桥梁的作用	public WeatherPresenter(IMainActivity view) {		this.view = view;		this.model = new WeatherModel();	}	//进行数据请求,请求时显示progress	@Override	public void validateCredentials(String citykey) {		view.showProgress();		model.getWeather(citykey, this);	}	//数据请求失败时隐藏progress	@Override	public void onFailed() {		view.clearAll();		MyBean bean = model.getBean();		view.showMsg(bean.getMsg());		view.hideProgress();	}	//数据请求成功后将数据显示在控件上,且在请求成功后隐藏progress	@Override	public void onSuccess() {		MyBean bean = model.getBean();		if (bean.getMsg().equals("请求数据正确,请稍后")) {			view.showMsg(bean.getMsg());			view.setText(bean.getWendu(), bean.getGanmao(), bean.getCity(), bean.getYesterdayfl(),					bean.getYesterdayfx(), bean.getYesterdayhigh(), bean.getYesterdaylow(),					bean.getYesterdaytype(), bean.getYesterdaydate());			list = bean.getList();			MyAdapter adapter = new MyAdapter((Context) view, list);			view.setItem(adapter);			view.hideProgress();		}	}}recyclerview的adapter非常简单,就不贴出来了,有兴趣的话就下载源码自己看看吧,欢迎各位大佬提出建议

demo源码


发表评论 共有条评论
用户名: 密码:
验证码: 匿名发表