Retrofit+Rxjava+MVP的简单使用

Retrofit 的使用

Retrofit GitHub 官方地址
Retrofit 是square公司出的一个框架，是基于OkHttp进行封装。

第一步:导入Retrofit 依赖:

   //rxjava依赖
    implementation 'io.reactivex.rxjava2:rxjava:2.1.9'
    implementation 'io.reactivex.rxjava2:rxandroid:2.0.2'
   //retrofit依赖
    implementation 'com.squareup.retrofit2:retrofit:2.4.0'
    implementation 'com.squareup.retrofit2:adapter-rxjava2:2.4.0'
    implementation 'com.squareup.retrofit2:converter-gson:2.4.0'
    implementation 'com.squareup.okhttp3:okhttp:3.10.0'
    implementation 'com.squareup.okhttp3:logging-interceptor:3.9.1'

第二步创建实体类

现在这样一个api接口
http://service.picasso.adesk.com/v1/vertical/vertical?limit=30&skip=180&adult=false&first=0&order=hot
根据返回json数据创建实体类

RetrofitBean

第三步我们新创建一个用于网络请求的接口叫RetrofitService他长这样 ↓

public interface RetrofitService {
   //  get请求无参数这样
    @GET("v1/vertical/vertical?limit=30&skip=180&adult=false&first=0&order=hot")
   //要调用的方法和要解析的实体类
    Call<RetrofitBean> getData();
   //使用path  
    @GET("v1/{vertical}/vertical?limit=30&skip=180&adult=false&first=0&order=hot")
    Call<RetrofitBean> getPath(@Path("vertical") String vertical);
  //使用Query
    @GET("v1/vertical/vertical?limit=30&skip=180&adult=false")
    Call<RetrofitBean> getQuery(@Query("first") int fist,@Query("order") String hot);
   //使用url 需要传递整个url，如传递v1/vertical/vertical?limit=30&skip=180&adult=false&first=0&order=hot
    @GET()
    Call<RetrofitBean> getUrl(@Url String url);
}

在需要请求的地方调用

   String baseUrl="http://service.picasso.adesk.com/"; //要以/结尾
//创建Retrofit 并添加baseurl，gson解析
Retrofit retrofit = new Retrofit.Builder().baseUrl(baseUrl).addConverterFactory(GsonConverterFactory.create()).build();
//获取服务接口并创建
RetrofitService service=retrofit.create(RetrofitService.class);
   service.getData().enqueue(new Callback<RetrofitBean>() {
            @Override
            public void onResponse(Call<RetrofitBean> call, Response<RetrofitBean> response){
                Log.e("response--getData：",response.toString()+"");
            }
            @Override
            public void onFailure(Call<RetrofitBean> call, Throwable t) {
            }
        });
   service.getPath("vertical").enqueue(new Callback<RetrofitBean>() {
            @Override
            public void onResponse(Call<RetrofitBean> call, Response<RetrofitBean> response) {
                Log.e("response--getPath：",response.response.toString()+"");
            }

            @Override
            public void onFailure(Call<RetrofitBean> call, Throwable t) {
            }
        });
     service.getQuery(0,"hot").enqueue(new Callback<RetrofitBean>() {
            @Override
            public void onResponse(Call<RetrofitBean> call, Response<RetrofitBean> response) {
                Log.e("response--getQuery：",response.response.toString()+"");
            }

            @Override
            public void onFailure(Call<RetrofitBean> call, Throwable t) {
            }
        });
       service.getUrl("v1/vertical/vertical?limit=30&skip=180&adult=false&first=0&order=hot").enqueue(new Callback<RetrofitBean>() {
            @Override
            public void onResponse(Call<RetrofitBean> call, Response<RetrofitBean> response) {
                Log.e("response--getUrl：",response.response.toString()+"");
            }

            @Override
            public void onFailure(Call<RetrofitBean> call, Throwable t) {
            }
        });

查看log打印：

日志

这样我们就成功请求到了，只不过使用了不同的url拼接方式去请求

Rxjava

Rxjava简单使用

