鸿蒙 MVP+ Rxjava+Retrofit+okhttp 实现教程-6ren

鸿蒙 MVP+ Rxjava+Retrofit+okhttp 实现教程

转载作者：qq735679552 更新时间：2022-09-27 22:32:09

26

4

CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章鸿蒙 MVP+ Rxjava+Retrofit+okhttp 实现教程由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.

鸿蒙 MVP+ Rxjava+Retrofit+okhttp 实现教程

前言：

各位同学大家好，有段时间没有给大家更新文章，最近还在学习鸿蒙开发的支持，就想着把android里面部分用到知识搬到鸿蒙里面因为基础语言都是java 语言，所以就写了现在这教程那么废话不多说我们正式开始。

##效果图

准备工作

1 安装鸿蒙开发环境大家可以看我之前的文章。

需要用到的三方库

//okhttp3
implementation 'com.squareup.okhttp3:okhttp:4.2.0'
implementation "com.squareup.okhttp3:logging-interceptor:3.10.0"
//retrofit2
implementation 'com.squareup.retrofit2:retrofit:2.9.0'
implementation 'com.squareup.retrofit2:converter-gson:2.9.0'
implementation 'com.squareup.retrofit2:adapter-rxjava3:2.9.0'

请在build.gradle里面添加依赖然后sygn now 同步下载依赖。

具体实现

MainAbility布局代码。

<?xml version="1.0" encoding="utf-8"?>
<DirectionalLayout
xmlns:ohos="http://schemas.huawei.com/res/ohos"
ohos:height="match_parent"
ohos:width="match_parent"
ohos:orientation="vertical">
<Text
ohos:id="$+id:text_fruit_tag"
ohos:height="35vp"
ohos:width="match_parent"
ohos:background_element="$graphic:text_element"
ohos:layout_alignment="left"
ohos:text="账户"
ohos:text_size="85"
ohos:right_margin="20vp"
ohos:left_margin="20vp"
ohos:top_margin="25vp"
ohos:text_color="#000000"
/>
<TextField
ohos:id="$+id:text_username"
ohos:height="35vp"
ohos:width="match_parent"
ohos:background_element="$graphic:text_element"
ohos:layout_alignment="left"
ohos:text_size="50"
ohos:right_margin="20vp"
ohos:left_margin="20vp"
ohos:text_color="#000000"
ohos:top_margin="25vp"
ohos:basement="#000099"
ohos:hint="请输入账号"
/>
<Text
ohos:id="$+id:text_number_tag"
ohos:height="35vp"
ohos:width="match_parent"
ohos:background_element="$graphic:text_element"
ohos:layout_alignment="left"
ohos:text="密码"
ohos:text_size="85"
ohos:right_margin="20vp"
ohos:left_margin="20vp"
ohos:text_color="#000000"
ohos:top_margin="25vp"
/>
<TextField
ohos:id="$+id:text_password"
ohos:height="35vp"
ohos:width="match_parent"
ohos:background_element="$graphic:text_element"
ohos:layout_alignment="left"
ohos:text_size="50"
ohos:right_margin="20vp"
ohos:left_margin="20vp"
ohos:text_color="#000000"
ohos:top_margin="25vp"
ohos:basement="#000099"
ohos:hint="请输入密码"
/>
<Button
ohos:id="$+id:login_btn"
ohos:width="match_parent"
ohos:height="50vp"
ohos:text="登录"
ohos:background_element="$graphic:button_element"
ohos:text_size="50"
ohos:text_color="#FFFFFF"
ohos:top_margin="25vp"
ohos:right_margin="20vp"
ohos:left_margin="20vp"
/>
</DirectionalLayout>

布局效果

我们的目的很明确我们想拿到2个输入框的内容然后调用网络接口来实现登录的操作业务非常简单。

但是今天要用 MVP+ Rxjava+Retrofit+okhttp 来实现。

网络核心部分

RetrofitClient 类封装

