Android开发：如何使用Retrofit 2实现每5秒发起网络请求？

嘿，我看了你这段每5秒发起Retrofit请求的代码，发现有可以优化的地方——比如每次调用getUserData()都重新创建Retrofit和APIService实例，这会浪费不少资源。下面给你整理一套更高效、更健壮的实现方案：

1. 先把Retrofit与APIService做成单例 #

Retrofit的初始化是比较消耗资源的操作，我们可以把它做成单例，避免重复创建：

public class RetrofitClient {
    private static Retrofit retrofit;
    private static APIService apiService;

    // 私有构造方法，防止外部实例化
    private RetrofitClient() {}

    public static Retrofit getRetrofitInstance() {
        if (retrofit == null) {
            retrofit = new Retrofit.Builder()
                    .baseUrl(Constants.BASE_URL)
                    .addConverterFactory(GsonConverterFactory.create())
                    .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
                    .build();
        }
        return retrofit;
    }

    public static APIService getApiService() {
        if (apiService == null) {
            apiService = getRetrofitInstance().create(APIService.class);
        }
        return apiService;
    }
}

2. 用RxJava实现定时重复请求 #

既然你已经引入了RxJava2的CallAdapter，直接用interval操作符来实现定时请求是最契合的，同时还能轻松处理生命周期，避免内存泄漏：

// 保存订阅的Disposable，用于生命周期销毁时取消请求
private Disposable requestDisposable;

private void startPeriodicUserDataRequest() {
    // 先取消之前的订阅，防止重复发起请求
    if (requestDisposable != null && !requestDisposable.isDisposed()) {
        requestDisposable.dispose();
    }

    // interval(0, 5, TimeUnit.SECONDS) 表示立即执行第一次请求，之后每5秒执行一次
    // 如果想要首次请求等待5秒，把第一个参数改成5即可
    requestDisposable = Observable.interval(0, 5, TimeUnit.SECONDS)
            .flatMap(ignored -> {
                // 构建请求参数
                Map<String, Object> params = new HashMap<>();
                params.put("device_id", Utils.GetDeviceID(getApplicationContext()));
                
                // 发起网络请求，切换到IO线程执行，主线程回调
                return RetrofitClient.getApiService().getUserData(params)
                        .subscribeOn(Schedulers.io())
                        .observeOn(AndroidSchedulers.mainThread());
            })
            .subscribe(
                    // 请求成功的回调
                    userData -> {
                        // 这里处理返回的用户数据，比如更新UI
                        updateUserInterface(userData);
                    },
                    // 请求失败的回调
                    throwable -> {
                        // 处理请求错误，比如打印日志或提示用户
                        Log.e("UserDataRequest", "请求失败: " + throwable.getMessage());
                    }
            );
}

// 在页面销毁时取消订阅，防止内存泄漏
@Override
protected void onDestroy() {
    super.onDestroy();
    if (requestDisposable != null && !requestDisposable.isDisposed()) {
        requestDisposable.dispose();
    }
}

3. 几个关键注意点 #

• 资源优化：单例模式避免了重复初始化Retrofit，提升了请求性能
• 生命周期管理：必须在onDestroy（或对应组件的销毁方法）中取消RxJava订阅，否则会造成内存泄漏
• 错误处理：不要忽略请求失败的情况，可以根据需求加入重试逻辑（比如用retryWhen操作符实现指数退避重试）
• 请求时机：根据业务需求调整interval的参数，控制首次请求和后续请求的间隔时间

内容的提问来源于stack exchange，提问作者Giorgi Asaturyan