ssh框架--圖片(檔案)上傳
阿新 • • 發佈:2019-02-05
看過很多關於圖片上傳的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配置檔案中配置加入:
第二步:前端提交:提交的方式有兩種,第一種是表單提交,這裡需要注意的是form表單中form標籤中加入屬性enctype="multipart/form-data",並且method必須是post提交方式,如下所示:<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"/>
第二種提交方式是非同步提交,需要匯入jquery.form.js檔案,form表單屬性同第一種一致,但不用寫action屬性。<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>
<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包。首
先 的