package com.example.hmsrxjava_demo.net;
import java.io.IOException;
import io.reactivex.rxjava3.annotations.NonNull;
import ohos.agp.render.render3d.BuildConfig;
import okhttp3.Interceptor;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.Response;
import okhttp3.logging.HttpLoggingInterceptor;
import retrofit2.Retrofit;
import retrofit2.adapter.rxjava3.RxJava3CallAdapterFactory;
import retrofit2.converter.gson.GsonConverterFactory;
/**
* description：
*/
public class RetrofitClient {
private static volatile RetrofitClient instance;
private APIService apiService;
private String baseUrl = "https://www.wanandroid.com";
private Retrofit retrofit;
private OkHttpClient okHttpClient;
private RetrofitClient() {
}
public static RetrofitClient getInstance() {
if (instance == null) {
synchronized (RetrofitClient.class) {
if (instance == null) {
instance = new RetrofitClient();
}
}
}
return instance;
}
/**
* 设置Header
*
* @return
*/
private Interceptor getHeaderInterceptor() {
return new Interceptor() {
@Override
public Response intercept(@NonNull Chain chain) throws IOException {
Request original = chain.request();
Request.Builder requestBuilder = original.newBuilder();
//添加Token 如果需要添加请求头可以统一在这里添加
// Request.Builder requestBuilder = original.newBuilder().header("token", "");
Request request = requestBuilder.build();
return chain.proceed(request);
}
};
}
/**
* 设置拦截器打印日志
*
* @return
*/
private Interceptor getInterceptor() {
HttpLoggingInterceptor interceptor = new HttpLoggingInterceptor();
//显示日志
interceptor.setLevel(HttpLoggingInterceptor.Level.BODY);
return interceptor;
}
public OkHttpClient getOkHttpClient() {
if (okHttpClient == null) {
//如果为DEBUG 就打印日志
if (BuildConfig.DEBUG) {
okHttpClient = new OkHttpClient().newBuilder()
//设置Header
.addInterceptor(getHeaderInterceptor())
//设置拦截器
.addInterceptor(getInterceptor())
.build();
} else {
okHttpClient = new OkHttpClient().newBuilder()
//设置Header
.addInterceptor(getHeaderInterceptor())
.build();
}
}
return okHttpClient;
}
public APIService getApi() {
//初始化一个client,不然retrofit会自己默认添加一个
if (retrofit == null) {
retrofit = new Retrofit.Builder()
//设置网络请求的Url地址
.baseUrl(baseUrl)
//设置数据解析器
.addConverterFactory(GsonConverterFactory.create())
//设置网络请求适配器，使其支持RxJava与RxAndroid
.addCallAdapterFactory(RxJava3CallAdapterFactory.create())
.client(getOkHttpClient())
.build();
}
//创建—— 网络请求接口—— 实例
if (apiService==null){
apiService = retrofit.create(APIService.class);
}
return apiService;
}
}

我们写了一个单例来获取 RetrofitClient 实力并且设置的了请求头 handler 和设置OKHTTP 日志拦截器。

然后定义了 getApi 方法来获取 APIService 的实例。

RxScheduler

RXjava 线程调度。

package com.example.hmsrxjava_demo.net;
import com.example.hmsrxjava_demo.HarmonySchedulers;
import org.reactivestreams.Publisher;
import io.reactivex.rxjava3.core.Flowable;
import io.reactivex.rxjava3.core.FlowableTransformer;
import io.reactivex.rxjava3.core.Observable;
import io.reactivex.rxjava3.core.ObservableSource;
import io.reactivex.rxjava3.core.ObservableTransformer;
import io.reactivex.rxjava3.schedulers.Schedulers;
/**
* description：RXjava 线程调度
*/
public class RxScheduler {
/**
* 统一线程处理
*
* @param <T> 指定的泛型类型
* @return FlowableTransformer
*/
public static <T> FlowableTransformer< T, T> Flo_io_main() {
return new FlowableTransformer<T, T>() {
@Override
public Publisher<T> apply(Flowable<T> upstream) {
return upstream.subscribeOn(Schedulers.io())
.observeOn(HarmonySchedulers.mainThread());
}
};
}
/* *
* 统一线程处理
*
* @param <T> 指定的泛型类型
* @return ObservableTransformer*/
public static <T> ObservableTransformer<T, T> Obs_io_main() {
return new ObservableTransformer<T, T>() {
@Override
public ObservableSource<T> apply( Observable<T> upstream) {
return upstream.subscribeOn(Schedulers.io())
.observeOn(HarmonySchedulers.mainThread());
}
};
}
}

这里代码就参考了安卓里面部分没有的 HarmonySchedulers.mainThread() 参考了安卓里面的自己实现了一下。

APIService

处理网络请求的接口类所有网络请求的都写在 APIService 写法和安卓的 Retrofitle类似。

package com.example.hmsrxjava_demo.net;
import com.example.hmsrxjava_demo.bean.BaseObjectBean;
import com.example.hmsrxjava_demo.bean.LoginBean;
import io.reactivex.rxjava3.core.Observable;
import retrofit2.http.Field;
import retrofit2.http.FormUrlEncoded;
import retrofit2.http.POST;
/**
* Description：
*/
public interface APIService {
/**
* 登陆
*
* @param username 账号
* @param password 密码
* @return
*/
@FormUrlEncoded
@POST("user/login")
Observable<BaseObjectBean<LoginBean>> login(@Field("username") String username,
@Field("password") String password);
}

