Retrifit2+RxJava2 实现MVP

2024-08-22 20:18
文章标签 java 实现 mvp rx retrifit2

本文主要是介绍Retrifit2+RxJava2 实现MVP,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

第1步 在build.gradle中引入

   // Retrofit库implementation 'com.squareup.retrofit2:retrofit:2.3.0'implementation 'com.squareup.retrofit2:converter-gson:2.3.0'implementation 'com.squareup.retrofit2:adapter-rxjava2:2.3.0'// Okhttp库implementation 'com.squareup.okhttp3:okhttp:3.9.1'implementation 'io.reactivex.rxjava2:rxjava:2.1.5'implementation 'io.reactivex.rxjava2:rxandroid:2.0.1'

   (网络权限:    <uses-permission android:name="android.permission.INTERNET"/>)

 

第2步 初始化和Base创建

2.1 LogInterceptor

import android.util.Log;import java.io.IOException;import okhttp3.Interceptor;
import okhttp3.MediaType;
import okhttp3.Request;
import okhttp3.RequestBody;
import okhttp3.Response;
import okhttp3.ResponseBody;
import okio.Buffer;public class LogInterceptor implements Interceptor {@Overridepublic Response intercept(Chain chain) throws IOException {Request request = chain.request();Log.e("info", String.format("%1$s->%2$s", request.method(), request.url()));if (request.headers() != null) {Log.e("info", "Headers:" + request.headers());}if (request.body() != null) {Log.e("info", "RequestBody:" + bodyToString(request.body()));}Response response = chain.proceed(chain.request());MediaType mediaType = response.body().contentType();String responseBody = response.body().string();Log.e("info", "ResponseBody:" + responseBody);return response.newBuilder().body(ResponseBody.create(mediaType, responseBody)).build();}private String bodyToString(final RequestBody request) {if (request != null) {try {final RequestBody copy = request;final Buffer buffer = new Buffer();copy.writeTo(buffer);return buffer.readUtf8();} catch (final IOException e) {Log.e("info", "Did not work.");}}return null;}
}

 

2.2 ApiManager

import java.util.concurrent.TimeUnit;import okhttp3.OkHttpClient;
import retrofit2.Retrofit;
import retrofit2.adapter.rxjava2.RxJava2CallAdapterFactory;
import retrofit2.converter.gson.GsonConverterFactory;public class ApiManager {private OkHttpClient mOkHttpClient;private static String mBaseUrl = "http://www.gwadarpro.com";private static int mTimeout = 20;private static ApiManager mInstance = new ApiManager();private Retrofit mRetrofit;public static ApiManager getInstance() {return mInstance;}private ApiManager() {}public <T> T getApiService(Class<T> service) {return getRetrofit().create(service);}private Retrofit getRetrofit() {if (mRetrofit == null) {mRetrofit = new Retrofit.Builder().baseUrl(mBaseUrl).addConverterFactory(GsonConverterFactory.create()).addCallAdapterFactory(RxJava2CallAdapterFactory.create()).client(getOkHttpClient()).build();}return mRetrofit;}private OkHttpClient getOkHttpClient() {if (mOkHttpClient == null) {mOkHttpClient = new OkHttpClient.Builder().connectTimeout(mTimeout, TimeUnit.SECONDS).readTimeout(mTimeout, TimeUnit.SECONDS).writeTimeout(mTimeout, TimeUnit.SECONDS).retryOnConnectionFailure(true).addInterceptor(new LogInterceptor()).build();}return mOkHttpClient;}
}

2.3 ApiService(定义接口地址、参数):

import com.jlncjf.retrofit2demo.model.LoginBean;import io.reactivex.Observable;
import retrofit2.http.Field;
import retrofit2.http.FormUrlEncoded;
import retrofit2.http.POST;public interface ApiService {/*** 登录** @param username     用户名* @param password     密码* @param type         登录类型* @param google_token 谷歌推送token* @return*/@FormUrlEncoded@POST("/mobile/index.php?act=login&op=index")Observable<LoginBean> login(@Field("username") String username, @Field("password") String password, @Field("type") String type, @Field("google_token") String google_token);
}

2.4 ApiObserver

import io.reactivex.Observable;
import io.reactivex.Observer;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.annotations.NonNull;
import io.reactivex.disposables.Disposable;
import io.reactivex.schedulers.Schedulers;public class ApiObserver<T> implements Observer<T> {private final ApiCallback<T> mCallback;public ApiObserver(ApiCallback<T> callback) {this.mCallback = callback;}@Overridepublic void onSubscribe(@NonNull Disposable d) {}@Overridepublic void onError(Throwable e) {if (mCallback != null) {mCallback.onError(e);}}@Overridepublic void onNext(T t) {if (mCallback != null) {mCallback.onNext(t);}}@Overridepublic void onComplete() {if (mCallback != null) {mCallback.onCompleted();}}public static <T> ApiObserver<T> getApiObserver(ApiCallback<T> callback) {return new ApiObserver<>(callback);}public static <T> void subscribe(Observable<T> observable, SimpleCallback<T> callback) {observable.subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).subscribe(getApiObserver(callback));}}

 

