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。

相关文章

Java实现检查多个时间段是否有重合

Java实现检查多个时间段是否有重合

《Java实现检查多个时间段是否有重合》这篇文章主要为大家详细介绍了如何使用Java实现检查多个时间段是否有重合,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录流程概述步骤详解China编程步骤1：定义时间段类步骤2：添加时间段步骤3：检查时间段是否有重合步骤4：输出结果示例代码结语作
阅读更多...
Java中String字符串使用避坑指南

Java中String字符串使用避坑指南

《Java中String字符串使用避坑指南》Java中的String字符串是我们日常编程中用得最多的类之一,看似简单的String使用,却隐藏着不少“坑”,如果不注意,可能会导致性能问题、意外的错误容... 目录8个避坑点如下：1. 字符串的不可变性：每次修改都创建新对象2. 使用 == 比较字符串，陷阱满
阅读更多...
Java判断多个时间段是否重合的方法小结

Java判断多个时间段是否重合的方法小结

《Java判断多个时间段是否重合的方法小结》这篇文章主要为大家详细介绍了Java中判断多个时间段是否重合的方法,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录判断多个时间段是否有间隔判断时间段集合是否与某时间段重合判断多个时间段是否有间隔实体类内容public class D
阅读更多...
使用C++实现链表元素的反转

使用C++实现链表元素的反转

《使用C++实现链表元素的反转》反转链表是链表操作中一个经典的问题,也是面试中常见的考题,本文将从思路到实现一步步地讲解如何实现链表的反转,帮助初学者理解这一操作,我们将使用C++代码演示具体实现,同... 目录问题定义思路分析代码实现带头节点的链表代码讲解其他实现方式时间和空间复杂度分析总结问题定义给定
阅读更多...
IDEA编译报错“java: 常量字符串过长”的原因及解决方法

IDEA编译报错“java: 常量字符串过长”的原因及解决方法

《IDEA编译报错“java:常量字符串过长”的原因及解决方法》今天在开发过程中,由于尝试将一个文件的Base64字符串设置为常量,结果导致IDEA编译的时候出现了如下报错java:常量字符串过长,... 目录一、问题描述二、问题原因2.1 理论角度2.2 源码角度三、解决方案解决方案①：StringBui
阅读更多...
Java覆盖第三方jar包中的某一个类的实现方法

Java覆盖第三方jar包中的某一个类的实现方法

《Java覆盖第三方jar包中的某一个类的实现方法》在我们日常的开发中,经常需要使用第三方的jar包,有时候我们会发现第三方的jar包中的某一个类有问题,或者我们需要定制化修改其中的逻辑,那么应该如何... 目录一、需求描述二、示例描述三、操作步骤四、验证结果五、实现原理一、需求描述需求描述如下：需要在
阅读更多...
Java中ArrayList和LinkedList有什么区别举例详解

Java中ArrayList和LinkedList有什么区别举例详解

《Java中ArrayList和LinkedList有什么区别举例详解》：本文主要介绍Java中ArrayList和LinkedList区别的相关资料,包括数据结构特性、核心操作性能、内存与GC影... 目录一、底层数据结构二、核心操作性能对比三、内存与 GC 影响四、扩容机制五、线程安全与并发方案六、工程
阅读更多...
JavaScript中的reduce方法执行过程、使用场景及进阶用法

JavaScript中的reduce方法执行过程、使用场景及进阶用法

《JavaScript中的reduce方法执行过程、使用场景及进阶用法》：本文主要介绍JavaScript中的reduce方法执行过程、使用场景及进阶用法的相关资料,reduce是JavaScri... 目录1. 什么是reduce2. reduce语法2.1 语法2.2 参数说明3. reduce执行过程
阅读更多...
如何使用Java实现请求deepseek

如何使用Java实现请求deepseek

《如何使用Java实现请求deepseek》这篇文章主要为大家详细介绍了如何使用Java实现请求deepseek功能,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录1.deepseek的api创建2.Java实现请求deepseek2.1 pom文件2.2 json转化文件2.2
阅读更多...
Java调用DeepSeek API的最佳实践及详细代码示例

Java调用DeepSeek API的最佳实践及详细代码示例

《Java调用DeepSeekAPI的最佳实践及详细代码示例》：本文主要介绍如何使用Java调用DeepSeekAPI,包括获取API密钥、添加HTTP客户端依赖、创建HTTP请求、处理响应、... 目录1. 获取API密钥2. 添加HTTP客户端依赖3. 创建HTTP请求4. 处理响应5. 错误处理6.
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2