Android实现上传文件到服务器实例详解

本实例实现每隔5秒上传⼀次，通过服务器端获取⼿机上传过来的⽂件信息并做相应处理；采⽤Android+Struts2技术。⼀、Android端实现⽂件上传

1)、新建⼀个Android项⽬命名为androidUpload，⽬录结构如下：2)、新建FormFile类，⽤来封装⽂件信息

package com.ljq.utils;

import java.io.File;

import java.io.FileInputStream;

import java.io.FileNotFoundException;import java.io.InputStream;

/**

* 上传⽂件 */

public class FormFile { /* 上传⽂件的数据 */ private byte[] data;

private InputStream inStream; private File file; /* ⽂件名称 */

private String filname; /* 请求参数名称*/

private String parameterName; /* 内容类型 */

private String contentType = \"application/octet-stream\";

public FormFile(String filname, byte[] data, String parameterName, String contentType) { this.data = data;

this.filname = filname;

this.parameterName = parameterName;

if(contentType!=null) this.contentType = contentType; }

public FormFile(String filname, File file, String parameterName, String contentType) { this.filname = filname;

this.parameterName = parameterName; this.file = file; try {

this.inStream = new FileInputStream(file); } catch (FileNotFoundException e) { e.printStackTrace(); }

if(contentType!=null) this.contentType = contentType; }

public File getFile() { return file; }

public InputStream getInStream() { return inStream; }

public byte[] getData() { return data; }

public String getFilname() { return filname; }

public void setFilname(String filname) { this.filname = filname; }

public String getParameterName() { return parameterName; }

public void setParameterName(String parameterName) { this.parameterName = parameterName; }

public String getContentType() { return contentType; }

public void setContentType(String contentType) { this.contentType = contentType; } }

3）、新建SocketHttpRequester类，封装上传⽂件到服务器代码

package com.ljq.utils;

import java.io.BufferedReader;import java.io.InputStreamReader;import java.io.OutputStream;import java.net.InetAddress;import java.net.Socket;import java.net.URL;import java.util.Map;

/**

* 上传⽂件到服务器 *

* @author Administrator * */

