博客
关于我
强烈建议你试试无所不能的chatGPT，快点击我
Android之使用Http协议实现文件上传功能
阅读量：5836 次
发布时间：2019-06-18

本文共 12341 字，大约阅读时间需要 41 分钟。

hot3.png

注意一般使用Http协议上传的文件都比较小，一般是小于2M

这里示例是上传一个小的MP3文件

1.主Activity：MainActivity.java

  1. public class MainActivity extends Activity   
  2. {  
  3.     private static final String TAG = "MainActivity";  
  4.     private EditText timelengthText;  
  5.     private EditText titleText;  
  6.     private EditText videoText;  
  7.       
  8.     @Override  
  9.     public void onCreate(Bundle savedInstanceState)   
  10.     {  
  11.        super.onCreate(savedInstanceState);  
  12.        setContentView(R.layout.main);  
  13.        //提交上传按钮  
  14.        Button button = (Button) this.findViewById(R.id.button);  
  15.        timelengthText = (EditText) this.findViewById(R.id.timelength);  
  16.        videoText = (EditText) this.findViewById(R.id.video);  
  17.        titleText = (EditText) this.findViewById(R.id.title);  
  18.        button.setOnClickListener(new View.OnClickListener()   
  19.        {              
  20.             @Override  
  21.             public void onClick(View v)   
  22.             {  
  23.                 String title = titleText.getText().toString();  
  24.                 String timelength = timelengthText.getText().toString();  
  25.                 Map<String, String> params = new HashMap<String, String>();  
  26.                 params.put("method", "save");  
  27.                 params.put("title", title);  
  28.                 params.put("timelength", timelength);  
  29.                 try   
  30.                 {                     
  31.                     //得到SDCard的目录  
  32.                     File uploadFile = new File(Environment.getExternalStorageDirectory(), videoText.getText().toString());  
  33.                     //上传音频文件  
  34.                     FormFile formfile = new FormFile("02.mp3", uploadFile, "video", "audio/mpeg");  
  35.                     SocketHttpRequester.post("http://192.168.1.100:8080/videoweb/video/manage.do", params, formfile);  
  36.                     Toast.makeText(MainActivity.this, R.string.success, 1).show();  
  37.                 }  
  38.                 catch (Exception e)   
  39.                 {  
  40.                     Toast.makeText(MainActivity.this, R.string.error, 1).show();  
  41.                     Log.e(TAG, e.toString());  
  42.                 }  
  43.             }  
  44.         });          
  45.     }  
  46. }  
 

