1. 程式人生 > >ssh框架--圖片(檔案)上傳

ssh框架--圖片(檔案)上傳

看過很多關於圖片上傳的demo,但是都比較亂。本案例經過我幾次調整,整理成了一個工具類,與大家分享之。

第一步:準備工作。如果status2.3.4版本以下,struts2在上傳檔案的時候 upload.parseRequest(request)值將為空,解決辦法是寫一個繼承JakartaMultiPartRequest類的子類,如下所示:

public class RequestParseWrapper extends JakartaMultiPartRequest {
	@Override
	public void parse(HttpServletRequest arg0, String arg1) throws IOException {
		
	}
}

同時在struts.xml配置檔案中配置加入:

<bean type= "org.apache.struts2.dispatcher.multipart.MultiPartRequest"   
		name= "myRequestParser"   class= "com.zho.app.status.request.file.RequestParseWrapper"   
		scope= "default"  optional= "true"/>   
	<constant name= "struts.multipart.handler" value= "myRequestParser"/> 
第二步:前端提交:提交的方式有兩種,第一種是表單提交,這裡需要注意的是form表單中form標籤中加入屬性enctype="multipart/form-data",並且method必須是post提交方式,如下所示:
<form action="<%=basePath %>/sharedFarmUsers_sp/posting.action" enctype="multipart/form-data" method="post" id="mytest_id">
		<input type="text" name="userid" /><br /> 
		<input type="file" id="f2" name="image" /><br /> 
		<input type="submit" value="上傳" /><br />
</form>
第二種提交方式是非同步提交,需要匯入jquery.form.js檔案,form表單屬性同第一種一致,但不用寫action屬性。
<form id="contentForm" method="post" enctype="multipart/form-data">
		<div>
			<span>正文內容</span>
			<div>
			<input type="text" name="consultationid" value="${consultationid }">
			<select id="type_id" name="type">
				<option value="0">圖片</option>
				<option value="1">文字</option>
			</select>
			<div id=typeview>
			</div>
			<!-- <input type="file" name="value"/><br>
			<textarea rows="3" cols="80" name="value"></textarea> -->
			</div><br>
		</div>
		<p><input type="button" value="正文編輯" onclick="consultationTextEditor()"/><input type="reset" value="重置"/></p>
		<p><span>${success }</span></p>
</form>
<script type="text/javascript">
function consultationTextEditor(){
var option={
type:'POST',
url:'<%=path %>/sharedFarmAdmin_sp/consultationTextEditor.action',
dataType:'text',
data: '',
success:function(data){
}
};
$("#contentForm").ajaxSubmit(option);
}
</script>
第三步:後臺接受把圖片存入伺服器中,把傳入伺服器中的圖片地址存入資料庫。
public void posting() throws IOException{
		HttpServletRequest request = ServletActionContext.getRequest();
		HttpServletResponse response = ServletActionContext.getResponse();
		response.setContentType("text/json; charset=utf-8");
	        response.setHeader("Cache-Control", "no-cache"); //取消瀏覽器快取
		PrintWriter out = response.getWriter();
		Map<String, Object> map = MyUpload.upLoad(request,"image");//獲取到普通文字userid存入到map,圖片image上傳至伺服器並把地址存入map中
		String json = "{\"success\":"+0+"}";
		String zjson = "{\"success\":"+1+"}";
		Integer save = sharedFarmUsersManager.save("Posts", map);//採用動態的方式把資料存入資料庫
		if(save != -1){
			out.print(json);
		}else{
			out.print(zjson);
		}
		out.flush();
        out.close();
	}
以下是經過本人整合的圖片(檔案)上傳工具類:
package com.zho.app.util.check;

import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.UnsupportedEncodingException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.UUID;

import javax.servlet.ServletContext;
import javax.servlet.http.HttpServletRequest;

import org.apache.commons.fileupload.FileItem;
import org.apache.commons.fileupload.FileUploadException;
import org.apache.commons.fileupload.disk.DiskFileItemFactory;
import org.apache.commons.fileupload.servlet.ServletFileUpload;
import org.apache.commons.io.FilenameUtils;
import org.apache.struts2.ServletActionContext;

import com.sun.jersey.api.client.Client;
import com.sun.jersey.api.client.WebResource;

/**
 * 
 * @author zho
 * @Time 2017-08-08
 * 作用:form表單提交方式   圖片上傳模板
 */
