当前位置：首页 > news >正文

RxjavaRetrofitDemo源码解析：从单例模式到观察者模式的设计思路

news 2026/7/6 15:31:58

RxjavaRetrofitDemo源码解析：从单例模式到观察者模式的设计思路

【免费下载链接】RxjavaRetrofitDemoA demo show how to use Retrofit with Rxjava项目地址: https://gitcode.com/gh_mirrors/rx/RxjavaRetrofitDemo

RxjavaRetrofitDemo是一个展示如何结合RxJava与Retrofit使用的示例项目，通过巧妙的设计模式将网络请求与响应处理解耦，为Android开发者提供了优雅的异步编程解决方案。本文将深入剖析项目中的单例模式与观察者模式实现，揭示其背后的设计思路与最佳实践。

单例模式：HttpMethods的唯一实例设计

在网络请求场景中，创建过多的Retrofit实例会导致资源浪费和配置不一致问题。RxjavaRetrofitDemo通过静态内部类单例模式完美解决了这一问题，确保全局只有一个HttpMethods实例。

核心实现代码解析

核心实现位于app/src/main/java/com/queen/rxjavaretrofitdemo/http/HttpMethods.java文件中：

// 构造方法私有 private HttpMethods() { // 初始化OkHttpClient和Retrofit OkHttpClient.Builder builder = new OkHttpClient.Builder(); builder.connectTimeout(DEFAULT_TIMEOUT, TimeUnit.SECONDS); retrofit = new Retrofit.Builder() .client(builder.build()) .addConverterFactory(ResponseConvertFactory.create()) .addCallAdapterFactory(RxJavaCallAdapterFactory.create()) .baseUrl(BASE_URL) .build(); movieService = retrofit.create(MovieService.class); } // 静态内部类实现单例 private static class SingletonHolder{ private static final HttpMethods INSTANCE = new HttpMethods(); } // 获取单例实例 public static HttpMethods getInstance(){ return SingletonHolder.INSTANCE; }

单例模式的优势

延迟初始化：静态内部类在第一次被引用时才会加载，实现了懒加载
线程安全：JVM保证静态内部类的初始化是线程安全的
资源高效：避免重复创建Retrofit实例，减少内存占用
全局配置一致：统一的BaseUrl和转换器配置，避免请求不一致问题

观察者模式：RxJava的事件驱动架构

RxjavaRetrofitDemo充分利用RxJava的观察者模式特性，将网络请求的发送、处理和响应解耦，实现了优雅的异步数据流处理。

订阅者与观察者的实现

项目中的ProgressSubscriber.java是观察者模式的典型实现，它继承自RxJava的Subscriber类，实现了对网络请求过程的完整监控：

public class ProgressSubscriber<T> extends Subscriber<T> implements ProgressCancelListener{ private SubscriberOnNextListener mSubscriberOnNextListener; private ProgressDialogHandler mProgressDialogHandler; @Override public void onStart() { showProgressDialog(); // 请求开始时显示进度对话框 } @Override public void onNext(T t) { if (mSubscriberOnNextListener != null) { mSubscriberOnNextListener.onNext(t); // 将结果传递给业务层处理 } } @Override public void onError(Throwable e) { // 统一错误处理 dismissProgressDialog(); } @Override public void onCompleted() { dismissProgressDialog(); // 请求完成时关闭进度对话框 } }

数据流的转换与订阅

在HttpMethods类中，通过Observable的map操作符对数据进行转换，并通过toSubscribe方法完成订阅：

public void getTopMovie(Subscriber<List<Subject>> subscriber, int start, int count){ Observable observable = movieService.getTopMovie(start, count) .map(new HttpResultFunc<List<Subject>>()); // 转换HttpResult为实际数据 toSubscribe(observable, subscriber); // 完成订阅 } private <T> void toSubscribe(Observable<T> o, Subscriber<T> s){ o.subscribeOn(Schedulers.io()) // 订阅在IO线程 .unsubscribeOn(Schedulers.io()) // 取消订阅在IO线程 .observeOn(AndroidSchedulers.mainThread()) // 观察在主线程 .subscribe(s); // 执行订阅 }