閱讀707 返回首頁    go 阿裏雲 go 技術社區[雲棲]

Android分別使用HTTP協議和TCP協議實現上傳文件

https://blog.csdn.net/furongkang/article/details/6838450

Android上傳文件有兩種方式，第一種是基於Http協議的HttpURLConnection，第二種是基於TCP協議的Socket。 這兩種方式的區別是使用HttpURLConnection上傳時內部有緩存機製，如果上傳較大文件會導致內存溢出。如果用TCP協議Socket方式上傳就會解決這種弊端。

HTTP協議HttpURLConnection

1. 通過URL封裝路徑打開一個HttpURLConnection

2.設置請求方式以及頭字段：Content-Type、Content-Length、Host

3.拚接數據發送

示例：

[java] view plaincopy
  1. private static final String BOUNDARY = "---------------------------7db1c523809b2";//數據分割線  
  2.   
  3. public boolean uploadHttpURLConnection(String username, String password, String path) throws Exception {  
  4.     //找到sdcard上的文件  
  5.     File file = new File(Environment.getExternalStorageDirectory(), path);  
  6.                  //仿Http協議發送數據方式進行拚接  
  7.     StringBuilder sb = new StringBuilder();  
  8.     sb.append("--" + BOUNDARY + "\r\n");  
  9.     sb.append("Content-Disposition: form-data; name=\"username\"" + "\r\n");  
  10.     sb.append("\r\n");  
  11.     sb.append(username + "\r\n");  
  12.   
  13.     sb.append("--" + BOUNDARY + "\r\n");  
  14.     sb.append("Content-Disposition: form-data; name=\"password\"" + "\r\n");  
  15.     sb.append("\r\n");  
  16.     sb.append(password + "\r\n");  
  17.   
  18.     sb.append("--" + BOUNDARY + "\r\n");  
  19.     sb.append("Content-Disposition: form-data; name=\"file\"; filename=\"" + path + "\"" + "\r\n");  
  20.     sb.append("Content-Type: image/pjpeg" + "\r\n");  
  21.     sb.append("\r\n");  
  22.   
  23.     byte[] before = sb.toString().getBytes("UTF-8");  
  24.     byte[] after = ("\r\n--" + BOUNDARY + "--\r\n").getBytes("UTF-8");  
  25.   
  26.     URL url = new URL("https://192.168.1.16:8080/14_Web/servlet/LoginServlet");  
  27.     HttpURLConnection conn = (HttpURLConnection) url.openConnection();  
  28.     conn.setRequestMethod("POST");  
  29.     conn.setRequestProperty("Content-Type", "multipart/form-data; boundary=" + BOUNDARY);  
  30.     conn.setRequestProperty("Content-Length", String.valueOf(before.length + file.length() + after.length));  
  31.     conn.setRequestProperty("HOST", "192.168.1.16:8080");  
  32.     conn.setDoOutput(true);   
  33.   
  34.     OutputStream out = conn.getOutputStream();  
  35.     InputStream in = new FileInputStream(file);  
  36.       
  37.     out.write(before);  
  38.   
  39.     byte[] buf = new byte[1024];  
  40.     int len;  
  41.     while ((len = in.read(buf)) != -1)  
  42.         out.write(buf, 0, len);  
  43.   
  44.     out.write(after);  
  45.   
  46.     in.close();  
  47.     out.close();  
  48.     return conn.getResponseCode() == 200;  
  49. }  

TCP協議Socket

1.我們可以使用Socket發送TCP請求，將上傳數據分段發送

示例：

