Android okHttp網路請求之檔案上傳下載

阿新 • • 發佈：2019-01-15

前言：

前面介紹了基於okHttp的get、post基本使用（http://www.cnblogs.com/whoislcj/p/5526431.html），今天來實現一下基於okHttp的檔案上傳、下載。

okHttp相關文章地址：

檔案上傳：

1.）不帶引數上傳檔案

    /**
     * 上傳檔案
     * @param actionUrl 介面地址
     * @param filePath  本地檔案地址
     */
    public <T> void upLoadFile(String actionUrl, String filePath, final 
 ReqCallBack<T> callBack) {
        //補全請求地址
        String requestUrl = String.format("%s/%s", BASE_URL, actionUrl);
        //建立File
        File file = new File(filePath);
        //建立RequestBody
        RequestBody body = RequestBody.create(MEDIA_OBJECT_STREAM, file);
        //建立Request
        final 
 Request request = new Request.Builder().url(requestUrl).post(body).build();
        final Call call = mOkHttpClient.newBuilder().writeTimeout(50, TimeUnit.SECONDS).build().newCall(request);
        call.enqueue(new Callback() {
            @Override
            public void onFailure(Call call, IOException e) {
                Log.e(TAG, e.toString());
                failedCallBack( 
"上傳失敗", callBack);
            }

            @Override
            public void onResponse(Call call, Response response) throws IOException {
                if (response.isSuccessful()) {
                    String string = response.body().string();
                    Log.e(TAG, "response ----->" + string);
                    successCallBack((T) string, callBack);
                } else {
                    failedCallBack("上傳失敗", callBack);
                }
            }
        });
    }

2.）帶引數上傳檔案

/**
     *上傳檔案
     * @param actionUrl 介面地址
     * @param paramsMap 引數
     * @param callBack 回撥
     * @param <T>
     */
    public <T>void upLoadFile(String actionUrl, HashMap<String, Object> paramsMap, final ReqCallBack<T> callBack) {
        try {
            //補全請求地址
            String requestUrl = String.format("%s/%s", upload_head, actionUrl);
            MultipartBody.Builder builder = new MultipartBody.Builder();
            //設定型別
            builder.setType(MultipartBody.FORM);
            //追加引數
            for (String key : paramsMap.keySet()) {
                Object object = paramsMap.get(key);
                if (!(object instanceof File)) {
                    builder.addFormDataPart(key, object.toString());
                } else {
                    File file = (File) object;
                    builder.addFormDataPart(key, file.getName(), RequestBody.create(null, file));
                }
            }
            //建立RequestBody
            RequestBody body = builder.build();
            //建立Request
            final Request request = new Request.Builder().url(requestUrl).post(body).build();
            //單獨設定引數 比如讀取超時時間
            final Call call = mOkHttpClient.newBuilder().writeTimeout(50, TimeUnit.SECONDS).build().newCall(request);
            call.enqueue(new Callback() {
                @Override
                public void onFailure(Call call, IOException e) {
                    Log.e(TAG, e.toString());
                    failedCallBack("上傳失敗", callBack);
                }

                @Override
                public void onResponse(Call call, Response response) throws IOException {
                    if (response.isSuccessful()) {
                        String string = response.body().string();
                        Log.e(TAG, "response ----->" + string);
                        successCallBack((T) string, callBack);
                    } else {
                        failedCallBack("上傳失敗", callBack);
                    }
                }
            });
        } catch (Exception e) {
            Log.e(TAG, e.toString());
        }
    }