//被观察者
 Observable.create(new ObservableOnSubscribe<Integer>() {
            @Override
            public void subscribe(ObservableEmitter<Integer> emitter) throws Exception {
                //ObservableEmitter是用来发送事件 onNext、onError、onComplete
                emitter.onNext(1);
                emitter.onNext(2);
                //onComplete 阻止onNext事件继续接收事件，发送没有影响
                emitter.onComplete();
                emitter.onNext(3);
                emitter.onNext(4);
            }
        }) //观察者
        .subscribe(new Observer<Integer>() {
            @Override
            public void onSubscribe(Disposable d) {
            }
            @Override
            public void onNext(Integer integer) {
                Log.e("onNext", integer + "");
                buffer.append("onNext：" + integer + constans.mNewline);
                textView.setText(buffer);
            }
            @Override
            public void onError(Throwable e) {
            }
            @Override
            public void onComplete() {
            }
        });

log日志如下：

logRxjav.png

Rxjava线程切换：

 Observable.create(new ObservableOnSubscribe<Integer>() {
            @Override
            public void subscribe(ObservableEmitter<Integer> emitter) throws Exception {
                Log.e("Observable_Thread",Thread.currentThread().getName()+"");
                emitter.onNext(1);
                emitter.onNext(2);
                emitter.onNext(3);
                emitter.onNext(4);
            }
       }).observeOn(AndroidSchedulers.mainThread()).subscribeOn(Schedulers.io()).subscribe(new Observer<Integer>() {
            @Override
            public void onSubscribe(Disposable d) {
            }
            @Override
            public void onNext(Integer integer) {
                Log.e("Observer_onNext",Thread.currentThread().getName()+"");
            }
            @Override
            public void onError(Throwable e) {
            }
            @Override
            public void onComplete() {
            }
        });

log日志如下：

线程.png

我们看到跟上一段代码只是添加了
观察者所在线程observeOn(AndroidSchedulers.mainThread())
被观察者所在线程subscribeOn(Schedulers.io())

Retrofit+Rxjava简单封装

获取okhttp拦截，这里只是拦截了url连接

public class OkHttpClientHelper {
    //写入超时
    private static final int WRITE_TIME_OUT = 30;
    //建立连接的超时时间
    private static final int CONNECT_TIME_OUT = 30;
    //读取超时
    private static final int READ_TIME_OUT = 30;
    private static OkHttpClientHelper client;
    private OkHttpClient mOkHttpClient;

    public static OkHttpClientHelper getmOkHttpClient() {
        if (client == null) return new OkHttpClientHelper();
        return client;
    }

    public OkHttpClient getClient() {
        mOkHttpClient = new OkHttpClient.Builder().writeTimeout(WRITE_TIME_OUT, TimeUnit.SECONDS).connectTimeout(CONNECT_TIME_OUT, TimeUnit.SECONDS).readTimeout(READ_TIME_OUT, TimeUnit.SECONDS).addNetworkInterceptor(new Interceptor() {
            @Override
            public Response intercept(Chain chain) throws IOException {
                Request request = chain.request();
                Response response = chain.proceed(request);
                Log.e("URL-----",response.toString());
                return response;
            }
        }).build();
        return mOkHttpClient;
    }

创建服务获取Retrofit

public class RetrofitApi {
    public static <T> T getApiService(Class<T> tClass, String BaseUrl) {
//client添加自己的okhttp  addCallAdapterFactory添加rxjava适配器 addConverterFactory 添加gson适配器
        Retrofit retrofit = new Retrofit.Builder().client(OkHttpClientHelper.getmOkHttpClient().getClient()).addCallAdapterFactory(RxJava2CallAdapterFactory.create()).addConverterFactory(GsonConverterFactory.create()).baseUrl(BaseUrl).build();
        return retrofit.create(tClass);
    }
}

public class RetrofitHelper {
    private static RetrofitHelper mHelper;
    private String BASE_URL = "";
    private RetrofitHelper() {
        BASE_URL = constans.baseUrl;
    }
    public static RetrofitHelper getService() {
        if (mHelper == null) mHelper = new RetrofitHelper();
        return mHelper;
    }