2.上传工具类，注意里面构造协议字符串需要根据不同的提交表单来处理

  1. public class SocketHttpRequester   
  2. {  
  3.     /** 
  4.      * 发送xml数据 
  5.      * @param path 请求地址 
  6.      * @param xml xml数据 
  7.      * @param encoding 编码 
  8.      *   
  9.      * @throws Exception 
  10.      */  
  11.     public static byte[] postXml(String path, String xml, String encoding) throws Exception{  
  12.         byte[] data = xml.getBytes(encoding);  
  13.         URL url = new URL(path);  
  14.         HttpURLConnection conn = (HttpURLConnection)url.openConnection();  
  15.         conn.setRequestMethod("POST");  
  16.         conn.setDoOutput(true);  
  17.         conn.setRequestProperty("Content-Type", "text/xml; charset="+ encoding);  
  18.         conn.setRequestProperty("Content-Length", String.valueOf(data.length));  
  19.         conn.setConnectTimeout(5 * 1000);  
  20.         OutputStream outStream = conn.getOutputStream();  
  21.         outStream.write(data);  
  22.         outStream.flush();  
  23.         outStream.close();  
  24.         if(conn.getResponseCode()==200){  
  25.             return readStream(conn.getInputStream());  
  26.         }  
  27.         return null;  
  28.     }  
  29.       
  30.     /** 
  31.      * 直接通过HTTP协议提交数据到服务器,实现如下面表单提交功能: 
  32.      *   <FORM METHOD=POST ACTION="http://192.168.0.200:8080/ssi/fileload/test.do" enctype="multipart/form-data"> 
  33.             <INPUT TYPE="text" NAME="name"> 
  34.             <INPUT TYPE="text" NAME="id"> 
  35.             <input type="file" name="imagefile"/> 
  36.             <input type="file" name="zip"/> 
  37.          </FORM> 
  38.      * @param path 上传路径(注：避免使用localhost或127.0.0.1这样的路径测试， 
  39.      *                  因为它会指向手机模拟器，你可以使用http://www.baidu.com或http://192.168.1.10:8080这样的路径测试) 
  40.      * @param params 请求参数 key为参数名,value为参数值 
  41.      * @param file 上传文件 
  42.      */  
  43.     public static boolean post(String path, Map<String, String> params, FormFile[] files) throws Exception  
  44.     {     
  45.         //数据分隔线  
  46.         final String BOUNDARY = "---------------------------7da2137580612";   
  47.         //数据结束标志"---------------------------7da2137580612--"  
  48.         final String endline = "--" + BOUNDARY + "--/r/n";  
  49.           
  50.         //下面两个for循环都是为了得到数据长度参数，依据表单的类型而定  
  51.         //首先得到文件类型数据的总长度(包括文件分割线)  
  52.         int fileDataLength = 0;  
  53.         for(FormFile uploadFile : files)  
  54.         {  
  55.             StringBuilder fileExplain = new StringBuilder();  
  56.             fileExplain.append("--");  
  57.             fileExplain.append(BOUNDARY);  
  58.             fileExplain.append("/r/n");  
  59.             fileExplain.append("Content-Disposition: form-data;name=/""+ uploadFile.getParameterName()+"/";filename=/""+ uploadFile.getFilname() + "/"/r/n");  
  60.             fileExplain.append("Content-Type: "+ uploadFile.getContentType()+"/r/n/r/n");  
  61.             fileExplain.append("/r/n");  
  62.             fileDataLength += fileExplain.length();  
  63.             if(uploadFile.getInStream()!=null){  
  64.                 fileDataLength += uploadFile.getFile().length();  
  65.             }else{  
  66.                 fileDataLength += uploadFile.getData().length;  
  67.             }  
  68.         }  
  69.         //再构造文本类型参数的实体数据  
  70.         StringBuilder textEntity = new StringBuilder();          
  71.         for (Map.Entry<String, String> entry : params.entrySet())   
  72.         {    
  73.             textEntity.append("--");  
  74.             textEntity.append(BOUNDARY);  
  75.             textEntity.append("/r/n");  
  76.             textEntity.append("Content-Disposition: form-data; name=/""+ entry.getKey() + "/"/r/n/r/n");  
  77.             textEntity.append(entry.getValue());  
  78.             textEntity.append("/r/n");  
  79.         }  
  80.           
  81.         //计算传输给服务器的实体数据总长度(文本总长度+数据总长度+分隔符)  
  82.         int dataLength = textEntity.toString().getBytes().length + fileDataLength +  endline.getBytes().length;  
  83.           
  84.         URL url = new URL(path);  
  85.         //默认端口号其实可以不写  
  86.         int port = url.getPort()==-1 ? 80 : url.getPort();  
  87.         //建立一个Socket链接  
  88.         Socket socket = new Socket(InetAddress.getByName(url.getHost()), port);  
  89.         //获得一个输出流（从Android流到web）  
  90.         OutputStream outStream = socket.getOutputStream();  
  91.         //下面完成HTTP请求头的发送  
  92.         String requestmethod = "POST "+ url.getPath()+" HTTP/1.1/r/n";  
  93.         outStream.write(requestmethod.getBytes());  
  94.         //构建accept  
  95.         String accept = "Accept: image/gif, image/jpeg, image/pjpeg, image/pjpeg, application/x-shockwave-flash, application/xaml+xml, application/vnd.ms-xpsdocument, application/x-ms-xbap, application/x-ms-application, application/vnd.ms-excel, application/vnd.ms-powerpoint, application/msword, */*/r/n";  
  96.         outStream.write(accept.getBytes());  
  97.         //构建language  
  98.         String language = "Accept-Language: zh-CN/r/n";  
  99.         outStream.write(language.getBytes());  
  100.         //构建contenttype  
  101.         String contenttype = "Content-Type: multipart/form-data; boundary="+ BOUNDARY+ "/r/n";  
  102.         outStream.write(contenttype.getBytes());  
  103.         //构建contentlength  
  104.         String contentlength = "Content-Length: "+ dataLength + "/r/n";  
  105.         outStream.write(contentlength.getBytes());  
  106.         //构建alive  
  107.         String alive = "Connection: Keep-Alive/r/n";          
  108.         outStream.write(alive.getBytes());  
  109.         //构建host  
  110.         String host = "Host: "+ url.getHost() +":"+ port +"/r/n";  
  111.         outStream.write(host.getBytes());  
  112.         //写完HTTP请求头后根据HTTP协议再写一个回车换行  
  113.         outStream.write("/r/n".getBytes());  
  114.         //把所有文本类型的实体数据发送出来  
  115.         outStream.write(textEntity.toString().getBytes());           
  116.           
  117.         //把所有文件类型的实体数据发送出来  
  118.         for(FormFile uploadFile : files)  
  119.         {  
  120.             StringBuilder fileEntity = new StringBuilder();  
  121.             fileEntity.append("--");  
  122.             fileEntity.append(BOUNDARY);  
  123.             fileEntity.append("/r/n");  
  124.             fileEntity.append("Content-Disposition: form-data;name=/""+ uploadFile.getParameterName()+"/";filename=/""+ uploadFile.getFilname() + "/"/r/n");  
  125.             fileEntity.append("Content-Type: "+ uploadFile.getContentType()+"/r/n/r/n");  
  126.             outStream.write(fileEntity.toString().getBytes());  
  127.             //边读边写  
  128.             if(uploadFile.getInStream()!=null)  
  129.             {  
  130.                 byte[] buffer = new byte[1024];  
  131.                 int len = 0;  
  132.                 while((len = uploadFile.getInStream().read(buffer, 0, 1024))!=-1)  
  133.                 {  
  134.                     outStream.write(buffer, 0, len);  
  135.                 }  
  136.                 uploadFile.getInStream().close();  
  137.             }  
  138.             else  
  139.             {  
  140.                 outStream.write(uploadFile.getData(), 0, uploadFile.getData().length);  
  141.             }  
  142.             outStream.write("/r/n".getBytes());  
  143.         }  
  144.         //下面发送数据结束标志，表示数据已经结束  
  145.         outStream.write(endline.getBytes());          
  146.         BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));  
  147.         //读取web服务器返回的数据，判断请求码是否为200，如果不是200，代表请求失败  
  148.         if(reader.readLine().indexOf("200")==-1)  
  149.         {  
  150.             return false;  
  151.         }  
  152.         outStream.flush();  
  153.         outStream.close();  
  154.         reader.close();  
  155.         socket.close();  
  156.         return true;  
  157.     }  
  158.       
  159.     /**  
  160.      * 提交数据到服务器  
  161.      * @param path 上传路径(注：避免使用localhost或127.0.0.1这样的路径测试，因为它会指向手机模拟器，你可以使用http://www.baidu.com或http://192.168.1.10:8080这样的路径测试)  
  162.      * @param params 请求参数 key为参数名,value为参数值  
  163.      * @param file 上传文件  
  164.      */  
  165.     public static boolean post(String path, Map<String, String> params, FormFile file) throws Exception  
  166.     {  
  167.        return post(path, params, new FormFile[]{file});  
  168.     }  
  169.     /** 
  170.      * 提交数据到服务器 
  171.      * @param path 上传路径(注：避免使用localhost或127.0.0.1这样的路径测试，因为它会指向手机模拟器，你可以使用http://www.baidu.com或http://192.168.1.10:8080这样的路径测试) 
  172.      * @param params 请求参数 key为参数名,value为参数值 
  173.      * @param encode 编码 
  174.      */  
  175.     public static byte[] postFromHttpClient(String path, Map<String, String> params, String encode) throws Exception  
  176.     {  
  177.         //用于存放请求参数  
  178.         List<NameValuePair> formparams = new ArrayList<NameValuePair>();  
  179.         for(Map.Entry<String, String> entry : params.entrySet())  
  180.         {  
  181.             formparams.add(new BasicNameValuePair(entry.getKey(), entry.getValue()));  
  182.         }  
  183.         UrlEncodedFormEntity entity = new UrlEncodedFormEntity(formparams, encode);  
  184.         HttpPost httppost = new HttpPost(path);  
  185.         httppost.setEntity(entity);  
  186.         //看作是浏览器  
  187.         HttpClient httpclient = new DefaultHttpClient();  
  188.         //发送post请求    
  189.         HttpResponse response = httpclient.execute(httppost);     
  190.         return readStream(response.getEntity().getContent());  
  191.     }  
  192.     /** 
  193.      * 发送请求 
  194.      * @param path 请求路径 
  195.      * @param params 请求参数 key为参数名称 value为参数值 
  196.      * @param encode 请求参数的编码 
  197.      */  
  198.     public static byte[] post(String path, Map<String, String> params, String encode) throws Exception  
  199.     {  
  200.         //String params = "method=save&name="+ URLEncoder.encode("老毕", "UTF-8")+ "&age=28&";//需要发送的参数  
  201.         StringBuilder parambuilder = new StringBuilder("");  
  202.         if(params!=null && !params.isEmpty())  
  203.         {  
  204.             for(Map.Entry<String, String> entry : params.entrySet())  
  205.             {  
  206.                 parambuilder.append(entry.getKey()).append("=")  
  207.                     .append(URLEncoder.encode(entry.getValue(), encode)).append("&");  
  208.             }  
  209.             parambuilder.deleteCharAt(parambuilder.length()-1);  
  210.         }  
  211.         byte[] data = parambuilder.toString().getBytes();  
  212.         URL url = new URL(path);  
  213.         HttpURLConnection conn = (HttpURLConnection)url.openConnection();  
  214.         //设置允许对外发送请求参数  
  215.         conn.setDoOutput(true);  
  216.         //设置不进行缓存  
  217.         conn.setUseCaches(false);  
  218.         conn.setConnectTimeout(5 * 1000);  
  219.         conn.setRequestMethod("POST");  
  220.         //下面设置http请求头  
  221.         conn.setRequestProperty("Accept", "image/gif, image/jpeg, image/pjpeg, image/pjpeg, application/x-shockwave-flash, application/xaml+xml, application/vnd.ms-xpsdocument, application/x-ms-xbap, application/x-ms-application, application/vnd.ms-excel, application/vnd.ms-powerpoint, application/msword, */*");  
  222.         conn.setRequestProperty("Accept-Language", "zh-CN");  
  223.         conn.setRequestProperty("User-Agent", "Mozilla/4.0 (compatible; MSIE 8.0; Windows NT 5.2; Trident/4.0; .NET CLR 1.1.4322; .NET CLR 2.0.50727; .NET CLR 3.0.04506.30; .NET CLR 3.0.4506.2152; .NET CLR 3.5.30729)");  
  224.         conn.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");  
  225.         conn.setRequestProperty("Content-Length", String.valueOf(data.length));  
  226.         conn.setRequestProperty("Connection", "Keep-Alive");  
  227.           
  228.         //发送参数  
  229.         DataOutputStream outStream = new DataOutputStream(conn.getOutputStream());  
  230.         outStream.write(data);//把参数发送出去  
  231.         outStream.flush();  
  232.         outStream.close();  
  233.         if(conn.getResponseCode()==200)  
  234.         {  
  235.             return readStream(conn.getInputStream());  
  236.         }  
  237.         return null;  
  238.     }  
  239.       
  240.     /**  
  241.      * 读取流  
  242.      * @param inStream  
  243.      *   字节数组  
  244.      *   Exception  
  245.      */  
  246.     public static byte[] readStream(InputStream inStream) throws Exception  
  247.     {  
  248.         ByteArrayOutputStream outSteam = new ByteArrayOutputStream();  
  249.         byte[] buffer = new byte[1024];  
  250.         int len = -1;  
  251.         while( (len=inStream.read(buffer)) != -1)  
  252.         {  
  253.             outSteam.write(buffer, 0, len);  
  254.         }  
  255.         outSteam.close();  
  256.         inStream.close();  
  257.         return outSteam.toByteArray();  
  258.     }  
  259. }  
 

  1. public class StreamTool   
  2. {  
  3.     /** 
  4.      * 从输入流读取数据 
  5.      * @param inStream 
  6.      *   
  7.      * @throws Exception 
  8.      */  
  9.     public static byte[] readInputStream(InputStream inStream) throws Exception{  
  10.         ByteArrayOutputStream outSteam = new ByteArrayOutputStream();  
  11.         byte[] buffer = new byte[1024];  
  12.         int len = 0;  
  13.         while( (len = inStream.read(buffer)) !=-1 ){  
  14.             outSteam.write(buffer, 0, len);  
  15.         }  
  16.         outSteam.close();  
  17.         inStream.close();  
  18.         return outSteam.toByteArray();  
  19.     }  
  20. }  
 

  1. /** 
  2.  * 使用JavaBean封装上传文件数据 
  3.  *  
  4.  */  
  5. public class FormFile   
  6. {  
  7.     //上传文件的数据   
  8.     private byte[] data;  
  9.     private InputStream inStream;  
  10.     private File file;  
  11.     //文件名称   
  12.     private String filname;  
  13.     //请求参数名称  
  14.     private String parameterName;  
  15.     //内容类型  
  16.     private String contentType = "application/octet-stream";  
  17.       
  18.     /** 
  19.      * 上传小文件，把文件数据先读入内存 
  20.      * @param filname 
  21.      * @param data 
  22.      * @param parameterName 
  23.      * @param contentType 
  24.      */  
  25.     public FormFile(String filname, byte[] data, String parameterName, String contentType)   
  26.     {  
  27.         this.data = data;  
  28.         this.filname = filname;  
  29.         this.parameterName = parameterName;  
  30.         if(contentType!=null) this.contentType = contentType;  
  31.     }  
  32.       
  33.     /** 
  34.      * 上传大文件，一边读文件数据一边上传 
  35.      * @param filname 
  36.      * @param file 
  37.      * @param parameterName 
  38.      * @param contentType 
  39.      */  
  40.     public FormFile(String filname, File file, String parameterName, String contentType)   
  41.     {  
  42.         this.filname = filname;  
  43.         this.parameterName = parameterName;  
  44.         this.file = file;  
  45.         try   
  46.         {  
  47.             this.inStream = new FileInputStream(file);  
  48.         }  
  49.         catch (FileNotFoundException e)   
  50.         {  
  51.             e.printStackTrace();  
  52.         }  
  53.         if(contentType!=null) this.contentType = contentType;  
  54.     }  
  55.       
  56.     public File getFile()   
  57.     {  
  58.         return file;  
  59.     }  
  60.     public InputStream getInStream()   
  61.     {  
  62.         return inStream;  
  63.     }  
  64.     public byte[] getData()   
  65.     {  
  66.         return data;  
  67.     }  
  68.     public String getFilname()   
  69.     {  
  70.         return filname;  
  71.     }  
  72.     public void setFilname(String filname)  
  73.     {  
  74.         this.filname = filname;  
  75.     }  
  76.     public String getParameterName()   
  77.     {  
  78.         return parameterName;  
  79.     }  
  80.     public void setParameterName(String parameterName)   
  81.     {  
  82.         this.parameterName = parameterName;  
  83.     }  
  84.     public String getContentType()  
  85.     {  
  86.         return contentType;  
  87.     }  
  88.     public void setContentType(String contentType)   
  89.     {  
  90.         this.contentType = contentType;  
  91.     }     
  92. }  

