Android中RxJava+Retrofit2.0+MVP模式的整合
2016年03月02日 17:01:40
阅读数：19324
转载请标明出处:http://blog.csdn.net/u010046908/article/details/50781360 本文出自:【李东的博客】
MVP的工作原理
以上是MVP的工作原理图。其中大家注意的Presenter操作View和Mode都是通过接口来实现直接的调用。
MVP的工作流程
Presenter负责逻辑的处理，Model提供数据，View负责显示。 作为一种新的模式，在MVP中View并不直接使用Model，它们之间的通信是通过Presenter来进行的，所有的交互都发生在Presenter内部，而在MVC中View会从直接Model中读取数据而不是通过 Controller。
RxJava和Retrofit2.0使用
这二者的使用我就不罗嗦了，github中后好多demo，大家自己看。
MVP、RxJava和Reterofit2.0三者的整合现在开始讲解
首先说一下本项目的结构
api包主要存放网络请求接口bean包中存放实体类model包中存放处理数据pesenter包中存放主导器view包中存放界面处理
view的代码：
public interface WeatherView {
void showProgress()
void hideProgress()
void loadWeather(WeatherData weatherData)
}
package
com.lidong.demo.android_rapid_development_of_library
.mvp
import android
.os.Bundle
import android
.support.v7
.app.AppCompatActivity
import android
.support.v7
.widget.Toolbar
import android
.util.Log
import android
.widget.TextView
import android
.widget.Toast
import
com.lidong.android_ibrary
.LoadingUIHelper
import
com.lidong.demo.android_rapid_development_of_library
.R
import
com.lidong.demo.android_rapid_development_of_library
.mvp.bean.WeatherData
import
com.lidong.demo.android_rapid_development_of_library
.mvp.presenter.WeatherPresenter
import
com.lidong.demo.android_rapid_development_of_library
.mvp.presenter.WeatherPresenterImp
import
com.lidong.demo.android_rapid_development_of_library
.mvp.view.WeatherView
import butterknife
.Bind
import butterknife
.ButterKnife
public class WeatherActivity extends AppCompatActivity implements WeatherView {
@Bind(R
.id.toolbar)
Toolbar toolbar
@Bind(R
.id.textView1)
TextView textView1
@Bind(R
.id.textView2)
TextView textView2
@Bind(R
.id.textView3)
TextView textView3
@Bind(R
.id.textView4)
TextView textView4
@Bind(R
.id.textView5)
TextView textView5
@Bind(R
.id.textView6)
TextView textView6
@Bind(R
.id.textView7)
TextView textView7
@Bind(R
.id.textView8)
TextView textView8
@Bind(R
.id.textView9)
TextView textView9
private WeatherPresenter mWeatherPresenter
@Override
protected void onCreate(Bundle savedInstanceState) {
super
.onCreate(savedInstanceState)
setContentView(R
.layout.activity_weather)
ButterKnife
.bind(this)
setSupportActionBar(toolbar)
mWeatherPresenter = new WeatherPresenterImp(this)
mWeatherPresenter
.getWeatherData(
"2",
"苏州")
}
@Override
public void showProgress() {
LoadingUIHelper
.showDialogForLoading(this,
"获取数据",false)
}
@Override
public void hideProgress() {
LoadingUIHelper
.hideDialogForLoading()
Toast
.makeText(this,
"服务器异常",Toast
.LENGTH_SHORT)
.show()
mWeatherPresenter
.onUnsubscribe()
}
@Override
public void loadWeather(WeatherData weatherData) {
Log
.d(
"weatherData",
"weatherData==" + weatherData
.toString())
textView1
.setText(
"城市："+weatherData
.getResult()
.getToday()
.getCity())
textView2
.setText(
"日期："+weatherData
.getResult()
.getToday()
.getWeek())
textView3
.setText(
"今日温度："+weatherData
.getResult()
.getToday()
.getTemperature())
textView4
.setText(
"天气标识：" +WeatherIDUtils
.transfer(weatherData
.getResult()
.getToday()
.getWeather_id()
.getFa()))
textView5
.setText(
"穿衣指数：" + weatherData
.getResult()
.getToday()
.getDressing_advice())
textView6
.setText(
"干燥指数："+weatherData
.getResult()
.getToday()
.getDressing_index())
textView7
.setText(
"紫外线强度："+weatherData
.getResult()
.getToday()
.getUv_index())
textView8
.setText(
"穿衣建议："+weatherData
.getResult()
.getToday()
.getDressing_advice())
textView9
.setText(
"旅游指数："+weatherData
.getResult()
.getToday()
.getTravel_index())
}
}
@Override
protected void onDestroy() {
super
.onDestroy()
//取消注册
mWeatherPresenter
.onUnsubscribe()
}
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899
model层中的代码
/**
*
* Created by lidong on 2016/3/2.
*/
public interface WeatherModel {
/**
* 获取天气信息
* @param format
* @param city
*/
Subscription getWeatherData(String format, String city);
}
/**
* Created by lidong on 2016/3/2.
*/
public class WeatherModelImp implements WeatherModel {
private WeatherOnListener mWeatherOnListener;
public WeatherModelImp(WeatherOnListener mWeatherOnListener) {
this.mWeatherOnListener = mWeatherOnListener;
}
@Override
public void getWeatherData(String format,String city) {
@Override
public Subscription
getWeatherData(String format,String city) {
Observable<WeatherData> request = com.lidong.demo.mvp_dagger2.api.ApiManager.getWeatherData(format, city).cache();
Subscription sub = request.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(
new Action1<WeatherData>() {
@Override
public void call(WeatherData weatherData) {
mWeatherOnListener.onSuccess(weatherData);
}
},
new Action1<Throwable>() {
@Override
public void call(Throwable throwable) {
mWeatherOnListener.onFailure(throwable);
}
});
return sub;
}
/**
*回调接口
*/
public interface WeatherOnListener{
void onSuccess(WeatherData s);
void onFailure(Throwable e);
}
}
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657
presenter层中的代码：
/**
* Created by lidong on 16/9/10.
*/
public class BasePresenter {
protected CompositeSubscription mCompositeSubscription;
public void onUnsubscribe() {
if (mCompositeSubscription !=
null && mCompositeSubscription.hasSubscriptions()) {
mCompositeSubscription.unsubscribe();
}
}
public void addSubscription(Subscription subscriber) {
if (mCompositeSubscription ==
null) {
mCompositeSubscription =
new CompositeSubscription();
}
mCompositeSubscription.add(subscriber);
}
}
/**
* Created by lidong on 2016/3/2.
*/
public abstract class WeatherPresenter extends BasePresenter{
/**
* 获取天气信息
* @param format
* @param city
*/
public abstract void getWeatherData(String format, String city);
}
package com.lidong.demo.mvp.presenter;
import android.util.Log;
import com.lidong.demo.mvp.bean.WeatherData;
import com.lidong.demo.mvp.model.WeatherModel;
import com.lidong.demo.mvp.model.WeatherModelImp;
import com.lidong.demo.mvp.view.WeatherView;
/**
* Created by lidong on 2016/3/2.
*/
public class WeatherPresenterImp extends WeatherPresenter implements WeatherModelImp.WeatherOnListener{
/**
* WeatherModel和WeatherView都是通过接口来实现，这就Java设计原则中依赖倒置原则使用
*/
private WeatherModel mWeatherModel;
private WeatherView mWeatherView;
public WeatherPresenterImp( WeatherView mWeatherView) {
this.mWeatherModel =
new WeatherModelImp(
this);
this.mWeatherView = mWeatherView;
}
@Override
public void getWeatherData(String format, String city) {
mWeatherView.showProgress();
addSubscription(mWeatherModel.getWeatherData(format,city));
}
@Override
public void onSuccess(WeatherData s) {
mWeatherView.loadWeather(s);
mWeatherView.hideProgress();
Log.d(
"-------",
"onSuccess() called with: " +
"s = [" + s.toString() +
"]");
}
@Override
public void onFailure(Throwable e) {
mWeatherView.hideProgress();
Log.d(
"-------",
"onFailure" + e.getMessage());
}
}
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384
api层的代码
package com.lidong.demo.android_rapid_development_of_library.mvp.api;
import com.lidong.demo.android_rapid_development_of_library.mvp.bean.WeatherData;
import retrofit.GsonConverterFactory;
import retrofit.Retrofit;
import retrofit.RxJavaCallAdapterFactory;
import rx.Observable;
/**
* Created by lidong on 2016/3/2.
*/
public class ApiManager {
private static final String ENDPOINT =
"http://v.juhe.cn";
private static final Retrofit sRetrofit =
new Retrofit .Builder()
.baseUrl(ENDPOINT)
.addConverterFactory(GsonConverterFactory.create())
.addCallAdapterFactory(RxJavaCallAdapterFactory.create())
.build();
private static final ApiManagerService apiManager = sRetrofit.create(ApiManagerService.class);
/**
* 获取天气数据
* @param city
* @return
*/
public static Observable<WeatherData>
getWeatherData(String format, String city) {
return apiManager.getWeatherData(format,city,
"ad1d20bebafe0668502c8eea5ddd0333");
}
}
package com.lidong.demo.android_rapid_development_of_library.mvp.api;
import com.lidong.demo.android_rapid_development_of_library.mvp.bean.WeatherData;
import retrofit.http.GET;
import retrofit.http.Query;
import rx.Observable;
/**
* @className：ApiManagerService
* Created by lidong on 2016/3/2.
*/
public interface ApiManagerService {
/**
* 获取数据
* @param cityname
* @param key
* @return
*/
@GET(
"/weather/index")
Observable<WeatherData> getWeatherData(
@Query(
"format") String format,
@Query(
"cityname") String cityname,
@Query(
"key") String key);
}
12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061
bean层的代码
package com.lidong.demo.android_rapid_development_of_library.mvp.bean;
import java.util.List;
/**
* Created by Administrator on 2015/12/21.
*/
public class WeatherData {
/**
* resultcode : 200
* reason : successed!
* result : {"sk":{"temp":"18","wind_direction":"东南风","wind_strength":"2级","humidity":"41%","time":"14:32"},"today":{"temperature":"8℃~17℃","weather":"多云","weather_id":{"fa":"01","fb":"01"},"wind":"东南风3-4 级","week":"星期三","city":"苏州","date_y":"2016年03月02日","dressing_index":"较冷","dressing_advice":"建议着厚外套加毛衣等服装。年老体弱者宜着大衣、呢外套加羊毛衫。","uv_index":"弱","comfort_index":"","wash_index":"较适宜","travel_index":"较适宜","exercise_index":"较适宜","drying_index":""},"future":[{"temperature":"8℃~17℃","weather":"多云","weather_id":{"fa":"01","fb":"01"},"wind":"东南风3-4 级","week":"星期三","date":"20160302"},{"temperature":"11℃~21℃","weather":"多云","weather_id":{"fa":"01","fb":"01"},"wind":"东南风3-4 级","week":"星期四","date":"20160303"},{"temperature":"12℃~19℃","weather":"多云转阴","weather_id":{"fa":"01","fb":"02"},"wind":"东南风3-4 级","week":"星期五","date":"20160304"},{"temperature":"10℃~19℃","weather":"多云","weather_id":{"fa":"01","fb":"01"},"wind":"东北风3-4 级","week":"星期六","date":"20160305"},{"temperature":"11℃~20℃","weather":"多云","weather_id":{"fa":"01","fb":"01"},"wind":"东南风3-4 级","week":"星期日","date":"20160306"},{"temperature":"10℃~19℃","weather":"多云","weather_id":{"fa":"01","fb":"01"},"wind":"东北风3-4 级","week":"星期一","date":"20160307"},{"temperature":"12℃~19℃","weather":"多云转阴","weather_id":{"fa":"01","fb":"02"},"wind":"东南风3-4 级","week":"星期二","date":"20160308"}]}
* error_code : 0
*/
private String resultcode;
private String reason;
/**
* sk : {"temp":"18","wind_direction":"东南风","wind_strength":"2级","humidity":"41%","time":"14:32"}
* today : {"temperature":"8℃~17℃","weather":"多云","weather_id":{"fa":"01","fb":"01"},"wind":"东南风3-4 级","week":"星期三","city":"苏州","date_y":"2016年03月02日","dressing_index":"较冷","dressing_advice":"建议着厚外套加毛衣等服装。年老体弱者宜着大衣、呢外套加羊毛衫。","uv_index":"弱","comfort_index":"","wash_index":"较适宜","travel_index":"较适宜","exercise_index":"较适宜","drying_index":""}
* future : [{"temperature":"8℃~17℃","weather":"多云","weather_id":{"fa":"01","fb":"01"},"wind":"东南风3-4 级","week":"星期三","date":"20160302"},{"temperature":"11℃~21℃","weather":"多云","weather_id":{"fa":"01","fb":"01"},"wind":"东南风3-4 级","week":"星期四","date":"20160303"},{"temperature":"12℃~19℃","weather":"多云转阴","weather_id":{"fa":"01","fb":"02"},"wind":"东南风3-4 级","week":"星期五","date":"20160304"},{"temperature":"10℃~19℃","weather":"多云","weather_id":{"fa":"01","fb":"01"},"wind":"东北风3-4 级","week":"星期六","date":"20160305"},{"temperature":"11℃~20℃","weather":"多云","weather_id":{"fa":"01","fb":"01"},"wind":"东南风3-4 级","week":"星期日","date":"20160306"},{"temperature":"10℃~19℃","weather":"多云","weather_id":{"fa":"01","fb":"01"},"wind":"东北风3-4 级","week":"星期一","date":"20160307"},{"temperature":"12℃~19℃","weather":"多云转阴","weather_id":{"fa":"01","fb":"02"},"wind":"东南风3-4 级","week":"星期二","date":"20160308"}]
*/
private ResultEntity result;
private int error_code;
public void setResultcode(String resultcode) {
this.resultcode = resultcode;
}
public void setReason(String reason) {
this.reason = reason;
}
public void setResult(ResultEntity result) {
this.result = result;
}
public void setError_code(
int error_code) {
this.error_code = error_code;
}
public String
getResultcode() {
return resultcode;
}
public String
getReason() {
return reason;
}
public ResultEntity
getResult() {
return result;
}
public int getError_code() {
return error_code;
}
public static class ResultEntity {
/**
* temp : 18
* wind_direction : 东南风
* wind_strength : 2级
* humidity : 41%
* time : 14:32
*/
private SkEntity sk;
/**
* temperature : 8℃~17℃
* weather : 多云
* weather_id : {"fa":"01","fb":"01"}
* wind : 东南风3-4 级
* week : 星期三
* city : 苏州
* date_y : 2016年03月02日
* dressing_index : 较冷
* dressing_advice : 建议着厚外套加毛衣等服装。年老体弱者宜着大衣、呢外套加羊毛衫。
* uv_index : 弱
* comfort_index :
* wash_index : 较适宜
* travel_index : 较适宜
* exercise_index : 较适宜
* drying_index :
*/
private TodayEntity today;
/**
* temperature : 8℃~17℃
* weather : 多云
* weather_id : {"fa":"01","fb":"01"}
* wind : 东南风3-4 级
* week : 星期三
* date : 20160302
*/
private List<FutureEntity> future;
public void setSk(SkEntity sk) {
this.sk = sk;
}
public void setToday(TodayEntity today) {
this.today = today;
}
public void setFuture(List<FutureEntity> future) {
this.future = future;
}
public SkEntity
getSk() {
return sk;
}
public TodayEntity
getToday() {
return today;
}
public List<FutureEntity>
getFuture() {
return future;
}
public static class SkEntity {
private String temp;
private String wind_direction;
private String wind_strength;
private String humidity;
private String time;
public void setTemp(String temp) {
this.temp = temp;
}
public void setWind_direction(String wind_direction) {
this.wind_direction = wind_direction;
}
public void setWind_strength(String wind_strength) {
this.wind_strength = wind_strength;
}
public void setHumidity(String humidity) {
this.humidity = humidity;
}
public void setTime(String time) {
this.time = time;
}
public String
getTemp() {
return temp;
}
public String
getWind_direction() {
return wind_direction;
}
public String
getWind_strength() {
return wind_strength;
}
public String
getHumidity() {
return humidity;
}
public String
getTime() {
return time;
}
@Override
public String
toString() {
return "SkEntity{" +
"temp='" + temp +
'\'' +
", wind_direction='" + wind_direction +
'\'' +
", wind_strength='" + wind_strength +
'\'' +
", humidity='" + humidity +
'\'' +
", time='" + time +
'\'' +
'}';
}
}
public static class TodayEntity {
@Override
public String
toString() {
return "TodayEntity{" +
"temperature='" + temperature +
'\'' +
", weather='" + weather +
'\'' +
", weather_id=" + weather_id +
", wind='" + wind +
'\'' +
", week='" + week +
'\'' +
", city='" + city +
'\'' +
", date_y='" + date_y +
'\'' +
", dressing_index='" + dressing_index +
'\'' +
", dressing_advice='" + dressing_advice +
'\'' +
", uv_index='" + uv_index +
'\'' +
", comfort_index='" + comfort_index +
'\'' +
", wash_index='" + wash_index +
'\'' +
", travel_index='" + travel_index +
'\'' +
", exercise_index='" + exercise_index +
'\'' +
", drying_index='" + drying_index +
'\'' +
'}';
}
private String temperature;
private String weather;
/**
* fa : 01
* fb : 01
*/
private WeatherIdEntity weather_id;
private String wind;
private String week;
private String city;
private String date_y;
private String dressing_index;
private String dressing_advice;
private String uv_index;
private String comfort_index;
private String wash_index;
private String travel_index;
private String exercise_index;
private String drying_index;
public void setTemperature(String temperature) {
this.temperature = temperature;
}
public void setWeather(String weather) {
this.weather = weather;
}
public void setWeather_id(WeatherIdEntity weather_id) {
this.weather_id = weather_id;
}
public void setWind(String wind) {
this.wind = wind;
}
public void setWeek(String week) {
this.week = week;
}
public void setCity(String city) {
this.city = city;
}
public void setDate_y(String date_y) {
this.date_y = date_y;
}
public void setDressing_index(String dressing_index) {
this.dressing_index = dressing_index;
}
public void setDressing_advice(String dressing_advice) {
this.dressing_advice = dressing_advice;
}
public void setUv_index(String uv_index) {
this.uv_index = uv_index;
}
public void setComfort_index(String comfort_index) {
this.comfort_index = comfort_index;
}
public void setWash_index(String wash_index) {
this.wash_index = wash_index;
}
public void setTravel_index(String travel_index) {
this.travel_index = travel_index;
}
public void setExercise_index(String exercise_index) {
this.exercise_index = exercise_index;
}
public void setDrying_index(String drying_index) {
this.drying_index = drying_index;
}
public String
getTemperature() {
return temperature;
}
public String
getWeather() {
return weather;
}
public WeatherIdEntity
getWeather_id() {
return weather_id;
}
public String
getWind() {
return wind;
}
public String
getWeek() {
return week;
}
public String
getCity() {
return city;
}
public String
getDate_y() {
return date_y;
}
public String
getDressing_index() {
return dressing_index;
}
public String
getDressing_advice() {
return dressing_advice;
}
public String
getUv_index() {
return uv_index;
}
public String
getComfort_index() {
return comfort_index;
}
public String
getWash_index() {
return wash_index;
}
public String
getTravel_index() {
return travel_index;
}
public String
getExercise_index() {
return exercise_index;
}
public String
getDrying_index() {
return drying_index;
}
public static class WeatherIdEntity {
private String fa;
private String fb;
public void setFa(String fa) {
this.fa = fa;
}
public void setFb(String fb) {
this.fb = fb;
}
public String
getFa() {
return fa;
}
public String
getFb() {
return fb;
}
}
}
public static class FutureEntity {
private String temperature;
private String weather;
/**
* fa : 01
* fb : 01
*/
private WeatherIdEntity weather_id;
private String wind;
private String week;
private String date;
public void setTemperature(String temperature) {
this.temperature = temperature;
}
public void setWeather(String weather) {
this.weather = weather;
}
public void setWeather_id(WeatherIdEntity weather_id) {
this.weather_id = weather_id;
}
public void setWind(String wind) {
this.wind = wind;
}
public void setWeek(String week) {
this.week = week;
}
public void setDate(String date) {
this.date = date;
}
public String
getTemperature() {
return temperature;
}
public String
getWeather() {
return weather;
}
public WeatherIdEntity
getWeather_id() {
return weather_id;
}
public String
getWind() {
return wind;
}
public String
getWeek() {
return week;
}
public String
getDate() {
return date;
}
public static class WeatherIdEntity {
private String fa;
private String fb;
public void setFa(String fa) {
this.fa = fa;
}
public void setFb(String fb) {
this.fb = fb;
}
public String
getFa() {
return fa;
}
public String
getFb() {
return fb;
}
@Override
public String
toString() {
return "WeatherIdEntity{" +
"fa='" + fa +
'\'' +
", fb='" + fb +
'\'' +
'}';
}
}
@Override
public String
toString() {
return "FutureEntity{" +
"temperature='" + temperature +
'\'' +
", weather='" + weather +
'\'' +
", weather_id=" + weather_id +
", wind='" + wind +
'\'' +
", week='" + week +
'\'' +
", date='" + date +
'\'' +
'}';
}
}
@Override
public String
toString() {
return "ResultEntity{" +
"sk=" + sk +
", today=" + today +
", future=" + future +
'}';
}
}
@Override
public String
toString() {
return "WeatherData{" +
"resultcode='" + resultcode +
'\'' +
", reason='" + reason +
'\'' +
", result=" + result +
", error_code=" + error_code +
'}';
}
}
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494
总结
最后总结一下，通过使用mvp对代码进行分层之后，模块化更加的清楚，假如要换网络框架，需要修改model层和api层的代码，其他的层的代码都不需要再动，这样各层之间保持单一职责。代码的易读性变得更强了。
代码的下载地址
代码的运行效果：
欢迎大家查看。如果有问题直接回复。