    public RetrofitService getApi() {
        return RetrofitApi.getApiService(RetrofitService.class, BASE_URL);
    }
}

设置默认观察者请求回调

public abstract class DefaultObserver<T> implements Observer<T> {
    private String ERROR_TOAST ="";
    @Override
    public void onSubscribe(Disposable d) {

    }

    @Override
    public void onNext(T t) {
        onSuccess(t);
        onFinish();
    }

    @Override
    public void onError(Throwable e) {
        if (e instanceof ConnectException){
            ERROR_TOAST="连接超时，请稍后重试！";
            onError(ERROR_TOAST);
            onFinish();
        }else {
            onError(e.getMessage());
            onFinish();
        }
    }

    @Override
    public void onComplete() {

    }

    public abstract void onSuccess(T data);

    public abstract void onError(String error);

    public abstract void onFinish();
}

MVP 模式

什么是MVP ，是有MVC演化而来。
M→Model（对数据的操作）
V→View（负责显示）
P→presenter（负责逻辑处理）
先创建一个BaseView和BasePresenter 接口里面放着通用操作

public interface BaseView<T> {
    void lodingShow();
    void lodingDissmis();
    void setPresenter(T presenter);
}
public interface BasePresenter {
    void start();
}

创建一个Model接口回调

public interface BaseHttpEntity<T> {
    void onSuccess(T data);
    void onError(String error);
    void onFinish();
}

创建Controller类

    public interface Presenter extends BasePresenter {
        void getData();
    }
    public interface View extends BaseView<Presenter> {
        void setData(RetrofitBean RetrofitBean);
    }
    public interface Model {
        void getModel(BaseHttpEntity<RetrofitBean > entity);
    }
}

创建Model类实现Controller.Model

public class Mode implements Controller.Model {

    @Override
    public void getModel(final BaseHttpEntity<RetrofitBean> entity) {
        RetrofitHelper.getService().getApi().getData().subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).subscribe(new DefaultObserver<RetrofitBean>() {

            @Override
            public void onSuccess(RetrofitBean data) {
                entity.onSuccess(data);
            }
            @Override
            public void onError(String error) {
                entity.onError(error);
            }
            @Override
            public void onFinish() {
            }
        });
    }
}

创建Presenter类实现Controller.presenter

public class Presenter implements Controller.presenter {
    private Controller.Model model;
    private Controller.View view;

    public Presenter(Controller.View view) {
        this.view = view;
        model = new Mode();
        view.setPresenter(this);
    }
    @Override
    public void getData() {
   model.getModel(new BaseHttpEntity<RetrofitBean>() {
       @Override
       public void onSuccess(RetrofitBean data) {
           view.setData(data);
       }
       @Override
       public void onError(String error) {
       }
       @Override
       public void onFinish() {
       }
   });
    }

    @Override
    public void start() {
          getData();
    }
}

在activity中

public class MvpActivity extends AppCompatActivity implements Controller.View {
    private Controller.presenter presenter;
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_mvp);
        new Presenter(this);
        presenter.start();
    }
    @Override
    public void setData(RetrofitBean mRetrofitBean) {
        Log.e("mRetrofitBean.getCode()",mRetrofitBean.getCode()+"");
    }
    @Override
    public void lodingShow() {
    }
    @Override
    public void lodingDissmis() {
    }

    @Override
    public void setPresenter(Controller.presenter presenter) {
        this.presenter = presenter;
    }
}

要把RetrofitService中Call改成Observable！！！
项目地址GitHub

最后编辑于：2018.04.25 18:25:13

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 219,366评论 6赞 508
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 93,521评论 3赞 395
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 165,689评论 0赞 356
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 58,925评论 1赞 295
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 67,942评论 6赞 392
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 51,727评论 1赞 305
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 40,447评论 3赞 420
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 39,349评论 0赞 276
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 45,820评论 1赞 317
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 37,990评论 3赞 337
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 40,127评论 1赞 351
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 35,812评论 5赞 346
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 41,471评论 3赞 331
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 32,017评论 0赞 22
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 33,142评论 1赞 272
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 48,388评论 3赞 373
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 45,066评论 2赞 355