Retrofit 下載網絡圖片 保存到本地

 

private void downImage(String imagePath) {  try {
                CommonV2Api.downloadFile(mContext, imagePath, new ICallBack<ResponseBody>() {
                    @Override
                    public void onSuccess(String flag, String key, ResponseBody responseBody) {
                        InputStream is = null;
                        FileOutputStream fos = null;
                        BufferedInputStream bis = null;
                        try {
                            int index = imagePath.lastIndexOf("/");
                            newFileName = imagePath.substring(index, imagePath.length());
                            saveImagePath = fileUtils.getPath(AppConfig.SD_DIR) +  newFileName;
                            is = responseBody.byteStream();
                            file = new File(saveImagePath);
                            if (file.exists()) {
                                file.delete();
                                file = new File(saveImagePath);
                            }
                            fos = new FileOutputStream(file);
                            bis = new BufferedInputStream(is);
                            byte[] buffer = new byte[1024];
                            int len;
                            while ((len = bis.read(buffer)) != -1) {
                                fos.write(buffer, 0, len);
                            }
                            ToastUtil.show(mContext,saveImagePath);
                        } catch (Exception e) {
                            e.printStackTrace();
                        } finally {
                            if (fos != null) {
                                try {
                                    fos.flush();
                                    fos.close();
                                } catch (IOException e) {
                                    e.printStackTrace();
                                }
                            }
                            if (bis != null) {
                                try {
                                    bis.close();
                                } catch (IOException e) {
                                    e.printStackTrace();
                                }
                            }
                            if (is != null) {
                                try {
                                    is.close();
                                } catch (IOException e) {
                                    e.printStackTrace();
                                }
                            }
                        }
                    }

                    @Override
                    public void onFailure(String flag, String key, String why) {

                    }
                }, false);
            } catch (Exception e) {
                e.printStackTrace();
            } 
    }

 

 

    public static void downloadFile(Context mContext, String filePath, ICallBack<ResponseBody> callBack, Boolean boolShow, String... title) {
        Observable<ResponseBody> mObservable =
                BuildService.getCloud().downloadFile(filePath);
        new RequestCallBack<ResponseBody>().RXResponseBody(mContext, mObservable, callBack
                , boolShow, title);
    }

 

    @GET
    Observable<ResponseBody> downloadFile(@Url String fileUrl);

 

 

public void RXResponseBody(Context mContext, Observable<T> mObservable, final ICallBack<T> callBack, Boolean boolShow, String... title){    if (!NetUtil.isNetworkAvailable(mContext)) {        ToastUtil.show(mContext, "請檢查網絡!");        callBack.onFailure("", "404", "請檢查網絡!");        return;    }    if (boolShow) {        showDialog(mContext, title);    }    mObservable.subscribeOn(Schedulers.io())//請求數據的事件發生在io線程            .observeOn(AndroidSchedulers.mainThread())            .subscribe(new io.reactivex.Observer<T>() {                @Override                public void onSubscribe(Disposable d) {                }                @Override                public void onNext(T result) {                    if (pd != null) {                        pd.dismiss();                    }                    if (result == null) {                        callBack.onFailure("", "", "沒法解析");                    } else {                        callBack.onSuccess("", "", result);                    }                }                @Override                public void onError(Throwable e) {                    if (pd != null) {                        pd.dismiss();                    }                    callBack.onFailure("", "", "沒法解析");                }                @Override                public void onComplete() {                }            });}