base类

BaseAbility

package com.example.hmsrxjava_demo.base;
import ohos.aafwk.ability.Ability;
import ohos.aafwk.content.Intent;
public abstract class BaseAbility extends Ability {
@Override
protected void onStart(Intent intent) {
super.onStart(intent);
super.setUIContent(getLayoutId());
initView();
}
@Override
protected void onStop() {
super.onStop();
}
/**
* 设置布局
*
* @return
*/
public abstract int getLayoutId();
/**
* 初始化视图
*/
public abstract void initView();
}

BaseMvpAbility

package com.example.hmsrxjava_demo.base;
import ohos.aafwk.content.Intent;
public abstract class BaseMvpAbility <T extends BasePresenter>extends BaseAbility implements BaseView {
protected T mPresenter;
@Override
protected void onStart(Intent intent) {
super.onStart(intent);
}
@Override
protected void onStop() {
if (mPresenter != null) {
mPresenter.detachView();
}
super.onStop();
}
}

BasePresenter

package com.example.hmsrxjava_demo.base;
/**
* Description：
*/
public class BasePresenter<V extends BaseView> {
protected V mView;
/**
* 绑定view，一般在初始化中调用该方法
*
* @param view view
*/
public void attachView(V view) {
this.mView = view;
}
/**
* 解除绑定view，一般在onDestroy中调用
*/
public void detachView() {
this.mView = null;
}
/**
* View是否绑定
*
* @return
*/
public boolean isViewAttached() {
return mView != null;
}
}

BaseView 。

package com.example.hmsrxjava_demo.base;
/**
* Description：
*/
public interface BaseView {
/**
* 显示加载中
*/
void showLoading();
/**
* 隐藏加载
*/
void hideLoading();
/**
* 数据获取失败
* @param errMessage
*/
void onError(String errMessage);
}

Model 层

package com.example.hmsrxjava_demo.contract;
import com.example.hmsrxjava_demo.base.BaseView;
import com.example.hmsrxjava_demo.bean.BaseObjectBean;
import com.example.hmsrxjava_demo.bean.LoginBean;
import io.reactivex.rxjava3.core.Observable;
/**
* Description：
*/
public interface MainContract {
interface Model {
Observable<BaseObjectBean<LoginBean>> login(String username, String password);
}
interface View extends BaseView {
@Override
void showLoading();
@Override
void hideLoading();
@Override
void onError(String errMessage);
void onSuccess(BaseObjectBean<LoginBean> bean);
}
interface Presenter {
/**
* 登陆
*
* @param username
* @param password
*/
void login(String username, String password);
}
}

##model 实现层

package com.example.hmsrxjava_demo.model;
import com.example.hmsrxjava_demo.bean.BaseObjectBean;
import com.example.hmsrxjava_demo.bean.LoginBean;
import com.example.hmsrxjava_demo.contract.MainContract;
import com.example.hmsrxjava_demo.net.RetrofitClient;
import io.reactivex.rxjava3.core.Observable;
/**
* Description：
*/
public class MainModel implements MainContract.Model {
private static final String TAG = "MainModel";
@Override
public Observable<BaseObjectBean<LoginBean>> login(String username, String password) {
System.out.println("MainModel login 被调用");
return RetrofitClient.getInstance().getApi().login(username,password);
}
}

Presenter层。

package com.example.hmsrxjava_demo.presenter;
import com.example.hmsrxjava_demo.base.BasePresenter;
import com.example.hmsrxjava_demo.bean.BaseObjectBean;
import com.example.hmsrxjava_demo.bean.LoginBean;
import com.example.hmsrxjava_demo.contract.MainContract;
import com.example.hmsrxjava_demo.model.MainModel;
import com.example.hmsrxjava_demo.net.RxScheduler;
import io.reactivex.rxjava3.annotations.NonNull;
import io.reactivex.rxjava3.core.Observer;
import io.reactivex.rxjava3.disposables.Disposable;
/**
* Description：
*/
public class MainPresenter extends BasePresenter<MainContract.View> implements MainContract.Presenter {
private MainContract.Model model;
public MainPresenter() {
model = new MainModel();
}
@Override
public void login(String username, String password) {
//View是否绑定如果没有绑定，就不执行网络请求
if (!isViewAttached()) {
return;
}
model.login(username, password)
.compose(RxScheduler.Obs_io_main())
.subscribe(new Observer<BaseObjectBean<LoginBean>>() {
@Override
public void onSubscribe(@NonNull Disposable d) {
mView.showLoading();
}
@Override
public void onNext(@NonNull BaseObjectBean<LoginBean> loginBeanBaseObjectBean) {
mView.onSuccess(loginBeanBaseObjectBean);
System.out.println("onNext ----- >");
}
@Override
public void onError(@NonNull Throwable e) {
mView.onError(e.getMessage());
mView.hideLoading();
}
@Override
public void onComplete() {
mView.hideLoading();
}
});
}
}

