本實(shí)例實(shí)現(xiàn)每隔5秒上傳一次,通過(guò)服務(wù)器端獲取手機(jī)上傳過(guò)來(lái)的文件信息并做相應(yīng)處理;采用Android+Struts2技術(shù)。
一、Android端實(shí)現(xiàn)文件上傳
1)、新建一個(gè)Android項(xiàng)目命名為androidUpload,目錄結(jié)構(gòu)如下:

2)、新建FormFile類,用來(lái)封裝文件信息
package com.ljq.utils;import java.io.File;import java.io.FileInputStream;import java.io.FileNotFoundException;import java.io.InputStream;/** * 上傳文件 */public class FormFile { /* 上傳文件的數(shù)據(jù) */ private byte[] data; private InputStream inStream; private File file; /* 文件名稱 */ private String filname; /* 請(qǐng)求參數(shù)名稱*/ private String parameterName; /* 內(nèi)容類型 */ 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類,封裝上傳文件到服務(wù)器代碼
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;/** * 上傳文件到服務(wù)器 * * @author Administrator * */public class SocketHttpRequester { /** * 直接通過(guò)HTTP協(xié)議提交數(shù)據(jù)到服務(wù)器,實(shí)現(xiàn)如下面表單提交功能: * <FORM METHOD=POST ACTION="http://192.168.1.101:8083/upload/servlet/UploadServlet" enctype="multipart/form-data"> <INPUT TYPE="text" NAME="name"> <INPUT TYPE="text" NAME="id"> <input type="file" name="imagefile"/> <input type="file" name="zip"/> </FORM> * @param path 上傳路徑(注:避免使用localhost或127.0.0.1這樣的路徑測(cè)試,因?yàn)樗鼤?huì)指向手機(jī)模擬器,你可以使用http://www.iteye.cn或http://192.168.1.101:8083這樣的路徑測(cè)試) * @param params 請(qǐng)求參數(shù) key為參數(shù)名,value為參數(shù)值 * @param file 上傳文件 */ public static boolean post(String path, Map<String, String> params, FormFile[] files) throws Exception{ final String BOUNDARY = "---------------------------7da2137580612"; //數(shù)據(jù)分隔線 final String endline = "--" + BOUNDARY + "--/r/n";//數(shù)據(jù)結(jié)束標(biāo)志 int fileDataLength = 0; for(FormFile uploadFile : files){//得到文件類型數(shù)據(jù)的總長(zhǎng)度 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<String, String> entry : params.entrySet()) {//構(gòu)造文本類型參數(shù)的實(shí)體數(shù)據(jù) 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"); } //計(jì)算傳輸給服務(wù)器的實(shí)體數(shù)據(jù)總長(zhǎng)度 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請(qǐng)求頭的發(fā)送 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.ms-powerpoint, application/msword, */*/r/n"; 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請(qǐng)求頭后根據(jù)HTTP協(xié)議再寫一個(gè)回車換行 outStream.write("/r/n".getBytes()); //把所有文本類型的實(shí)體數(shù)據(jù)發(fā)送出來(lái) outStream.write(textEntity.toString().getBytes()); //把所有文件類型的實(shí)體數(shù)據(jù)發(fā)送出來(lái) 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()); } //下面發(fā)送數(shù)據(jù)結(jié)束標(biāo)志,表示數(shù)據(jù)已經(jīng)結(jié)束 outStream.write(endline.getBytes()); BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream())); if(reader.readLine().indexOf("200")==-1){//讀取web服務(wù)器返回的數(shù)據(jù),判斷請(qǐng)求碼是否為200,如果不是200,代表請(qǐng)求失敗 return false; } outStream.flush(); outStream.close(); reader.close(); socket.close(); return true; } /** * 提交數(shù)據(jù)到服務(wù)器 * @param path 上傳路徑(注:避免使用localhost或127.0.0.1這樣的路徑測(cè)試,因?yàn)樗鼤?huì)指向手機(jī)模擬器,你可以使用http://www.itcast.cn或http://192.168.1.10:8080這樣的路徑測(cè)試) * @param params 請(qǐng)求參數(shù) key為參數(shù)名,value為參數(shù)值 * @param file 上傳文件 */ public static boolean post(String path, Map<String, String> params, FormFile file) throws Exception{ return post(path, params, new FormFile[]{file}); }}4)、新建MainActivity類,實(shí)現(xiàn)每隔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); } }; /** * 上傳圖片到服務(wù)器 * * @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"; //請(qǐng)求普通信息 Map<String, String> params = new HashMap<String, String>(); params.put("username", "張三"); params.put("pwd", "zhangsan"); params.put("age", "21"); params.put("fileName", imageFile.getName()); //上傳文件 FormFile formfile = new FormFile(imageFile.getName(), imageFile, "image", "application/octet-stream"); 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)、修改清單文件
<?xml version="1.0" encoding="utf-8"?><manifest xmlns:android="http://schemas.android.com/apk/res/android" package="com.ljq.activity" android:versionCode="1" android:versionName="1.0"> <application android:icon="@drawable/icon" android:label="@string/app_name"> <activity android:name=".MainActivity" android:label="@string/app_name"> <intent-filter> <action android:name="android.intent.action.MAIN" /> <category android:name="android.intent.category.LAUNCHER" /> </intent-filter> </activity> </application> <uses-sdk android:minSdkVersion="4" /> <uses-permission android:name="android.permission.INTERNET" /> </manifest>
啟動(dòng)模擬器,運(yùn)行如下:

二、服務(wù)器端用來(lái)獲取Android端上傳過(guò)來(lái)的文件信息
1)、新建一個(gè)web項(xiàng)目命名為upload,目錄結(jié)構(gòu)如下

注意:記得加入struts2 jar包,需加入的jar如下

2)、新建action類,命名為UploadAction,內(nèi)容如下
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端上傳過(guò)來(lái)的信息 * * @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端傳過(guò)來(lái)的普通信息:"); 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端傳過(guò)來(lái)的文件信息:"); 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關(guān)閉失敗"); e.printStackTrace(); } } if (fos != null) { try { fos.close(); fis=null; } catch (IOException e) { System.out.println("FileOutputStream關(guān)閉失敗"); e.printStackTrace(); } } }}3)、配置struts.xml
<?xml version="1.0" encoding="UTF-8" ?><!DOCTYPE struts PUBLIC "-//Apache Software Foundation//DTD Struts Configuration 2.0//EN" "http://struts.apache.org/dtds/struts-2.0.dtd"><struts> <!-- 該屬性指定需要Struts2處理的請(qǐng)求后綴,該屬性的默認(rèn)值是action,即所有匹配*.action的請(qǐng)求都由Struts2處理。 如果用戶需要指定多個(gè)請(qǐng)求后綴,則多個(gè)后綴之間以英文逗號(hào)(,)隔開。 --> <constant name="struts.action.extension" value="do"/> <!-- 設(shè)置瀏覽器是否緩存靜態(tài)內(nèi)容,默認(rèn)值為true(生產(chǎn)環(huán)境下使用),開發(fā)階段最好關(guān)閉 --> <constant name="struts.serve.static.browserCache" value="false"/> <!-- 當(dāng)struts的配置文件修改后,系統(tǒng)是否自動(dòng)重新加載該文件,默認(rèn)值為false(生產(chǎn)環(huán)境下使用),開發(fā)階段最好打開 --> <constant name="struts.configuration.xml.reload" value="true"/> <!-- 開發(fā)模式下使用,這樣可以打印出更詳細(xì)的錯(cuò)誤信息 --> <constant name="struts.devMode" value="true"/> <!-- 默認(rèn)的視圖主題 --> <constant name="struts.ui.theme" value="simple"/> <!--<constant name="struts.objectFactory" value="spring" />--> <!--解決亂碼 --> <constant name="struts.i18n.encoding" value="UTF-8"/> <!-- 指定允許上傳的文件最大字節(jié)數(shù)。默認(rèn)值是2097152(2M) --> <constant name="struts.multipart.maxSize" value="22097152"/> <!-- 設(shè)置上傳文件的臨時(shí)文件夾,默認(rèn)使用javax.servlet.context.tempdir --> <constant name="struts.multipart.saveDir " value="d:/tmp"/> <package name="upload" namespace="/upload" extends="struts-default"> <action name="execute" class="com.ljq.action.UploadAction"> <!-- 動(dòng)態(tài)設(shè)置savePath的屬性值 --> <param name="savePath">/image</param> <result name="success">/WEB-INF/page/message.jsp</result> </action> </package></struts>
4)、配置web.xml
<?xml version="1.0" encoding="UTF-8"?><web-app version="2.4" xmlns="http://java.sun.com/xml/ns/j2ee" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://java.sun.com/xml/ns/j2ee http://java.sun.com/xml/ns/j2ee/web-app_2_4.xsd"> <filter> <filter-name>struts2</filter-name> <filter-class> org.apache.struts2.dispatcher.ng.filter.StrutsPrepareAndExecuteFilter </filter-class> </filter> <filter-mapping> <filter-name>struts2</filter-name> <url-pattern>/*</url-pattern> </filter-mapping> <filter> <filter-name>strutsCleanup</filter-name> <filter-class> org.apache.struts2.dispatcher.ActionContextCleanUp </filter-class> </filter> <filter-mapping> <filter-name>strutsCleanup</filter-name> <url-pattern>/*</url-pattern> </filter-mapping> <welcome-file-list> <welcome-file>index.jsp</welcome-file> </welcome-file-list></web-app>
運(yùn)行結(jié)構(gòu)如下:
獲取Android端傳過(guò)來(lái)的普通信息:
用戶名:張三
密碼:zhangsan
年齡:21
文件名:123.rmvb
獲取Android端傳過(guò)來(lái)的文件信息:
文件存放目錄: D:/apache-tomcat-6.0.18/webapps/upload/image
文件名稱: 123.rmvb
文件大小: 3962649
文件類型: application/octet-stream
文件上傳成功
以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持武林網(wǎng)。
新聞熱點(diǎn)
疑難解答
圖片精選