public class MyUpload {
	public static Map<String, Object> upLoad(HttpServletRequest request){
		return MyUpload.upLoad(request,null);
	}
	public static Map<String, Object> upLoad(HttpServletRequest request, String type){
		// 判斷表單是否支援檔案上傳。即:enctype="multipart/form-data"
		boolean isMultipartContent = ServletFileUpload
				.isMultipartContent(request);
		if (!isMultipartContent) {
			throw new RuntimeException("your form is not multipart/form-data");
		}
		// 建立一個DiskFileItemfactory工廠類
		DiskFileItemFactory factory = new DiskFileItemFactory();
		String contextPath = request.getContextPath();
		// 指定臨時檔案的儲存目錄
		factory.setRepository(new File("d:\\"));//測試用
		// 建立一個ServletFileUpload核心物件
		ServletFileUpload fileUpload = new ServletFileUpload(factory);
		// 解決上傳表單項亂碼問題
		fileUpload.setHeaderEncoding("UTF-8");
		Map<String, Object> map = new HashMap<String, Object>();
		// 解析request物件,並得到一個表單項的集合
		try {
			// 限制上傳檔案的大小
			// fileUpload.setFileSizeMax(1024*1024*3);//表示3M大小
			// fileUpload.setSizeMax(1024*1024*6);
			List<FileItem> fileItems = fileUpload.parseRequest(request);
			for (FileItem fileitem : fileItems) {
				if (fileitem.isFormField()) {
					// 普通表單項
					String[] formField = processFormField(fileitem);
					if(formField[1] != null && !formField[1].isEmpty() ) map.put(formField[0], formField[1]);
				} else {
					// 上傳表單項
					if(!(fileitem.getName() == null || fileitem.getName().isEmpty())){
					String[] UploadField = processUploadField(fileitem,type);
					map.put(UploadField[0], UploadField[1]);
					}
				}
			}
		} catch (FileUploadException e) {
			e.printStackTrace();
		}
		return map;
		
	}
	/**
	 * 頭像上傳
	 */
	public static Map<String, Object> upLoadToAvatar(HttpServletRequest request, String type){
		// 判斷表單是否支援檔案上傳。即:enctype="multipart/form-data"
		boolean isMultipartContent = ServletFileUpload
				.isMultipartContent(request);
		if (!isMultipartContent) {
			throw new RuntimeException("your form is not multipart/form-data");
		}
		// 建立一個DiskFileItemfactory工廠類
		DiskFileItemFactory factory = new DiskFileItemFactory();
		String contextPath = request.getContextPath();
		// 指定臨時檔案的儲存目錄
		factory.setRepository(new File("d:\\"));//測試用
		// 建立一個ServletFileUpload核心物件
		ServletFileUpload fileUpload = new ServletFileUpload(factory);
		// 解決上傳表單項亂碼問題
		fileUpload.setHeaderEncoding("UTF-8");
		Map<String, Object> map = new HashMap<String, Object>();
		// 解析request物件,並得到一個表單項的集合
		try {
			// 限制上傳檔案的大小
			// fileUpload.setFileSizeMax(1024*1024*3);//表示3M大小
			// fileUpload.setSizeMax(1024*1024*6);
			List<FileItem> fileItems = fileUpload.parseRequest(request);
			String id = "";
			for (FileItem fileitem : fileItems) {
				if (fileitem.isFormField()) {
					// 普通表單項
					String[] formField = processFormField(fileitem);
					if(formField[1] != null && !formField[1].isEmpty() ) map.put(formField[0], formField[1]);
					id = formField[1];
				} 
				if (!(fileitem.isFormField())) {
					// 上傳表單項
					if(!(fileitem.getName() == null || fileitem.getName().isEmpty())){
					String[] UploadField = processUploadField(fileitem,type,id);
					map.put(UploadField[0], UploadField[1]);
					}
				}
			}
		} catch (FileUploadException e) {
			e.printStackTrace();
		}
		return map;
		
	}
	/**
	 * 跨伺服器上傳
	 */
	public static Map<String, Object> upLoadCrossServer(HttpServletRequest request){
		// 判斷表單是否支援檔案上傳。即:enctype="multipart/form-data"
		boolean isMultipartContent = ServletFileUpload
				.isMultipartContent(request);
		if (!isMultipartContent) {
			throw new RuntimeException("your form is not multipart/form-data");
		}
		// 建立一個DiskFileItemfactory工廠類
		DiskFileItemFactory factory = new DiskFileItemFactory();
		factory.setRepository(new File("d:\\"));// 指定臨時檔案的儲存目錄
		// 建立一個ServletFileUpload核心物件
		ServletFileUpload fileUpload = new ServletFileUpload(factory);
		// 解決上傳表單項亂碼問題
		fileUpload.setHeaderEncoding("UTF-8");
		Map<String, Object> map = new HashMap<String, Object>();
		// 解析request物件,並得到一個表單項的集合
		try {
			// 限制上傳檔案的大小
			// fileUpload.setFileSizeMax(1024*1024*3);//表示3M大小
			// fileUpload.setSizeMax(1024*1024*6);
			List<FileItem> fileItems = fileUpload.parseRequest(request);
			for (FileItem fileitem : fileItems) {
				if (fileitem.isFormField()) {
					// 普通表單項
					String[] formField = processFormField(fileitem);
					map.put(formField[0], formField[1]);
				} else {
					// 上傳表單項
					if(!(fileitem.getName() == null || fileitem.getName().isEmpty())){
					String[] UploadField = processUploadFieldCrossServer(fileitem);
					map.put(UploadField[0], UploadField[1]);
					}
				}
			}
		} catch (FileUploadException e) {
			e.printStackTrace();
		}
		return map;
	}
	// 普通表單項
		private static String[] processFormField(FileItem fileitem) {
			String fieldname = null;
			String fieldvalue = null;					
			try {
				fieldname = fileitem.getFieldName();// 欄位名
				fieldvalue = fileitem.getString("UTF-8");// 欄位值
				//fieldvalue = new String(fieldvalue.getBytes("iso-8859-1"),"utf-8");
				System.out.println(fieldname + "=" + fieldvalue);
			} catch (UnsupportedEncodingException e) {
				e.printStackTrace();
			}
			return new String[]{fieldname,fieldvalue};
		}
		// 上傳表單項
		private static String[] processUploadField(FileItem fileitem, String type) {
			HttpServletRequest request = ServletActionContext.getRequest();
			ServletContext servletContext = ServletActionContext.getServletContext();
			String lastf = "";
			String fieldName = "";
			try {
				// 得到檔案輸入流
				//InputStream is = request.getInputStream();

				// 建立一個檔案存檔的目錄
				String directoryRealPath = servletContext.getRealPath("/upload");//測試用
				File storeDirectory = new File(directoryRealPath);// 即代表檔案又代表目錄
				if (!storeDirectory.exists()) {
					boolean b = storeDirectory.mkdirs();// 建立一個指定的目錄
				}
				// 得到上傳的名子
				String filename = fileitem.getName();
				System.out.println("filename"+filename);
				if (filename != null && !(filename.isEmpty())) {
					// filename =
					// filename.substring(filename.lastIndexOf(File.separator)+1);
					filename = FilenameUtils.getName(filename);// 效果同上
				}
				// 解決檔案同名的問題
				filename = UUID.randomUUID() + "_" + filename;
				// 目錄打散
				// String childDirectory = makeChildDirectory(storeDirectory); //
				// 2015-10-19
				String childDirectory = makeChildDirectory(storeDirectory, filename); // a/b
				System.out.println(3333);
				System.out.println(storeDirectory + childDirectory
						+ File.separator + filename);
				File lastfile  = new File(storeDirectory, childDirectory + File.separator + filename);
				lastf = lastfile.toString();
				lastf = lastf.replaceAll("\\\\", "/");//把地址的反斜線轉換成斜線
				int index = lastf.lastIndexOf("upload");
				lastf = lastf.substring(index);
				// 得到欄位名
				fieldName = fileitem.getFieldName();
				if(!(type == null || type.isEmpty())){
					fieldName = type;
				}
				// 上傳檔案,自動刪除臨時檔案
				fileitem.write(lastfile);
				fileitem.delete();
			} catch (IOException e) {
				e.printStackTrace();
			} catch (Exception e) {
				e.printStackTrace();
			}
			return new String[]{fieldName,lastf};
			}
		// 上傳表單項 頭像
		private static String[] processUploadField(FileItem fileitem, String type, String id ) {
			HttpServletRequest request = ServletActionContext.getRequest();
			ServletContext servletContext = ServletActionContext.getServletContext();
			String lastf = "";
			String fieldName = "";
			try {
				// 得到檔案輸入流
				//InputStream is = request.getInputStream();

				// 建立一個檔案存檔的目錄
//				String directoryRealPath = servletContext.getRealPath("/upload/data/avatar");//測試用
				File storeDirectory = new File(directoryRealPath);// 即代表檔案又代表目錄
				if (!storeDirectory.exists()) {
					boolean b = storeDirectory.mkdirs();// 建立一個指定的目錄
				}
				StringBuffer zid = new StringBuffer(id);
				int length = id.length();
				for(int i = 0 ;i<10-length ; i++){
					zid = zid.insert(0, "0");
				}
				
				StringBuffer insert = zid.insert(3, "/").insert(7, "/").insert(10, "/");
				String endstr = insert.toString();
				String folder = insert.substring(0, insert.length()-2);
				File file = new File(directoryRealPath,folder);
				if (!file.exists()) {
					boolean b = file.mkdirs();// 建立一個指定的目錄
				}
				String zzid = endstr+"_avatar.jpg";
				File lastfile  = new File(storeDirectory, zzid);
				
				lastf = lastfile.toString();
				lastf = lastf.replaceAll("\\\\", "/");//把地址的反斜線轉換成斜線
				int index = lastf.lastIndexOf("upload");
				lastf = lastf.substring(index);
				System.out.println(lastf+"-------");
				// 得到欄位名
				fieldName = fileitem.getFieldName();
				if(!(type == null || type.isEmpty())){
					fieldName = type;
				}
				// 上傳檔案,自動刪除臨時檔案
				fileitem.write(lastfile);
				fileitem.delete();
			} catch (IOException e) {
				e.printStackTrace();
			} catch (Exception e) {
				e.printStackTrace();
			}
			return new String[]{fieldName,lastf};
			}
		// 上傳表單項通過ios
		private static String[] processUploadFieldByIOS(FileItem fileitem) {
			HttpServletRequest request = ServletActionContext.getRequest();
			ServletContext servletContext = ServletActionContext.getServletContext();
			String lastf = "";
			String fieldName = "";
			try {
				// 得到檔案輸入流
				//InputStream is = request.getInputStream();

				// 建立一個檔案存檔的目錄
				String directoryRealPath = servletContext.getRealPath("/upload");//這種方式專案重新部署之後上傳的檔案會被刪除
				File storeDirectory = new File(directoryRealPath);// 即代表檔案又代表目錄
				if (!storeDirectory.exists()) {
					boolean b = storeDirectory.mkdirs();// 建立一個指定的目錄
				}
				// 得到上傳的名子
				String filename = fileitem.getName();
				System.out.println("filename"+filename);
				if (filename != null) {
					// filename =
					// filename.substring(filename.lastIndexOf(File.separator)+1);
					filename = FilenameUtils.getName(filename);// 效果同上
				}
				// 解決檔案同名的問題
				filename = UUID.randomUUID() + "_" + filename;
				// 目錄打散
				// String childDirectory = makeChildDirectory(storeDirectory); //
				// 2015-10-19
				String childDirectory = makeChildDirectory(storeDirectory, filename); // a/b
				System.out.println(3333);
				System.out.println(storeDirectory + childDirectory
						+ File.separator + filename);
				File lastfile  = new File(storeDirectory, childDirectory + File.separator + filename);
				lastf = lastfile.toString();
				lastf = lastf.replaceAll("\\\\", "/");//把地址的反斜線轉換成斜線
				int index = lastf.lastIndexOf("upload");
				lastf = lastf.substring(index);
				System.out.println(lastf+"-------");
				// 得到欄位名
				//fieldName = fileitem.getFieldName();
				fieldName = "image";
				// 上傳檔案,自動刪除臨時檔案
				fileitem.write(lastfile);
				fileitem.delete();
			} catch (IOException e) {
				e.printStackTrace();
			} catch (Exception e) {
				e.printStackTrace();
			}
			return new String[]{fieldName,lastf};
			}
		// 目錄打散
		private static String makeChildDirectory(File storeDirectory, String filename) {
			int hashcode = filename.hashCode();// 返回字元轉換的32位hashcode碼
			System.out.println(hashcode);
			String code = Integer.toHexString(hashcode); // 把hashcode轉換為16進位制的字元
															// abdsaf2131safsd
			System.out.println(code);
			String childDirectory = code.charAt(0) + "/"
					+ code.charAt(1); // a/b
			// 建立指定目錄
			File file = new File(storeDirectory, childDirectory);
			if (!file.exists()) {
				file.mkdirs();
			}
			return childDirectory;
		}
		// 上傳表單項
		private static String[] processUploadFieldCrossServer(FileItem fileitem) {
			String lastf = "";
			String fieldName = "";
			try {
				// 得到檔案輸入流
				InputStream is = fileitem.getInputStream();

				// 得到欄位名
				fieldName = fileitem.getFieldName();
				
				// 得到上傳的名子
				String filename = fileitem.getName();
				// 處理檔名
				if (filename != null) {
					// filename =
					// filename.substring(filename.lastIndexOf(File.separator)+1);
					filename = FilenameUtils.getName(filename);// 效果同上
				}

				// 解決檔案同名的問題
				filename = UUID.randomUUID() + "_" + filename;
				
				String host = "http://127.0.0.1:8081/image_zho";
				//建立jesy伺服器,進行跨伺服器上傳
				Client client = Client.create();
				
				lastf = host+"/upload/"+filename;
				
				//把檔案關聯到遠端伺服器
				// 在storeDirectory下,建立完整目錄下的檔案
				WebResource resource = client.resource(host+"/upload/"+filename);// 絕對目錄/日期目錄/檔名
				//上傳
				resource.put(String.class, is);

				is.close();

				fileitem.delete();
			} catch (IOException e) {
				e.printStackTrace();
			}
			return new String[]{fieldName,lastf};
		}
	 
}
注:跨伺服器上傳需要引入修改圖片伺服器檔案上傳許可權,並且需要匯入jersey-core  jar包和jersey-client  jar包。


先 的