MainAbility 中具体调用。

package com.example.hmsrxjava_demo;
import com.example.hmsrxjava_demo.base.BaseMvpAbility;
import com.example.hmsrxjava_demo.bean.BaseObjectBean;
import com.example.hmsrxjava_demo.bean.LoginBean;
import com.example.hmsrxjava_demo.contract.MainContract;
import com.example.hmsrxjava_demo.presenter.MainPresenter;
import ohos.agp.components.Button;
import ohos.agp.components.Component;
import ohos.agp.components.TextField;
import ohos.agp.window.dialog.ToastDialog;
public class MainAbility extends BaseMvpAbility<MainPresenter>implements MainContract.View {
private TextField textUsername, textpasswrod;
private String username, password;
private Button loginBtn;
private MainPresenter presenter;
@Override
public int getLayoutId() {
return ResourceTable.Layout_ability_main;
}
@Override
public void initView() {
textUsername= (TextField) findComponentById(ResourceTable.Id_text_username);
textpasswrod= (TextField) findComponentById(ResourceTable.Id_text_password);
presenter=new MainPresenter();
presenter.attachView(this);
loginBtn= (Button) findComponentById(ResourceTable.Id_login_btn);
if(loginBtn!=null){
loginBtn.setClickedListener(new Component.ClickedListener() {
@Override
public void onClick(Component component) {
System.out.println("点击登录按钮");
username=textUsername.getText();
password=textpasswrod.getText();
if(username!=null&&password!=null){
presenter.login(username,password);
// login(username,password);
}else {
new ToastDialog(MainAbility.this).setText("账号密码不输不能为空").show(); }
}
});
}
}
@Override
public void onSuccess(BaseObjectBean<LoginBean> bean) {
System.out.println(bean.getErrorCode()+bean.getErrorMsg());
new ToastDialog(MainAbility.this).setText(bean.getErrorCode()+bean.getErrorMsg()).show();
}
@Override
public void showLoading() {
}
@Override
public void hideLoading() {
}
@Override
public void onError(String errMessage) {
}
}

到此鸿蒙 MVP+ Rxjava+Retrofit+okhttp 实现教程使用起来和安卓的用法非常像我这里很多代码是复制过来同学们可以下载完整的代码来尝试.

最后总结：

鸿蒙中MVP+ Rxjava+Retrofit+okhttp 和安卓里面基本如出一辙只是很少地方有些诧异，同学们如果不是很熟悉 Rxjava+Retrofit+okhttp 请先去看看官方教程还有mvp模式的不熟悉的请切翻阅我之前的文章 .

原文链接：https://harmonyos.51cto.com 。

最后此篇关于鸿蒙 MVP+ Rxjava+Retrofit+okhttp 实现教程的文章就讲到这里了,如果你想了解更多关于鸿蒙 MVP+ Rxjava+Retrofit+okhttp 实现教程的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！。

26

4

0

文章推荐： Python基础教程之循环语句（for、while和嵌套循环）

文章推荐： java实现门禁系统

文章推荐： python中文本字符处理的简单方法记录

文章推荐：如何用python 实现老板键功能

