MVP+Retrofit+RxJava(Flowable)结合使用

痛定思痛。 2022-06-04 06:54 172阅读 0赞

## **MVP流程图：** ##

**![Center][]**

**添加依赖:**

compile 'io.reactivex.rxjava2:rxjava:2.1.7'
    compile 'io.reactivex.rxjava2:rxandroid:2.0.1'
    
    compile 'com.squareup.retrofit2:retrofit:2.3.0'
    compile 'com.squareup.retrofit2:converter-gson:2.3.0'
    compile 'com.squareup.retrofit2:adapter-rxjava2:2.3.0'

http

**ApiService接口实体类**`import com.bwie.com.myapplication.bean.MessageBean; import com.bwie.com.myapplication.bean.News; import java.util.List; import java.util.Map; import io.reactivex.Flowable; import retrofit2.http.GET; import retrofit2.http.QueryMap; /** * Created by Wangrx on 2017/12/6. */ public interface ApiService { @GET("93app/data.do") Flowable<MessageBean<List<News>>> getNews(@QueryMap Map<String,String> map); }`

RetrofitUtils（封装网络请求类）`import retrofit2.Retrofit; import retrofit2.adapter.rxjava2.RxJava2CallAdapterFactory; import retrofit2.converter.gson.GsonConverterFactory; /** * Created by Wangrx on 2017/12/6. */ public class RetrofitUtils { private static volatile RetrofitUtils instance; private ApiService apiService; private RetrofitUtils(){ Retrofit retrofit = new Retrofit.Builder() .addConverterFactory(GsonConverterFactory.create()) .addCallAdapterFactory(RxJava2CallAdapterFactory.create()) .baseUrl("http://www.93.gov.cn/") .build(); apiService = retrofit.create(ApiService.class); } public static RetrofitUtils getInstance(){ if (null==instance){ synchronized (RetrofitUtils.class){ if (instance==null){ instance = new RetrofitUtils(); } } } return instance; } public ApiService getApiService(){ return apiService; } }`

model层

**IModel接口**`import java.util.Map; /** * Created by Wangrx on 2017/12/6. */ public interface IModel { void getData(Map<String,String> map); }`

NewsModel`import com.bwie.com.myapplication.bean.MessageBean; import com.bwie.com.myapplication.bean.News; import com.bwie.com.myapplication.http.RetrofitUtils; import com.bwie.com.myapplication.presenter.NewsPresenter; import java.util.List; import java.util.Map; import io.reactivex.Flowable; /** * Created by Wangrx on 2017/12/6. */ public class NewsModel implements IModel{ private NewsPresenter presenter; public NewsModel(NewsPresenter presenter){ this.presenter = presenter; } @Override public void getData(Map<String, String> map) { Flowable<MessageBean<List<News>>> flowable = RetrofitUtils.getInstance().getApiService().getNews(map); presenter.getNews(flowable); } }`

presenter层

**BasePresenter接口**`import java.util.Map; /** * Created by Wangrx on 2017/12/6. */ public interface BasePresenter { void getData(Map<String,String> map); }`

NewsPresenter`import com.bwie.com.myapplication.bean.MessageBean; import com.bwie.com.myapplication.bean.News; import com.bwie.com.myapplication.model.NewsModel; import com.bwie.com.myapplication.view.Iview; import java.util.List; import java.util.Map; import io.reactivex.Flowable; import io.reactivex.android.schedulers.AndroidSchedulers; import io.reactivex.schedulers.Schedulers; import io.reactivex.subscribers.DisposableSubscriber; /** * Created by Wangrx on 2017/12/6. */ public class NewsPresenter implements BasePresenter { private Iview iv; private DisposableSubscriber subscriber; public void attachView(Iview iv) { this.iv = iv; } public void detachView() { if (iv != null) { iv = null; } if (!subscriber.isDisposed()){ subscriber.dispose(); } } @Override public void getData(Map<String, String> map) { NewsModel model = new NewsModel(this); model.getData(map); } public void getNews(Flowable<MessageBean<List<News>>> flowable) { subscriber = flowable.subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribeWith(new DisposableSubscriber<MessageBean<List<News>>>() { @Override public void onNext(MessageBean<List<News>> listMessageBean) { if (listMessageBean != null) { List<News> list = listMessageBean.getData(); if (list != null) { iv.onSuccess(list); } } } @Override public void onError(Throwable t) { iv.onFailed((Exception) t); } @Override public void onComplete() { } }); } }`

view层

**Iview接口**`/** * Created by Wangrx on 2017/12/6. */ public interface Iview { void onSuccess(Object o); void onFailed(Exception e); }`

MainActivity`import android.os.Bundle; import android.support.v7.app.AppCompatActivity; import android.util.Log; import com.bwie.com.myapplication.bean.News; import com.bwie.com.myapplication.presenter.NewsPresenter; import com.bwie.com.myapplication.view.Iview; import java.util.HashMap; import java.util.List; import java.util.Map; public class MainActivity extends AppCompatActivity { private NewsPresenter presenter; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); //http://www.93.gov.cn/93app/data.do?channelId=0&startNum=0 Map<String, String> map = new HashMap<>(); map.put("channelId","0"); map.put("startNum","0"); presenter = new NewsPresenter(); presenter.getData(map); presenter.attachView(new Iview() { @Override public void onSuccess(Object o) { if (o instanceof List){ List<News> news = (List<News>) o; Log.i("zzz", "onSuccess: "+news.size()); } } @Override public void onFailed(Exception e) { Log.i("zzz", "onSuccess: "+e.getMessage()); } }); } @Override protected void onDestroy() { super.onDestroy(); if (presenter!=null){ presenter.detachView(); } } }`

在MainActivity中onSuccess()得到数据，将数据显示出来即可。

[Center]: /images/20220604/640fd65f3f954d9ba2812f18455ac408.png