RxJava 搭建优雅的七牛云多图上传方案

2023-11-05 09:13:13

引言

在当今互联网时代，图片已成为信息传递和情感表达的重要载体。作为开发者，我们经常需要将用户上传的多张图片存储到云端，而七牛云作为国内领先的云存储服务商，凭借其稳定可靠、价格实惠的优势，成为众多开发者的选择。不过，七牛云官方 SDK 仅提供了单图上传功能，想要实现多图上传，就需要另辟蹊径。本文将借助 RxJava 的强大功能，结合回调接口，为七牛云多图上传打造一个优雅高效的解决方案。

RxJava简介

RxJava 是一种用于异步和事件驱动的编程库，它允许开发者以响应式的方式处理异步任务，大幅简化了异步编程的复杂性。RxJava 的核心概念是 Observable 和 Observer，Observable 负责产生数据，而 Observer 负责接收并处理数据。

实现方案

1. 回调接口设计

为了便于与 UI 线程交互，我们首先定义一个回调接口 MultiImageUploadCallback：

public interface MultiImageUploadCallback {
    void onProgress(int progress);
    void onSuccess(List<String> imageUrls);
    void onFailure(Throwable error);
}

2. 多图上传工具类

接下来，我们使用 RxJava 编写一个工具类 MultiImageUploader，它将七牛云多图上传过程封装为一个可观察对象：

public class MultiImageUploader {

    private QiniuStorage qiniuStorage;
    private Observable<UploadResult> uploadObservable;

    public MultiImageUploader(QiniuStorage qiniuStorage) {
        this.qiniuStorage = qiniuStorage;
    }

    public Observable<UploadResult> uploadImages(List<File> images, final MultiImageUploadCallback callback) {
        uploadObservable = Observable.create(new ObservableOnSubscribe<UploadResult>() {
            @Override
            public void subscribe(ObservableEmitter<UploadResult> emitter) throws Exception {
                qiniuStorage.uploadMulti(images, new UpCompletionHandler() {
                    @Override
                    public void complete(List<UploadResult> results, String key, ResponseInfo info, JSONObject response) {
                        if (info.isOK()) {
                            callback.onSuccess(results);
                            emitter.onComplete();
                        } else {
                            callback.onFailure(new Throwable(info.error));
                            emitter.onError(new Throwable(info.error));
                        }
                    }
                }, null);
            }
        });

        return uploadObservable.subscribeOn(Schedulers.io());
    }
}

3. 使用示例

有了 MultiImageUploader，我们可以轻松地使用 RxJava 来实现多图上传：

MultiImageUploader uploader = new MultiImageUploader(qiniuStorage);
uploader.uploadImages(images, new MultiImageUploadCallback() {
    @Override
    public void onProgress(int progress) {
        // 更新 UI 中的进度条
    }

    @Override
    public void onSuccess(List<String> imageUrls) {
        // 将上传成功的图片 URL 保存到数据库或其他地方
    }

    @Override
    public void onFailure(Throwable error) {
        // 上传失败，提示用户
    }
});