3.)帶引數帶進度上傳檔案

 /**
     *上傳檔案
     * @param actionUrl 介面地址
     * @param paramsMap 引數
     * @param callBack 回撥
     * @param <T>
     */
    public <T> void upLoadFile(String actionUrl, HashMap<String, Object> paramsMap, final ReqProgressCallBack<T> callBack) {
        try {
            //補全請求地址
            String requestUrl = String.format("%s/%s", upload_head, actionUrl);
            MultipartBody.Builder builder = new MultipartBody.Builder();
            //設定型別
            builder.setType(MultipartBody.FORM);
            //追加引數
            for (String key : paramsMap.keySet()) {
                Object object = paramsMap.get(key);
                if (!(object instanceof File)) {
                    builder.addFormDataPart(key, object.toString());
                } else {
                    File file = (File) object;
                    builder.addFormDataPart(key, file.getName(), createProgressRequestBody(MEDIA_OBJECT_STREAM, file, callBack));
                }
            }
            //建立RequestBody
            RequestBody body = builder.build();
            //建立Request
            final Request request = new Request.Builder().url(requestUrl).post(body).build();
            final Call call = mOkHttpClient.newBuilder().writeTimeout(50, TimeUnit.SECONDS).build().newCall(request);
            call.enqueue(new Callback() {
                @Override
                public void onFailure(Call call, IOException e) {
                    Log.e(TAG, e.toString());
                    failedCallBack("上傳失敗", callBack);
                }

                @Override
                public void onResponse(Call call, Response response) throws IOException {
                    if (response.isSuccessful()) {
                        String string = response.body().string();
                        Log.e(TAG, "response ----->" + string);
                        successCallBack((T) string, callBack);
                    } else {
                        failedCallBack("上傳失敗", callBack);
                    }
                }
            });
        } catch (Exception e) {
            Log.e(TAG, e.toString());
        }
    }