okhttp - 流式传输 okhttp 响应正文
我正在实现 Server-Sent Events使用 OkHttp 的库。服务器发送事件的工作原理是与服务器保持开放的 HTTP 连接，在该服务器上，“事件”可以流式传输回客户端。连接只会在错误或客户
okhttp - 如何重现 OkHttp 的错误
我需要用 OkHttp 重现错误，这样我就可以提交错误或在 StackOverflow 上提问。无需大量设置即可执行此操作的最简单方法是什么？我读过 https://stackoverflow.c
okhttp - 如何重现 OkHttp 的错误
我需要用 OkHttp 重现错误，这样我就可以提交错误或在 StackOverflow 上提问。无需大量设置即可执行此操作的最简单方法是什么？我读过 https://stackoverflow.c
okhttp - HTTP/2 与 OkHttp
我正在尝试使用 OkHttp 与 HTTP/2 服务器进行通信客户端。添加到 Maven POM: com.squareup.okhttp3 okhttp 3.2.0 这是我的
android - OkHttp 连接泄漏日志行，即使 OkHttp 不是依赖项
我在使用我的应用程序时不断在 Logcat 中看到以下日志行: 19098-19147/ W/OkHttpClient: A connection to was leaked. Did you fo
okhttp - Okio Throttler 与 OkHttp 的集成
我的团队正受此困扰issue使用 slack 集成来上传文件，因此根据该问题中的评论，我想限制我们的 Kotlin 实现中的请求。我正在尝试集成 Okio Throttler在 OkHttp 拦截器
okhttp - 如何验证 okhttp 是否使用 http/2 进行请求？
如何验证 okhttp 是否成功协商了 http/2 而没有使用 https/1.1？我可以检查回复中的一些信息吗？谢谢， -托尼最佳答案仅供引用，因为 okhttp 3.0 左右 OkHttp
okhttp - 如何强制 okhttp 使用 http/2 进行请求？
我想提出一个请求并强制它使用 Protocol.HTTP_2。我尝试了下面的代码: import okhttp3.{OkHttpClient, Protocol, Request} import s
android - OkHttp 异步调用 : AsyncTask or OkHttp async api?
我不太熟悉 OkHttp 库，我对它应该如何用于异步请求有一些疑问。对于 Android 编程，我将 android 库用于 http，并将 asyncTask 用于某些请求。但是因为我想尝试 O
android - Retrofit 在 OKHttp 2.0 的类路径错误上检测到不受支持的 OkHttp
我在我的项目中使用 Retrofit-1.6.0 + okhttp-2.0.0-RC1 。当我运行项目时出现错误。 java.lang.RuntimeException: Retrofit detec
okhttp - 在 OkHTTP 中，如何将 keep-alive 设置为 false？
OkHttpClient 的默认行为是将 keep-alive 设置为 true。对于我们的特定用例，我需要将其设置为 false。我没有在 Java 源代码中找到任何设置来执行此操作。有人遇到过
compiler-errors - OkHttp 请求在 com.squareup.okhttp 中不公开；无法从外部包访问
我试图让 OkHttp 在我的 Android Studio 项目中工作，我创建了一个类并从这里粘贴以下代码:https://github.com/square/okhttp/blob/master/
okhttp - 我可以通过 NPN 协商使用 OkHttp 发送 http/2 请求吗？
我注意到 OkHttp 在 Android 5.0+ 中通过 ALPN 支持 h2。来自 some article ,我了解到我们可以对 http/2 请求使用 NPN 协商。我可以通过 NPN
android - 如果 Retrofit 已经在内部使用 OkHttp，为什么开发人员将 OkHttp 设置为 Retrofit
我知道，Retrofit 在内部使用 OkHttp。但是，我可以看到一些开发人员提供了以下方法的应用 return new Retrofit.Builder() .baseUrl(Bu
okhttp - 我可以使用 OkHttp 将本地 IP 地址绑定(bind)到我的 SSLSocketFactory 吗？
我正在努力让 Android 上的 OkHttpClient 使用自定义证书发出 HTTPS 请求，同时绑定(bind)到特定网络接口(interface)的本地地址。我目前对此的尝试使用以下 OkH
android - 无法在 android studio 中访问 OKHttp 包，但从 Okhttp 包中抛出异常？
我有一个用于 https 连接演示的 native android 应用程序，我遇到了这样的异常:: 我的连接代码很简单: URL url = new URL("https://192.168.1.5
okhttp - 在 OkHttp 中使用 `call.cancel()` 内的 `EventListener.dnsEnd()` 允许列出 IP 地址
我正在重写 EventListener 中的 dnsEnd() 函数: @Override public void dnsEnd(Call call, String domainName, L
android - 重复的zip条目[okhttp-2.4.0.jar:com/squareup/okhttp/Address.class]
我有okhttp的android多项目设置，作为多个项目的一部分在项目A中，okhttp包含在源代码中。在项目B中，okhttp带有库依赖项的一部分。构建时，出现以下错误。 Execution
java - Gradle 无法下载 okhttp.jar (com.squareup.okhttp3 :okhttp:3. 8.0)
我正在尝试使用pesapal向我的应用程序添加付款但遇到问题，我将它们的依赖实现'com.pesapal.android:pesapalandroid:1.0.5'添加到我的应用程序中，从那时起我就一
android - Gradle - 错误 :Failed to find: com. squareup.okhttp :okhttp:2. 4.0
我只是尝试使用 OkHttp但是当我将我的 gradle 文件与 Android Studio 同步时，我遇到了以下问题: Error:Failed to find: com.squareup.okh

首页

博学

6Ren·AI

商城