2.5 ApiCallback:

public interface ApiCallback<T> {void onNext(T t);void onError(Throwable e);void onCompleted();}

2.5 SimpleCallback

import com.jlncjf.retrofit2demo.mvp.View.BaseView;public abstract class SimpleCallback<T> implements ApiCallback<T> {private BaseView mView;public SimpleCallback(BaseView mView){this.mView = mView;}@Overridepublic void onError(Throwable e) {mView.onError(e);}@Overridepublic void onCompleted() {mView.onCompleted();}
}

2.6 BaseBean(网络请求返回):

public class BaseBean {private int errCode;private String errMess;public int getErrCode() {return errCode;}public void setErrCode(int errCode) {this.errCode = errCode;}public String getErrMess() {return errMess;}public void setErrMess(String errMess) {this.errMess = errMess;}
}

2.7 BaseView:

public interface BaseView {void onError(Throwable e);void onCompleted();
}

2.8 IPresenter

import com.jlncjf.retrofit2demo.mvp.View.BaseView;public interface IPresenter<T extends BaseView> {void attachView(T view);void detachView();
}

2.9 BasePresenter:

import com.jlncjf.retrofit2demo.mvp.View.BaseView;public class BasePresenter<T extends BaseView> implements IPresenter<T> {protected T mView;@Overridepublic void attachView(T view) {mView = view;}@Overridepublic void detachView() {mView = null;}
}

 

2.10 BaseActivity:

import android.os.Bundle;
import android.support.annotation.LayoutRes;
import android.support.annotation.Nullable;
import android.support.v7.app.AppCompatActivity;import com.jlncjf.retrofit2demo.mvp.Presenter.BasePresenter;
import com.jlncjf.retrofit2demo.mvp.View.BaseView;public abstract class BaseActivity<T extends BasePresenter> extends AppCompatActivity implements BaseView {protected T mPresenter;protected BaseActivity mContext;@Overridepublic void onCreate(@Nullable Bundle savedInstanceState) {super.onCreate(savedInstanceState);mContext = this;setContentView(getRootViewId());initPresenter();if (mPresenter != null) {mPresenter.attachView(this);}initView();initData();}public abstract @LayoutResint getRootViewId();public abstract void initView();public abstract void initPresenter();public abstract void initData();@Overrideprotected void onDestroy() {super.onDestroy();if (mPresenter != null) {mPresenter.detachView();}}
}

 

2.11 Api

import com.jlncjf.retrofit2demo.model.LoginBean;public class Api {private static ApiService apiService;private Api() {throw new AssertionError();}private static ApiService getApiService() {if (apiService == null) {apiService = ApiManager.getInstance().getApiService(ApiService.class);}return apiService;}public static void login(String username, String password, String type, String google_token, SimpleCallback<LoginBean> callback) {ApiObserver.subscribe(getApiService().login(username, password, type, google_token), callback);}
}

 

3、具体实现

3.1 LoginBean(登录返回对应的实体类)

public class LoginBean extends BaseBean{private DataBean data;public DataBean getData() {return data;}public void setData(DataBean data) {this.data = data;}public static class DataBean {private String nickname;public String getNickname() {return nickname;}public void setNickname(String nickname) {this.nickname = nickname;}}
}

3.2 ILoginView(定义View中需要的接口,比如拿到数据以后)

import com.jlncjf.retrofit2demo.model.LoginBean;public interface ILoginView extends BaseView {void onLoginData(LoginBean bean);
}

3.3 LoginPresenter

import com.jlncjf.retrofit2demo.Api;
import com.jlncjf.retrofit2demo.mvp.View.ILoginView;
import com.jlncjf.retrofit2demo.SimpleCallback;
import com.jlncjf.retrofit2demo.mvp.model.LoginBean;public class LoginPresenter extends BasePresenter<ILoginView> {public void login(String username, String password, String type, String google_token) {Api.login(username, password, type, google_token, new SimpleCallback<LoginBean>(mView) {@Overridepublic void onNext(LoginBean bean) {mView.onLoginData(bean);}});}
}

3.4 LoginActivity