原文:

转载于:https://my.oschina.net/lendylongli/blog/226804

你可能感兴趣的文章
注解(Annotation)
查看>>
Java学习笔记十六:Java中的构造方法
查看>>
FastDFS+Nginx+fastdfs-nginx-module集群搭建
查看>>
浏览器启动时自动全屏配置
查看>>
1.OpenGLES——FBO方式的离屏渲染
查看>>
1.1大数据平台架构及Hadoop生态圈
查看>>
【Mobile Web Develop】Mobile Web Resources
查看>>
线性筛法及积性函数总结(欧拉函数、莫比乌斯函数、约数和函数、约数个数函数)...
查看>>
深度学习框架介绍与比较
查看>>
html基础
查看>>
Aizu-1378- ICPC Asia 2017-Secret of Chocolate Poles
查看>>
戴尔CEO:没兴趣收购惠普PC业务 借机扩市额
查看>>
路由配置命令
查看>>
UVA-11584
查看>>
WPF03(样式)
查看>>
C# DataSet数据导入Excel 修正版- .net FrameWork 4.0以上
查看>>
SharedPreferences和PreferencesActvity
查看>>
深入理解java虚拟机（三）--类文件结构
查看>>
Null value was assigned to a property of primitive type setter of
查看>>
UIRecorder 学习了解
查看>>
喝酒易醉，品茶养心，人生如梦，品茶悟道，何以解忧？唯有杜康！-- 愿君每日到此一游！
当前时间: 2024-12-24 03:17:32   当前IP: 18.217.89.130   联系邮箱:javaeecc@qq.com     Copyright © 2020 - 2022 baihongyu.com 京ICP备2021015314号-2
强烈建议你试试无所不能的CHAT-GPT，快点击我
强烈建议你试试无所不能的CHAT-GPT，快点击我