4.）建立帶進度RequestBody

 /**
     * 建立帶進度的RequestBody
     * @param contentType MediaType
     * @param file  準備上傳的檔案
     * @param callBack 回撥
     * @param <T>
     * @return
     */
    public <T> RequestBody createProgressRequestBody(final MediaType contentType, final File file, final ReqProgressCallBack<T> callBack) {
        return new RequestBody() {
            @Override
            public MediaType contentType() {
                return contentType;
            }

            @Override
            public long contentLength() {
                return file.length();
            }

            @Override
            public void writeTo(BufferedSink sink) throws IOException {
                Source source;
                try {
                    source = Okio.source(file);
                    Buffer buf = new Buffer();
                    long remaining = contentLength();
                    long current = 0;
                    for (long readCount; (readCount = source.read(buf, 2048)) != -1; ) {
                        sink.write(buf, readCount);
                        current += readCount;
                        Log.e(TAG, "current------>" + current);
                        progressCallBack(remaining, current, callBack);
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        };
    }

5.)不帶進度檔案下載

  /**
     * 下載檔案
     * @param fileUrl 檔案url
     * @param destFileDir 儲存目標目錄
     */
    public <T> void downLoadFile(String fileUrl, final String destFileDir, final ReqCallBack<T> callBack) {
        final String fileName = MD5.encode(fileUrl);
        final File file = new File(destFileDir, fileName);
        if (file.exists()) {
            successCallBack((T) file, callBack);
            return;
        }
        final Request request = new Request.Builder().url(fileUrl).build();
        final Call call = mOkHttpClient.newCall(request);
        call.enqueue(new Callback() {
            @Override
            public void onFailure(Call call, IOException e) {
                Log.e(TAG, e.toString());
                failedCallBack("下載失敗", callBack);
            }

            @Override
            public void onResponse(Call call, Response response) throws IOException {
                InputStream is = null;
                byte[] buf = new byte[2048];
                int len = 0;
                FileOutputStream fos = null;
                try {
                    long total = response.body().contentLength();
                    Log.e(TAG, "total------>" + total);
                    long current = 0;
                    is = response.body().byteStream();
                    fos = new FileOutputStream(file);
                    while ((len = is.read(buf)) != -1) {
                        current += len;
                        fos.write(buf, 0, len);
                        Log.e(TAG, "current------>" + current);
                    }
                    fos.flush();
                    successCallBack((T) file, callBack);
                } catch (IOException e) {
                    Log.e(TAG, e.toString());
                    failedCallBack("下載失敗", callBack);
                } finally {
                    try {
                        if (is != null) {
                            is.close();
                        }
                        if (fos != null) {
                            fos.close();
                        }
                    } catch (IOException e) {
                        Log.e(TAG, e.toString());
                    }
                }
            }
        });
    }

6.）帶進度檔案下載

 /**
     * 下載檔案
     * @param fileUrl 檔案url
     * @param destFileDir 儲存目標目錄
     */
    public <T> void downLoadFile(String fileUrl, final String destFileDir, final ReqProgressCallBack<T> callBack) {
        final String fileName = MD5.encode(fileUrl);
        final File file = new File(destFileDir, fileName);
        if (file.exists()) {
            successCallBack((T) file, callBack);
            return;
        }
        final Request request = new Request.Builder().url(fileUrl).build();
        final Call call = mOkHttpClient.newCall(request);
        call.enqueue(new Callback() {
            @Override
            public void onFailure(Call call, IOException e) {
                Log.e(TAG, e.toString());
                failedCallBack("下載失敗", callBack);
            }

            @Override
            public void onResponse(Call call, Response response) throws IOException {
                InputStream is = null;
                byte[] buf = new byte[2048];
                int len = 0;
                FileOutputStream fos = null;
                try {
                    long total = response.body().contentLength();
                    Log.e(TAG, "total------>" + total);
                    long current = 0;
                    is = response.body().byteStream();
                    fos = new FileOutputStream(file);
                    while ((len = is.read(buf)) != -1) {
                        current += len;
                        fos.write(buf, 0, len);
                        Log.e(TAG, "current------>" + current);
                        progressCallBack(total, current, callBack);
                    }
                    fos.flush();
                    successCallBack((T) file, callBack);
                } catch (IOException e) {
                    Log.e(TAG, e.toString());
                    failedCallBack("下載失敗", callBack);
                } finally {
                    try {
                        if (is != null) {
                            is.close();
                        }
                        if (fos != null) {
                            fos.close();
                        }
                    } catch (IOException e) {
                        Log.e(TAG, e.toString());
                    }
                }
            }
        });
    }

7.）介面ReqProgressCallBack.java實現

public interface ReqProgressCallBack<T>  extends ReqCallBack<T>{
    /**
     * 響應進度更新
     */
    void onProgress(long total, long current);
}

8.）進度回撥實現

    /**
     * 統一處理進度資訊
     * @param total    總計大小
     * @param current  當前進度
     * @param callBack
     * @param <T>
     */
    private <T> void progressCallBack(final long total, final long current, final ReqProgressCallBack<T> callBack) {
        okHttpHandler.post(new Runnable() {
            @Override
            public void run() {
                if (callBack != null) {
                    callBack.onProgress(total, current);
                }
            }
        });
    }

小結：基於okHttp的檔案上傳、下載基本實現，接下來就是返回資料的解析了。

Android okHttp網路請求之檔案上傳下載

前言：前面介紹了基於okHttp的get、post基本使用（http://www.cnblogs.com/whoislcj/p/5526431.html），今天來實現一下基於okHttp的檔案上傳、下載。 okHttp相關文章地址：檔案上傳： 1.）不帶引數上傳檔案

Android okHttp網路請求之快取控制Cache-Control

前言：　前面的學習基本上已經可以完成開發需求了，但是在專案中有時會遇到對請求做個快取，當沒網路的時候優先載入本地快取，基於這個需求我們來學習一直okHttp的Cache-Control。 okHttp相關文章地址： Cache-Control： Cache-Contro

Android okHttp網路請求之Retrofit+Okhttp+RxJava組合

前言：通過上面的學習，我們不難發現單純使用okHttp來作為網路庫還是多多少少有那麼一點點不太方便，而且還需自己來管理介面，對於介面的使用的是哪種請求方式也不能一目瞭然，出於這個目的接下來學習一下Retrofit+Okhttp的搭配使用。 okHttp相關文章地址： Retrof

Android okHttp網路請求之Get/Post請求

前言：之前專案中一直使用的Xutils開源框架，從xutils 2.1.5版本使用到最近的xutils 3.0，使用起來也是蠻方便的，只不過最近想著完善一下app中使用的開源框架，由於Xutils裡面包含的東西相對來說比較雜，有資料庫、圖片快取、註解、網路請求等等，秉著一個開源庫只處理一

Android okHttp網路請求之Json解析

前言：前面兩篇文章介紹了基於okHttp的post、get請求，以及檔案的上傳下載，今天主要介紹一下如何和Json解析一起使用？如何才能提高開發效率？ okHttp相關文章地址：關於Json解析：本文的Json解析採用阿里巴巴的FastJson 解析，也可以採用Gso

react-native之檔案上傳下載

目錄檔案上傳 1.檔案選擇 2.檔案上傳 1.FormData物件包裝 2.上傳示例檔案下載最近react-native專案上需要做檔案上傳下載的功能，由於才接觸react-native不久，好多東西不熟悉，前

python3 + selenium 之檔案上傳下載

檔案上傳檔案上傳下載的聯絡html： uplad.html <html> <head> <meta http-equiv="content-type" content="text/html;charset=utf-8" /&

SpringMVC筆記八之檔案上傳下載

一、檔案上傳 1、普通檔案上傳新建頁面WebContent/file.jsp <%@ page language="java" contentType="text/html; charset=utf-8" pageEncoding="utf-8"%>

【SpringMVC】SpringMVC之檔案上傳/下載

學習一個框架少不了學習檔案上傳和下載,原理來說上傳和下載都是基本二進位制流的轉換,所以搞清楚了這一點就很容易理解上傳和下載了在使用springMVC進行系統實現時，springMVC預設的解析器裡面是沒有加入對檔案上傳的解析的，這可以方便我們實現自己的檔案上傳。但如果

SpringMVC之檔案上傳/下載

學習一個框架少不了學習檔案上傳和下載,原理來說上傳和下載都是基本二進位制流的轉換,所以搞清楚了這一點就很容易理解上傳和下載了在使用springMVC進行系統實現時，springMVC預設的解析器裡面是沒有加入對檔案上傳的解析的，這可以方便我們實現自己的檔案上傳。但如果你想使用springMVC對檔案上

基於OkHttp網路通訊工具類(傳送get、post請求、檔案上傳和下載)

一、為什麼要用OkHttp? okhttp是專注於提升網路連線效率的http客戶端。優點： 1、它能實現同一ip和埠的請求重用一個socket，這種方式能大大降低網路連線的時間，和每次請求都建立socket，再斷開socket的方式相比，降低了伺服器伺服器的壓力。 2、okhttp 對

【Android架構】基於MVP模式的Retrofit2+RXjava封裝之檔案上傳（三）

最近手頭事比較多，抽個空把之前系列也補充一下。先回顧下之前的【Android架構】基於MVP模式的Retrofit2+RXjava封裝（一）【Android架構】基於MVP模式的Retrofit2+RXjava封裝之檔案下載（二）今天要說的是檔案上傳 1.單圖上

SpringCloud 之 Fegin —— 傳送GET、POST請求以及檔案上傳

深信自己通過學習理解寫出來的才是自己的 --

Android網路框架Retrofit2使用封裝：Get/Post/檔案上傳/下載

背景 Android開發中的網路框架經過多年的發展，目前比較主流的就是Retrofit了，Retrofit2版本出現也有幾年了，為了方便使用，特封裝了一些關於Retrofit2的程式碼，分享給大家。框架主要包括： Get請求 Post請求檔案上傳檔案下載

【php網路基礎知識】詳解get、post請求、檔案上傳

由客戶端向伺服器端傳資料的兩種方式：get、post 伺服器端接收資料，php有三種方式：$_GET、$_POST、$_REQUEST 第一種：get請求，資料儲存在$_GET陣列中注意：$_G

Android 網路開發（一） okHttp網路請求之快取控制Cache-Control

Cache-Control： Cache-Control指定請求和響應遵循的快取機制。在請求訊息或響應訊息中設定Cache-Control並不會修改另一個訊息處理過程中的快取處理過程。請求時的快取指令有下幾種： Public指示響應可被任何快取區快取。 Private指示對於單個

IOS學習網路 AFNetworking單檔案上傳取消單個佇列和全部佇列的方法(取消網路請求)

專案中有時會有這種情況，當介面正在請求資料，但資料為返回之前。返回到上一個介面，這種情況下，應取消此介面的網路請求。此篇就是為了處理此種情況下的操作，可以取消單個請求佇列，如果介面介面很多，可以一次性取消所有請求佇列。 AFHTTPSessionManager *manager =

falsk之檔案上傳

在使用flask定義路由完成檔案上傳時，定義upload檢視函式 from flask import Flask, render_template from werkzeug.utils import secure_filename import os app = Flask

laravel框架之檔案上傳

引用use檔案控制器引用模型檔案方便呼叫 use App\Info\Info; 模型引用DB檔案 use Illuminate\Support\Facades\DB; model模型中的程式碼 public function index(){ //

Android核心技術-day05-02-檔案上傳

package com.gaozewen.fileupload; import android.os.Bundle; import android.support.v7.app.AppCompatActivity; import android.text.TextUtils; impor

Android okHttp網路請求之檔案上傳下載

前言：

檔案上傳：

1.）不帶引數上傳檔案

2.）帶引數上傳檔案

3.)帶引數帶進度上傳檔案

4.）建立帶進度RequestBody

5.)不帶進度檔案下載

6.）帶進度檔案下載

7.）介面ReqProgressCallBack.java實現

8.）進度回撥實現

相關推薦