Android中實現OkHttp上傳文件到服務器并帶進度

2019-10-22 18:33:06

字體：大中小

來源：轉載

供稿：網友

在上一講中 OkHttp下載文件并帶進度條中，我們知道怎樣去下載文件了。那上傳文件呢

一、編寫服務器端

在上一講服務器下新建UploadFileServlet，代碼如下：然后重啟服務器！

@WebServlet("/UploadFileServlet")@MultipartConfigpublic class UploadFileServlet extends HttpServlet {  private static final long serialVersionUID = 1L;  public UploadFileServlet() {    super();    // TODO Auto-generated constructor stub  }  /**   * @see HttpServlet#doGet(HttpServletRequest request, HttpServletResponse   *   response)   */  protected void doGet(HttpServletRequest request, HttpServletResponse response)      throws ServletException, IOException {    this.doPost(request, response);  }  /**   * @see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse   *   response)   */  protected void doPost(HttpServletRequest request, HttpServletResponse response)      throws ServletException, IOException {    System.out.println("doPost==");    request.setCharacterEncoding("utf-8");    //獲取file命名的part，注意要與Android端一樣    Part part = request.getPart("file");    // 獲取請求頭，請求頭的格式：form-data; name="file"; filename="snmp4j--api.zip"    String header = part.getHeader("content-disposition");    System.out.println(header);    String fileName = getFileName(header);    // 存儲路徑    String savePath = "D:/huang/upload";    // 把文件寫到指定路徑    part.write(savePath + File.separator + fileName);    response.setCharacterEncoding("UTF-8");    PrintWriter writer = response.getWriter();    writer.print("上傳成功");  }  public String getFileName(String header) {    /**     * header 為 form-data; name="file"; filename="dial.png"     * String[] tempArr1 =     * header.split(";");代碼執行完之后，在不同的瀏覽器下，tempArr1數組里面的內容稍有區別     * 火狐或者google瀏覽器下：tempArr1={form-data,name="file",filename=     * "snmp4j--api.zip"}     * IE瀏覽器下：tempArr1={form-data,name="file",filename="E:/snmp4j--api.zip"}     */    String[] tempArr1 = header.split(";");    /**     * 火狐或者google瀏覽器下：tempArr2={filename,"snmp4j--api.zip"}     * IE瀏覽器下：tempArr2={filename,"E:/snmp4j--api.zip"}     */    String[] tempArr2 = tempArr1[2].split("=");    // 獲取文件名，兼容各種瀏覽器的寫法    String fileName = tempArr2[1].substring(tempArr2[1].lastIndexOf("//") + 1).replaceAll("/"", "");    return fileName;  }}

二、Android端

1.布局，上一講activity_main代碼中添加：

 <Button    android:id="@+id/ok_post_file"    android:layout_width="match_parent"    android:layout_height="wrap_content"    android:text="上傳文件" />  <TextView    android:id="@+id/post_text"    android:layout_width="match_parent"    android:layout_height="wrap_content"    android:gravity="center"    android:text="0" />  <ProgressBar    android:id="@+id/post_progress"    style="?android:attr/progressBarStyleHorizontal"    android:layout_width="match_parent"    android:layout_height="wrap_content"    android:max="100" />

2.OkHttpUtil新增上傳文件方法：

 public static void postFile(String url, final ProgressListener listener, Callback callback, File...files){    MultipartBody.Builder builder = new MultipartBody.Builder();    builder.setType(MultipartBody.FORM);    Log.i("huang","files[0].getName()=="+files[0].getName());    //第一個參數要與Servlet中的一致    builder.addFormDataPart("file",files[0].getName(), RequestBody.create(MediaType.parse("application/octet-stream"),files[0]));    MultipartBody multipartBody = builder.build();    Request request = new Request.Builder().url(url).post(new ProgressRequestBody(multipartBody,listener)).build();    okHttpClient.newCall(request).enqueue(callback);  }

3.ProgressRequestBody是自定義RequestBody類，用來監聽進度：

public class ProgressRequestBody extends RequestBody {  public static final int UPDATE = 0x01;  private RequestBody requestBody;  private ProgressListener mListener;  private BufferedSink bufferedSink;  private MyHandler myHandler;  public ProgressRequestBody(RequestBody body, ProgressListener listener) {    requestBody = body;    mListener = listener;    if (myHandler==null){      myHandler = new MyHandler();    }  }  class MyHandler extends Handler {  //放在主線程中顯示     public MyHandler() {      super(Looper.getMainLooper());    }    @Override    public void handleMessage(Message msg) {      switch (msg.what){        case UPDATE:          ProgressModel progressModel = (ProgressModel) msg.obj;          if (mListener!=null)mListener.onProgress(progressModel.getCurrentBytes(),progressModel.getContentLength(),progressModel.isDone());          break;      }    }  }  @Override  public MediaType contentType() {    return requestBody.contentType();  }  @Override  public long contentLength() throws IOException {    return requestBody.contentLength();  }  @Override  public void writeTo(BufferedSink sink) throws IOException {    if (bufferedSink==null){      bufferedSink = Okio.buffer(sink(sink));    }    //寫入    requestBody.writeTo(bufferedSink);    //刷新    bufferedSink.flush();  }  private Sink sink(BufferedSink sink) {    return new ForwardingSink(sink) {      long bytesWritten = 0L;      long contentLength = 0L;      @Override      public void write(Buffer source, long byteCount) throws IOException {        super.write(source, byteCount);        if (contentLength==0){          contentLength = contentLength();        }        bytesWritten += byteCount;        //回調        Message msg = Message.obtain();        msg.what = UPDATE;        msg.obj = new ProgressModel(bytesWritten,contentLength,bytesWritten==contentLength);        myHandler.sendMessage(msg);      }    };  }}

4.在MainActivity添加上傳按鈕點擊事件，代碼如下：

  File file = new File(basePath + "/1.mp4");        String postUrl = "http://192.168.0.104:8080/OkHttpServer/UploadFileServlet";        OkHttpUtil.postFile(postUrl, new ProgressListener() {          @Override          public void onProgress(long currentBytes, long contentLength, boolean done) {            Log.i(TAG, "currentBytes==" + currentBytes + "==contentLength==" + contentLength + "==done==" + done);            int progress = (int) (currentBytes * 100 / contentLength);            post_progress.setProgress(progress);            post_text.setText(progress + "%");          }        }, new Callback() {          @Override          public void onFailure(Call call, IOException e) {          }          @Override          public void onResponse(Call call, Response response) throws IOException {            if (response != null) {              String result = response.body().string();              Log.i(TAG, "result===" + result);            }          }        }, file);

相關效果圖：

OkHttp上傳文件,OkHttp文件上傳進度