[java] view plaincopy
  1. public boolean uploadBySocket(String username, String password, String path) throws Exception {  
  2.     // 根據path找到SDCard中的文件  
  3.     File file = new File(Environment.getExternalStorageDirectory(), path);  
  4.     // 組裝表單字段和文件之前的數據  
  5.     StringBuilder sb = new StringBuilder();  
  6.   
  7.     sb.append("--" + BOUNDARY + "\r\n");  
  8.     sb.append("Content-Disposition: form-data; name=\"username\"" + "\r\n");  
  9.     sb.append("\r\n");  
  10.     sb.append(username + "\r\n");  
  11.   
  12.     sb.append("--" + BOUNDARY + "\r\n");  
  13.     sb.append("Content-Disposition: form-data; name=\"password\"" + "\r\n");  
  14.     sb.append("\r\n");  
  15.     sb.append(password + "\r\n");  
  16.   
  17.     sb.append("--" + BOUNDARY + "\r\n");  
  18.     sb.append("Content-Disposition: form-data; name=\"file\"; filename=\"" + path + "\"" + "\r\n");  
  19.     sb.append("Content-Type: image/pjpeg" + "\r\n");  
  20.     sb.append("\r\n");  
  21.   
  22.     // 文件之前的數據  
  23.     byte[] before = sb.toString().getBytes("UTF-8");  
  24.     // 文件之後的數據  
  25.     byte[] after = ("\r\n--" + BOUNDARY + "--\r\n").getBytes("UTF-8");  
  26.   
  27.     URL url = new URL("https://192.168.1.199:8080/14_Web/servlet/LoginServlet");  
  28.   
  29.     // 由於HttpURLConnection中會緩存數據, 上傳較大文件時會導致內存溢出, 所以我們使用Socket傳輸  
  30.     Socket socket = new Socket(url.getHost(), url.getPort());  
  31.     OutputStream out = socket.getOutputStream();  
  32.     PrintStream ps = new PrintStream(out, true, "UTF-8");  
  33.   
  34.     // 寫出請求頭  
  35.     ps.println("POST /14_Web/servlet/LoginServlet HTTP/1.1");  
  36.     ps.println("Content-Type: multipart/form-data; boundary=" + BOUNDARY);  
  37.     ps.println("Content-Length: " + String.valueOf(before.length + file.length() + after.length));  
  38.     ps.println("Host: 192.168.1.199:8080");  
  39.       
  40.     InputStream in = new FileInputStream(file);  
  41.   
  42.     // 寫出數據  
  43.     out.write(before);  
  44.   
  45.     byte[] buf = new byte[1024];  
  46.     int len;  
  47.     while ((len = in.read(buf)) != -1)  
  48.         out.write(buf, 0, len);  
  49.   
  50.     out.write(after);  
  51.   
  52.     in.close();  
  53.     out.close();  
  54.   
  55.     return true;  
  56. }  


 

搭建服務器，完成上傳功能

[java] view plaincopy
  1. package cn.test.web.servlet;  
  2.   
  3. import java.io.File;  
  4. import java.io.IOException;  
  5. import java.util.List;  
  6.   
  7. import javax.servlet.ServletException;  
  8. import javax.servlet.http.HttpServlet;  
  9. import javax.servlet.http.HttpServletRequest;  
  10. import javax.servlet.http.HttpServletResponse;  
  11.   
  12. import org.apache.commons.fileupload.FileItem;  
  13. import org.apache.commons.fileupload.FileItemFactory;  
  14. import org.apache.commons.fileupload.disk.DiskFileItemFactory;  
  15. import org.apache.commons.fileupload.servlet.ServletFileUpload;  
  16.   
  17. public class LoginServlet extends HttpServlet {  
  18.   
  19.     private static final long serialVersionUID = 1L;  
  20.   
  21.     @Override  
  22.     public void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {  
  23.         doPost(request, response);  
  24.     }  
  25.   
  26.     @Override  
  27.     public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {  
  28.         boolean isMultipart = ServletFileUpload.isMultipartContent(request);  
  29.         if (isMultipart)  
  30.             try {  
  31.                 FileItemFactory factory = new DiskFileItemFactory();  
  32.                 ServletFileUpload upload = new ServletFileUpload(factory);  
  33.                 List<FileItem> items = upload.parseRequest(request);  
  34.                 File dir = new File(request.getSession().getServletContext().getRealPath("/WEB-INF/upload"));  
  35.                 //創建目錄  
  36.                 dir.mkdir();  
  37.                 for (FileItem item : items)  
  38.                     if (item.isFormField())  
  39.                         System.out.println(item.getFieldName() + ": " + item.getString());  
  40.                     else{  
  41.                         item.write(new File(dir,item.getName().substring(item.getName().lastIndexOf("\\")+1)));  
  42.                     }  
  43.             } catch (Exception e) {  
  44.                 e.printStackTrace();  
  45.             }  
  46.         else {  
  47.             System.out.println(request.getMethod());  
  48.             System.out.println(request.getParameter("username"));  
  49.             System.out.println(request.getParameter("password"));  
  50.         }  
  51.     }  
  52. }  

最後更新：2017-04-03 22:15:39

  上一篇：go 心動！首款Windows 8係統手機即將麵世
  下一篇：go 基於Hadoop雲盤係統1：上傳和下載效率優化