public class SocketHttpRequester { /**

* 直接通过HTTP协议提交数据到服务器,实现如下⾯表单提交功能:

*

* @param path 上传路径(注：避免使⽤localhost或127.0.0.1这样的路径测试，因为它会指向⼿机模拟器，你可以使⽤http://www.iteye.cn或http://192.168.1.101:8083这样的路径测试) * @param params 请求参数 key为参数名,value为参数值 * @param file 上传⽂件

*/

public static boolean post(String path, Map params, FormFile[] files) throws Exception{ final String BOUNDARY = \"---------------------------7da2137580612\"; //数据分隔线 final String endline = \"--\" + BOUNDARY + \"--\\r\\n\";//数据结束标志

int fileDataLength = 0;

for(FormFile uploadFile : files){//得到⽂件类型数据的总长度 StringBuilder fileExplain = new StringBuilder(); fileExplain.append(\"--\");

fileExplain.append(BOUNDARY); fileExplain.append(\"\\r\\n\");

fileExplain.append(\"Content-Disposition: form-data;name=\\\"\"+ uploadFile.getParameterName()+\"\\\";filename=\\\"\"+ uploadFile.getFilname() + \"\\\"\\r\\n\"); fileExplain.append(\"Content-Type: \"+ uploadFile.getContentType()+\"\\r\\n\\r\\n\"); fileExplain.append(\"\\r\\n\");

fileDataLength += fileExplain.length(); if(uploadFile.getInStream()!=null){

fileDataLength += uploadFile.getFile().length(); }else{

fileDataLength += uploadFile.getData().length; } }

StringBuilder textEntity = new StringBuilder();

for (Map.Entry entry : params.entrySet()) {//构造⽂本类型参数的实体数据 textEntity.append(\"--\");

textEntity.append(BOUNDARY); textEntity.append(\"\\r\\n\");

textEntity.append(\"Content-Disposition: form-data; name=\\\"\"+ entry.getKey() + \"\\\"\\r\\n\\r\\n\"); textEntity.append(entry.getValue()); textEntity.append(\"\\r\\n\"); }

//计算传输给服务器的实体数据总长度

int dataLength = textEntity.toString().getBytes().length + fileDataLength + endline.getBytes().length;

URL url = new URL(path);

int port = url.getPort()==-1 ? 80 : url.getPort();

Socket socket = new Socket(InetAddress.getByName(url.getHost()), port); OutputStream outStream = socket.getOutputStream(); //下⾯完成HTTP请求头的发送

String requestmethod = \"POST \"+ url.getPath()+\" HTTP/1.1\\r\\n\"; outStream.write(requestmethod.getBytes());

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 outStream.write(accept.getBytes());

String language = \"Accept-Language: zh-CN\\r\\n\"; outStream.write(language.getBytes());

String contenttype = \"Content-Type: multipart/form-data; boundary=\"+ BOUNDARY+ \"\\r\\n\"; outStream.write(contenttype.getBytes());

String contentlength = \"Content-Length: \"+ dataLength + \"\\r\\n\"; outStream.write(contentlength.getBytes()); String alive = \"Connection: Keep-Alive\\r\\n\"; outStream.write(alive.getBytes());

String host = \"Host: \"+ url.getHost() +\":\"+ port +\"\\r\\n\"; outStream.write(host.getBytes());

//写完HTTP请求头后根据HTTP协议再写⼀个回车换⾏ outStream.write(\"\\r\\n\".getBytes()); //把所有⽂本类型的实体数据发送出来

outStream.write(textEntity.toString().getBytes()); //把所有⽂件类型的实体数据发送出来 for(FormFile uploadFile : files){

StringBuilder fileEntity = new StringBuilder(); fileEntity.append(\"--\");

fileEntity.append(BOUNDARY); fileEntity.append(\"\\r\\n\");

fileEntity.append(\"Content-Disposition: form-data;name=\\\"\"+ uploadFile.getParameterName()+\"\\\";filename=\\\"\"+ uploadFile.getFilname() + \"\\\"\\r\\n\"); fileEntity.append(\"Content-Type: \"+ uploadFile.getContentType()+\"\\r\\n\\r\\n\"); outStream.write(fileEntity.toString().getBytes()); if(uploadFile.getInStream()!=null){ byte[] buffer = new byte[1024]; int len = 0;

while((len = uploadFile.getInStream().read(buffer, 0, 1024))!=-1){ outStream.write(buffer, 0, len); }

uploadFile.getInStream().close(); }else{

outStream.write(uploadFile.getData(), 0, uploadFile.getData().length); }

outStream.write(\"\\r\\n\".getBytes()); }

//下⾯发送数据结束标志，表⽰数据已经结束 outStream.write(endline.getBytes());

BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));

if(reader.readLine().indexOf(\"200\")==-1){//读取web服务器返回的数据，判断请求码是否为200，如果不是200，代表请求失败 return false; }

outStream.flush(); outStream.close(); reader.close(); socket.close(); return true; } /**

* 提交数据到服务器

* @param path 上传路径(注：避免使⽤localhost或127.0.0.1这样的路径测试，因为它会指向⼿机模拟器，你可以使⽤http://www.itcast.cn或http://192.168.1.10:8080这样的路径测试) * @param params 请求参数 key为参数名,value为参数值 * @param file 上传⽂件 */

public static boolean post(String path, Map params, FormFile file) throws Exception{ return post(path, params, new FormFile[]{file}); }}

4)、新建MainActivity类，实现每隔5秒上传⼀次

package com.ljq.activity;import java.io.File;

import java.util.HashMap;import java.util.Map;

import android.app.Activity;import android.os.Bundle;

import android.os.Environment;import android.os.Handler;import android.util.Log;

import com.ljq.utils.FormFile;

import com.ljq.utils.SocketHttpRequester;public class MainActivity extends Activity { private File file;

private Handler handler;

private static final String TAG=\"MainActivity\";

@Override

public void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.main); Log.i(TAG, \"onCreate\");

file = new File(Environment.getExternalStorageDirectory(), \"123.rmvb\"); Log.i(TAG, \"照⽚⽂件是否存在：\"+file); handler=new Handler(); handler.post(runnable); }

Runnable runnable=new Runnable() {

public void run() {

Log.i(TAG, \"runnable run\"); uploadFile(file);

handler.postDelayed(runnable, 5000); } }; /**

* 上传图⽚到服务器 *

* @param imageFile 包含路径 */

public void uploadFile(File imageFile) { Log.i(TAG, \"upload start\"); try {

String requestUrl = \"http://192.168.1.101:8083/upload/upload/execute.do\"; //请求普通信息

Map params = new HashMap(); params.put(\"username\张三\"); params.put(\"pwd\ params.put(\"age\

params.put(\"fileName\ //上传⽂件

FormFile formfile = new FormFile(imageFile.getName(), imageFile, \"image\

SocketHttpRequester.post(requestUrl, params, formfile); Log.i(TAG, \"upload success\"); } catch (Exception e) {

Log.i(TAG, \"upload error\"); e.printStackTrace(); }

Log.i(TAG, \"upload end\"); }}

5)、修改清单⽂件

启动模拟器，运⾏如下：

⼆、服务器端⽤来获取Android端上传过来的⽂件信息1)、新建⼀个web项⽬命名为upload，⽬录结构如下注意：记得加⼊struts2 jar包，需加⼊的jar如下2)、新建action类，命名为UploadAction，内容如下

package com.ljq.action;import java.io.File;

import java.io.FileInputStream;import java.io.FileOutputStream;import java.io.IOException;

import javax.servlet.http.HttpServletRequest;import org.apache.struts2.ServletActionContext;import com.opensymphony.xwork2.ActionSupport;/**

* 获取Android端上传过来的信息 *

* @author Administrator * */

@SuppressWarnings(\"serial\")

public class UploadAction extends ActionSupport { // 上传⽂件域

private File image; // 上传⽂件类型

private String imageContentType; // 封装上传⽂件名

private String imageFileName; // 接受依赖注⼊的属性 private String savePath; @Override

public String execute() {

HttpServletRequest request=ServletActionContext.getRequest(); FileOutputStream fos = null; FileInputStream fis = null; try {

System.out.println(\"获取Android端传过来的普通信息：\");

System.out.println(\"⽤户名：\"+request.getParameter(\"username\")); System.out.println(\"密码：\"+request.getParameter(\"pwd\")); System.out.println(\"年龄：\"+request.getParameter(\"age\"));

System.out.println(\"⽂件名：\"+request.getParameter(\"fileName\")); System.out.println(\"获取Android端传过来的⽂件信息：\"); System.out.println(\"⽂件存放⽬录: \"+getSavePath()); System.out.println(\"⽂件名称: \"+imageFileName); System.out.println(\"⽂件⼤⼩: \"+image.length());

System.out.println(\"⽂件类型: \"+imageContentType);

fos = new FileOutputStream(getSavePath() + \"/\" + getImageFileName()); fis = new FileInputStream(getImage()); byte[] buffer = new byte[1024]; int len = 0;

while ((len = fis.read(buffer)) != -1) { fos.write(buffer, 0, len); }

System.out.println(\"⽂件上传成功\"); } catch (Exception e) {

System.out.println(\"⽂件上传失败\"); e.printStackTrace(); } finally {

close(fos, fis); }

return SUCCESS; }

/**

* ⽂件存放⽬录 *

* @return */

public String getSavePath() throws Exception{

return ServletActionContext.getServletContext().getRealPath(savePath); }

public void setSavePath(String savePath) { this.savePath = savePath; }

public File getImage() { return image; }

public void setImage(File image) { this.image = image; }

public String getImageContentType() { return imageContentType; }

public void setImageContentType(String imageContentType) { this.imageContentType = imageContentType; }

public String getImageFileName() { return imageFileName; }

public void setImageFileName(String imageFileName) { this.imageFileName = imageFileName; }

private void close(FileOutputStream fos, FileInputStream fis) { if (fis != null) { try {

fis.close(); fis=null;

} catch (IOException e) {

System.out.println(\"FileInputStream关闭失败\"); e.printStackTrace(); } }

if (fos != null) { try {

fos.close(); fis=null;

} catch (IOException e) {

System.out.println(\"FileOutputStream关闭失败\"); e.printStackTrace(); } } }}

3)、配置struts.xml

\"-//Apache Software Foundation//DTD Struts Configuration 2.0//EN\" \"http://struts.apache.org/dtds/struts-2.0.dtd\">

/image

/WEB-INF/page/message.jsp

4)、配置web.xml

struts2

org.apache.struts2.dispatcher.ng.filter.StrutsPrepareAndExecuteFilter

struts2 /*

strutsCleanup

org.apache.struts2.dispatcher.ActionContextCleanUp

strutsCleanup /*

index.jsp

运⾏结构如下：

获取Android端传过来的普通信息：⽤户名：张三密码：zhangsan年龄：21

⽂件名：123.rmvb

获取Android端传过来的⽂件信息：

⽂件存放⽬录: D:\\apache-tomcat-6.0.18\\webapps\d\\image⽂件名称: 123.rmvb⽂件⼤⼩: 3962649

⽂件类型: application/octet-stream⽂件上传成功

以上就是本⽂的全部内容，希望对⼤家的学习有所帮助，也希望⼤家多多⽀持。