Android OkHttp+Retrofit+Rxjava,2024年最新kotlin语言架构
/未知错误//解析错误//网络错误/连接错误//解析错误return ex;//网络错误return ex;//连接错误return ex;} else {//未知错误return ex;对于很多初中级Android工程师而言,想要提升技能,往往是自己摸索成长。而不成体系的学习效果低效漫长且无助。时间久了,付出巨大的时间成本和努力,没有看到应有的效果,会气馁是再正常不过的。
Call<ResponseData> register(@FieldMap Map<String,String> map);
}
💥 设置OkHttp+Retrofit
public class NetworkManager {
private static volatile NetworkManager instances;
private static volatile OkHttpClient okHttpClient;
private static volatile Retrofit retrofit;
public static NetworkManager getInstance() {
if (instances == null) {
synchronized (NetworkManager.class) {
if (instances == null) {
instances = new NetworkManager();
}
}
}
return instances;
}
private static int TIME_OUT = 30; //30秒超时断开连接
private OkHttpClient initClient() {
if (okHttpClient == null) {
synchronized (NetworkManager.class) {
if (okHttpClient == null) {
//请求日志打印
HttpLoggingInterceptor loggingInterceptor = new HttpLoggingInterceptor(message -> {
try {
MLog.e(URLDecoder.decode(message, “utf-8”));
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
MLog.e(message);
}
});
loggingInterceptor.setLevel(HttpLoggingInterceptor.Level.BODY);
//注释1:创建OkHttpClient
okHttpClient = new OkHttpClient.Builder()
.sslSocketFactory(new NetworkSSL(TrustManager.trustAllCert), TrustManager.trustAllCert)
.connectTimeout(TIME_OUT, TimeUnit.SECONDS)
.addInterceptor(loggingInterceptor)
.readTimeout(TIME_OUT, TimeUnit.SECONDS)
.writeTimeout(TIME_OUT, TimeUnit.SECONDS)
.build();
}
}
}
return okHttpClient;
}
public Retrofit initRetrofit() {
if (retrofit == null) {
synchronized (NetworkManager.class) {
if (retrofit == null) {
//注释2:创建Retrofit
retrofit = new Retrofit.Builder()
.client(initClient())//选填
.baseUrl(IWanAndroidService.BASE_URL)//必填
.addConverterFactory(GsonConverterFactory.create())//选填(数据转换器,解析)
.build();
}
}
}
return retrofit;
}
}
-
注释1:创建OkHttpClient对象,构建一个网络类型的实例,一般会将所有的网络请求使用同一个单例对象。(如果OkHttpClient使用默认,可不设置)
-
注释2:创建Retrofit对象,构建一个网络请求的载体对象,在build的时候有非常多的初始化内容,如设置OkHttpClient、设置请求的url,添加数据转换器等。
💥 网络请求
//GET
//注释1:动态获取IWanAndroidService对象
IWanAndroidService service = NetworkManager.getInstance().initRetrofit().create(IWanAndroidService.class);
//注释2:网络请求
service.homeBanner().enqueue(new Callback<ResponseData<List>>() {
@Override
public void onResponse(Call<ResponseData<List>> call, Response<ResponseData<List>> response) {
if (response.body().getData() != null) {
MLog.e(response.body().getData().get(0).toString());
binding.loginTvContent.setText(response.body().getData().get(0).toString());
}
}
@Override
public void onFailure(Call<ResponseData<List>> call, Throwable t) {
MLog.e(t.getMessage());
}
});
//POST
Map<String, String> map = new HashMap<>();
map.put(“username”, account);
map.put(“password”, passsword);
map.put(“repassword”, passsword);
NetworkManager.getInstance().initRetrofit().create(IWanAndroidService.class)
.register(map).enqueue(new Callback<ResponseData>() {
@Override
public void onResponse(Call<ResponseData> call, Response<ResponseData> response) {
if (response.body().getData() != null) {
MLog.e(response.body().getData().toString());
binding.loginTvContent.setText(response.body().getData().toString());
}
}
@Override
public void onFailure(Call<ResponseData> call, Throwable t) {
MLog.e(t.getMessage());
}
});
Retrofit的精髓:为统一配置网络请求完成动态代理的设置。
💥 效果图
🔥 Rxjava
=========
RxJava使用了观察者模式和建造者模式中的链式调用。
观察者模式:
Observable(被观察者)被Observer(观察者)订阅(Subscribe)之后,Observable在发出消息的时候会通知对应的Observer,并且,一个Observable可以有被多个Observer订阅。
链式调用:调用对应的方法对原对象进行处理后返回原对象,从而做到链式调用。
参与者:
-
Observable:被观察者,也就是消息的发送者
-
Observer:观察者,消息的接收者
-
Subscriber:订阅者,观察者的另一种表示
-
Scheduler:调度器,进行线程切换
RxJava当然是优秀而且强大的,有以下优势:
-
具备响应式编程该有的特性。
-
为异步而生,无需手动创建线程,并具备线程切换能力。
-
支持链式调用,保证代码的简洁性。
-
各种操作符,功能非常强大,满足各种业务需求。
-
简化了异常的处理。
RxJava适用场景:网络请求、数据库读写、文件读写、定时任务等各种耗时操作需要通过异步来完成的操作都可以使用RxJava。
💥 添加依赖(新增)
implementation “io.reactivex.rxjava2:rxjava:2.2.6” // 必要rxjava依赖
implementation “io.reactivex.rxjava2:rxandroid:2.1.0” // 必要rxandrroid依赖,切线程时需要用到
…
implementation ‘com.squareup.retrofit2:adapter-rxjava2:2.5.0’ // 必要依赖,和rxjava结合必须用到
💥 修改请求接口
public interface IWanAndroidService {
String BASE_URL = “https://www.wanandroid.com/”;
//OkHttp+Retrofit
//OkHttp+Retrofit+RxJava
@GET(“banner/json”)
Observable<ResponseData<List>> homeBanner();
@POST(“user/register”)
@FormUrlEncoded
Observable<ResponseData> register(@FieldMap Map<String,String> map);
}
💥 设置OkHttp+Retrofit+RxJava
public Retrofit initRetrofitRxJava() {
if (retrofit == null) {
synchronized (NetworkManager.class) {
if (retrofit == null) {
retrofit = new Retrofit.Builder()
.client(initClient())//选填
.baseUrl(IWanAndroidService.BASE_URL)//必填
.addCallAdapterFactory(RxJava2CallAdapterFactory.create())//新增网络请求适配器
.addConverterFactory(GsonConverterFactory.create())//选填(数据转换器,解析)
.build();
}
}
}
return retrofit;
}
💥 进行网络请求
NetworkManager.getInstance().initRetrofitRxJava()
.create(IWanAndroidService.class)
.homeBanner()
.subscribeOn(Schedulers.io())//切换到IO线程
.observeOn(AndroidSchedulers.mainThread())//切换到主线程
// 添加订阅
.subscribe(listResponseData -> {
//请求成功
if (listResponseData != null) {
MLog.e(listResponseData.getData().get(0).toString());
binding.loginTvContent.setText(listResponseData.getData().get(0).toString());
}
}, throwable -> {
//请求失败
MLog.e(throwable.getMessage());
});
💥 效果图
💥 进一步封装
由于请求过于繁琐,咱们试着复进一步封装。
🌀 统一异常处理(自定义ApiException)
public class ApiException extends Exception {
//未知错误
public static final int UNKNOWN = 1000;
//解析错误
public static final int PARSE_ERROR = 1001;
//网络错误/连接错误
public static final int NETWORK_ERROR = 1002;
private int code;
private String displayMessage;
public ApiException(int code, String displayMessage) {
this.code = code;
this.displayMessage = displayMessage;
}
public int getCode() {
return code;
}
public void setCode(int code) {
this.code = code;
}
public String getDisplayMessage() {
return displayMessage;
}
public void setDisplayMessage(String displayMessage) {
this.displayMessage = displayMessage;
}
public static ApiException handleException(Throwable e) {
ApiException ex;
if (e instanceof JsonParseException
|| e instanceof JSONException
|| e instanceof ParseException) {
//解析错误
ex = new ApiException(PARSE_ERROR, e.getMessage());
return ex;
} else if (e instanceof ConnectException) {
//网络错误
ex = new ApiException(NETWORK_ERROR, e.getMessage());
return ex;
} else if (e instanceof UnknownHostException || e instanceof SocketTimeoutException) {
//连接错误
ex = new ApiException(NETWORK_ERROR, e.getMessage());
return ex;
} else {
//未知错误
ex = new ApiException(UNKNOWN, e.getMessage());
return ex;
}
}
}
🌀 统一异常处理(实现Consumer<Throwable>
接口)
public abstract class ErrorConsumer implements Consumer {
@Override
public void accept(@NotNull Throwable throwable) throws Exception {
//对异常进行处理
ApiException exception;
if (throwable instanceof ApiException) {
exception = (ApiException) throwable;
} else {
exception = ApiException.handleException(throwable);
}
//调用error方法
error(exception);
}
//使用时实现error方法即可。
protected abstract void error(ApiException e);
}
🌀 响应转换处理
public class ResponseTransformer implements ObservableTransformer<ResponseData, T> {
public ResponseTransformer() {
}
public static ResponseTransformer obtain(){
return new ResponseTransformer<>();
}
@NotNull
自我介绍一下,小编13年上海交大毕业,曾经在小公司待过,也去过华为、OPPO等大厂,18年进入阿里一直到现在。
深知大多数Android工程师,想要提升技能,往往是自己摸索成长或者是报班学习,但对于培训机构动则几千的学费,着实压力不小。自己不成体系的自学效果低效又漫长,而且极易碰到天花板技术停滞不前!
因此收集整理了一份《2024年Android移动开发全套学习资料》,初衷也很简单,就是希望能够帮助到想自学提升又不知道该从何学起的朋友,同时减轻大家的负担。
既有适合小白学习的零基础资料,也有适合3年以上经验的小伙伴深入学习提升的进阶课程,基本涵盖了95%以上Android开发知识点,真正体系化!
由于文件比较大,这里只是将部分目录大纲截图出来,每个节点里面都包含大厂面经、学习笔记、源码讲义、实战项目、讲解视频,并且后续会持续更新
如果你觉得这些内容对你有帮助,可以添加V获取:vip204888 (备注Android)
最后
对于很多初中级Android工程师而言,想要提升技能,往往是自己摸索成长。而不成体系的学习效果低效漫长且无助。时间久了,付出巨大的时间成本和努力,没有看到应有的效果,会气馁是再正常不过的。
所以学习一定要找到最适合自己的方式,有一个思路方法,不然不止浪费时间,更可能把未来发展都一起耽误了。
如果你是卡在缺少学习资源的瓶颈上,那么刚刚好我能帮到你。
一个人可以走的很快,但一群人才能走的更远。不论你是正从事IT行业的老鸟或是对IT行业感兴趣的新人,都欢迎扫码加入我们的的圈子(技术交流、学习资源、职场吐槽、大厂内推、面试辅导),让我们一起学习成长!
StPECDe-1712684773564)]
[外链图片转存中…(img-ETGmPsRH-1712684773564)]
既有适合小白学习的零基础资料,也有适合3年以上经验的小伙伴深入学习提升的进阶课程,基本涵盖了95%以上Android开发知识点,真正体系化!
由于文件比较大,这里只是将部分目录大纲截图出来,每个节点里面都包含大厂面经、学习笔记、源码讲义、实战项目、讲解视频,并且后续会持续更新
如果你觉得这些内容对你有帮助,可以添加V获取:vip204888 (备注Android)
[外链图片转存中…(img-J3OwGl8r-1712684773565)]
最后
对于很多初中级Android工程师而言,想要提升技能,往往是自己摸索成长。而不成体系的学习效果低效漫长且无助。时间久了,付出巨大的时间成本和努力,没有看到应有的效果,会气馁是再正常不过的。
所以学习一定要找到最适合自己的方式,有一个思路方法,不然不止浪费时间,更可能把未来发展都一起耽误了。
如果你是卡在缺少学习资源的瓶颈上,那么刚刚好我能帮到你。
一个人可以走的很快,但一群人才能走的更远。不论你是正从事IT行业的老鸟或是对IT行业感兴趣的新人,都欢迎扫码加入我们的的圈子(技术交流、学习资源、职场吐槽、大厂内推、面试辅导),让我们一起学习成长!
[外链图片转存中…(img-X4p1VFhU-1712684773565)]
更多推荐
所有评论(0)