import android.widget.TextView;import com.jlncjf.retrofit2demo.mvp.Presenter.LoginPresenter;
import com.jlncjf.retrofit2demo.mvp.View.ILoginView;
import com.jlncjf.retrofit2demo.mvp.model.LoginBean;public class LoginActivity extends BaseActivity<LoginPresenter> implements ILoginView {private static final String TAG = "LoginActivity";private TextView tv_result;@Overridepublic int getRootViewId() {return R.layout.activity_main;}@Overridepublic void initView() {tv_result = findViewById(R.id.tv_result);}@Overridepublic void initPresenter() {mPresenter = new LoginPresenter();}@Overridepublic void initData() {mPresenter.login("wangjinqiang", "qq", "0", "token");}@Overridepublic void onLoginData(LoginBean bean) {//根据登录返回的状态码做相应处理if (bean.getErrCode() == 200) {tv_result.setText(bean.getData().getNickname());} else {tv_result.setText("errCode:" + String.valueOf(bean.getErrCode()));}}@Overridepublic void onError(Throwable e) {tv_result.setText(e.getMessage());e.printStackTrace();}@Overridepublic void onCompleted() {}
}

Demo下载地址:https://download.csdn.net/download/u012954039/10615514

这篇关于Retrifit2+RxJava2 实现MVP的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1097293

相关文章

springboot security快速使用示例详解

《springbootsecurity快速使用示例详解》:本文主要介绍springbootsecurity快速使用示例,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝... 目录创www.chinasem.cn建spring boot项目生成脚手架配置依赖接口示例代码项目结构启用s

java之Objects.nonNull用法代码解读

《java之Objects.nonNull用法代码解读》:本文主要介绍java之Objects.nonNull用法代码,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐... 目录Java之Objects.nonwww.chinasem.cnNull用法代码Objects.nonN

Python如何使用__slots__实现节省内存和性能优化

《Python如何使用__slots__实现节省内存和性能优化》你有想过,一个小小的__slots__能让你的Python类内存消耗直接减半吗,没错,今天咱们要聊的就是这个让人眼前一亮的技巧,感兴趣的... 目录背景:内存吃得满满的类__slots__:你的内存管理小助手举个大概的例子:看看效果如何?1.

springboot security之前后端分离配置方式

《springbootsecurity之前后端分离配置方式》:本文主要介绍springbootsecurity之前后端分离配置方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的... 目录前言自定义配置认证失败自定义处理登录相关接口匿名访问前置文章总结前言spring boot secu

Python+PyQt5实现多屏幕协同播放功能

《Python+PyQt5实现多屏幕协同播放功能》在现代会议展示、数字广告、展览展示等场景中,多屏幕协同播放已成为刚需,下面我们就来看看如何利用Python和PyQt5开发一套功能强大的跨屏播控系统吧... 目录一、项目概述:突破传统播放限制二、核心技术解析2.1 多屏管理机制2.2 播放引擎设计2.3 专

一文详解SpringBoot响应压缩功能的配置与优化

《一文详解SpringBoot响应压缩功能的配置与优化》SpringBoot的响应压缩功能基于智能协商机制,需同时满足很多条件,本文主要为大家详细介绍了SpringBoot响应压缩功能的配置与优化,需... 目录一、核心工作机制1.1 自动协商触发条件1.2 压缩处理流程二、配置方案详解2.1 基础YAML

Python实现无痛修改第三方库源码的方法详解

《Python实现无痛修改第三方库源码的方法详解》很多时候,我们下载的第三方库是不会有需求不满足的情况,但也有极少的情况,第三方库没有兼顾到需求,本文将介绍几个修改源码的操作,大家可以根据需求进行选择... 目录需求不符合模拟示例 1. 修改源文件2. 继承修改3. 猴子补丁4. 追踪局部变量需求不符合很

java中使用POI生成Excel并导出过程

《java中使用POI生成Excel并导出过程》:本文主要介绍java中使用POI生成Excel并导出过程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录需求说明及实现方式需求完成通用代码版本1版本2结果展示type参数为atype参数为b总结注:本文章中代码均为

springboot简单集成Security配置的教程

《springboot简单集成Security配置的教程》:本文主要介绍springboot简单集成Security配置的教程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,... 目录集成Security安全框架引入依赖编写配置类WebSecurityConfig(自定义资源权限规则

Java的IO模型、Netty原理解析

《Java的IO模型、Netty原理解析》Java的I/O是以流的方式进行数据输入输出的,Java的类库涉及很多领域的IO内容:标准的输入输出,文件的操作、网络上的数据传输流、字符串流、对象流等,这篇... 目录1.什么是IO2.同步与异步、阻塞与非阻塞3.三种IO模型BIO(blocking I/O)NI